QtForum.org »
QtForum.org » Qt »
Qt Programming »Dear visitor, welcome to QtForum.org. If this is your first visit here, please read the Help. It explains in detail how this page works. To use all features of this page, you should consider registering. Please use the registration form, to register here or read more information about the registration process. If you are already registered, please login here.
Wednesday, September 8th 2004, 3:30pm
Thursday, September 9th 2004, 9:18am
|
Source code |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 |
else if(m_Status == SYNC || m_Status == START)
{
if(identifier == "event")
{
//Send identifier to let the client know what is being send
clientSocket->writeBlock((char*) &identifierLength, sizeof(identifierLength));
clientSocket->writeBlock(const_cast<char*>(identifier.data()), identifierLength);
qDebug("CLIENT<%d>: Sending Event: comp<%d> elem<%d> event<%d> name<%s>", m_Status, event.componentID, event.elementID, event.eventID, event.name.data());
clientSocket->writeBlock((char*) &event.elementID, sizeof(event.elementID));
clientSocket->writeBlock((char*) &event.eventID, sizeof(event.eventID));
clientSocket->writeBlock((char*) &event.componentID, sizeof(event.componentID));
//send events name
clientSocket->writeBlock((char*) &eventNameLength, sizeof(eventNameLength));
if( eventNameLength > 1 )
{
clientSocket->writeBlock(const_cast<char*>(eventName.data()), eventNameLength);
}
//check size before sending parameter
clientSocket->writeBlock((char*) ¶meterLength, sizeof(parameterLength) );
if( parameterLength > 1 )
{
clientSocket->writeBlock(const_cast<char*>(event.parameter.data()), parameterLength);
}
//send value list
clientSocket->writeBlock((char*)&valuesLength,sizeof(valuesLength));
if( valuesLength > 1)
{
for(int i=0; i<valuesLength; i++)
{
clientSocket->writeBlock((char*)&event.values[i],sizeof(event.values[i]));
}
}
clientSocket->flush();
}
}
|
|
|
Source code |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 |
else if(identifier == "event")
{
ReadStateEvent current = READ_ELEMENTID;
socket->readBlock((char*) &elementID, sizeof(elementID));
socket->readBlock((char*) &eventID, sizeof(eventID));
socket->readBlock((char*) &componentID, sizeof(componentID));
socket->readBlock((char*) &eventNamelength, sizeof(eventNamelength));
if(eventNamelength > 1)
eventName = convertStreamToString(socket, eventNamelength);
qDebug("SERVER<%d>: Name is <%s>", m_Status, eventName.data());
//check size before reading valuelist
socket->readBlock((char*) ¶meterlength, sizeof(parameterlength));
if(parameterlength > 1)
parameter = convertStreamToString(socket, parameterlength);
//check size before reading values
socket->readBlock((char*) &valuesLength, valuesLength);
if(valuesLength > 1)
{
int value;
for(int x=0;x<valuesLength;x++)
{
socket->readBlock((char*)&value,sizeof(value));
values.push_front(value);
}
}
qDebug("SERVER: Event received: comp<%d> elem<%d> event<%d> name<%s>", componentID, elementID, eventID, eventName.data());
//Send event to MMIManager
MMIEvent event( componentID, elementID, eventID, values, parameter, eventName);
MMIManager::getMMIObject()->delegateEvent( event );
}
|
Friday, September 10th 2004, 12:17pm
|
|
Source code |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 |
class PacketLayer : public QObject
{
Q_OBJECT
public:
PacketLayer(QSocket* socket, QObject* parent=0, const char* name=0);
~PacketLayer();
void sendPacket(const QByteArray& data);
signals:
void newPacket(const QByteArray& data);
private slots:
void slotNewData();
private:
QSocket* m_socket;
QBuffer* m_buffer;
}
|
|
|
Source code |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 |
PacketLayet(QSocket* socket, QObject* parent, const char* name)
: QObject(parent, name), m_socket(socket)
{
m_buffer = new QBuffer();
QObject::connect(socket, SIGNAL(readyRead()), this, SLOT(slotNewData()));
}
PacketLayer::~PacketLayer()
{
delete m_buffer;
}
void PacketLayer::sendPacket(const QByteArray& data)
{
Q_UINT32 len = data.size();
QDataStream stream(m_socket);
stream << len;
stream.witeRawBytes(data.data(), data.size());
}
void PacketLayer::slotNewData()
{
// read data from socket, write into buffer
// when at least 4 bytes are available, read size
// when size is known wait until size+4 bytes are in buffer
// read size bytes from buffer into temp byte array, emit signal
}
|
Friday, September 10th 2004, 7:02pm
