Lines Matching refs:xs
40 static void writeMessageHeader (de::BlockBuffer<deUint8>& dst, xs::MessageType type, int messageSize)
42 deUint8 hdr[xs::MESSAGE_HEADER_SIZE];
43 xs::Message::writeHeader(type, messageSize, &hdr[0], xs::MESSAGE_HEADER_SIZE);
44 dst.write(xs::MESSAGE_HEADER_SIZE, &hdr[0]);
49 writeMessageHeader(dst, xs::MESSAGETYPE_KEEPALIVE, xs::MESSAGE_HEADER_SIZE);
59 int totalSize = xs::MESSAGE_HEADER_SIZE + nameSize + paramsSize + workDirSize + caseListSize;
61 writeMessageHeader(dst, xs::MESSAGETYPE_EXECUTE_BINARY, totalSize);
71 writeMessageHeader(dst, xs::MESSAGETYPE_STOP_EXECUTION, xs::MESSAGE_HEADER_SIZE);
292 bool hasHeader = m_curMsgPos >= xs::MESSAGE_HEADER_SIZE;
295 xs::MessageType messageType = (xs::MessageType)0;
299 xs::Message::parseHeader(&m_curMsgBuf[0], xs::MESSAGE_HEADER_SIZE, messageType, messageSize);
306 handleMessage(messageType, m_curMsgPos > xs::MESSAGE_HEADER_SIZE ? &m_curMsgBuf[xs::MESSAGE_HEADER_SIZE] : DE_NULL, messageSize-xs::MESSAGE_HEADER_SIZE);
312 size_t curSize = hasHeader ? messageSize : (size_t)xs::MESSAGE_HEADER_SIZE;
362 void TcpIpRecvThread::handleMessage (xs::MessageType messageType, const deUint8* data, size_t dataSize)
366 case xs::MESSAGETYPE_KEEPALIVE:
370 case xs::MESSAGETYPE_PROCESS_STARTED:
375 case xs::MESSAGETYPE_PROCESS_LAUNCH_FAILED:
377 xs::ProcessLaunchFailedMessage msg(data, dataSize);
383 case xs::MESSAGETYPE_PROCESS_FINISHED:
386 xs::ProcessFinishedMessage msg(data, dataSize);
392 case xs::MESSAGETYPE_PROCESS_LOG_DATA:
393 case xs::MESSAGETYPE_INFO:
398 if (messageType == xs::MESSAGETYPE_PROCESS_LOG_DATA)
477 XE_CHECK(deTimer_scheduleInterval(m_keepaliveTimer, xs::KEEPALIVE_SEND_INTERVAL));
520 if ((deInt64)curTime-(deInt64)lastKeepalive > xs::KEEPALIVE_TIMEOUT*1000)
