Home
last modified time | relevance | path

Searched refs:MESSAGE_HEADER_SIZE (Results 1 - 7 of 7) sorted by relevance

/third_party/vk-gl-cts/execserver/
H A DxsTestDriver.cpp194 const int minBytesAvailable = MESSAGE_HEADER_SIZE + MIN_MSG_PAYLOAD_SIZE; in pollBuffer()
201 int msgSize = MESSAGE_HEADER_SIZE+1; // One byte is reserved for terminating 0. in pollBuffer()
205 ? m_process->readTestLog(&m_dataMsgTmpBuf[MESSAGE_HEADER_SIZE], maxMsgSize-MESSAGE_HEADER_SIZE-1) in pollBuffer()
206 : m_process->readInfoLog(&m_dataMsgTmpBuf[MESSAGE_HEADER_SIZE], maxMsgSize-MESSAGE_HEADER_SIZE-1); in pollBuffer()
217 Message::writeHeader(msgType, msgSize, &m_dataMsgTmpBuf[0], MESSAGE_HEADER_SIZE); in pollBuffer()
H A DxsExecutionServer.cpp43 if (m_buffer.size() < MESSAGE_HEADER_SIZE) in isComplete()
51 return m_buffer.size() > MESSAGE_HEADER_SIZE ? &m_buffer[MESSAGE_HEADER_SIZE] : DE_NULL; in getMessageData()
57 return m_buffer.size() - MESSAGE_HEADER_SIZE; in getMessageDataSize()
63 if (m_buffer.size() < MESSAGE_HEADER_SIZE) in read()
65 while (m_buffer.size() < MESSAGE_HEADER_SIZE && in read()
69 DE_ASSERT(m_buffer.size() <= MESSAGE_HEADER_SIZE); in read()
71 if (m_buffer.size() == MESSAGE_HEADER_SIZE) in read()
78 if (m_buffer.size() >= MESSAGE_HEADER_SIZE) in read()
332 m_bufferOut.getNumFree() >= MESSAGE_HEADER_SIZE) in pollKeepAlives()
[all...]
H A DxsProtocol.cpp111 DE_ASSERT(m_buf.size() >= MESSAGE_HEADER_SIZE);
143 XS_CHECK_MSG(dataSize >= MESSAGE_HEADER_SIZE, "Incomplete header"); in parseHeader()
151 XS_CHECK_MSG(bufSize >= MESSAGE_HEADER_SIZE, "Incomplete header"); in writeHeader()
H A DxsProtocol.hpp38 MESSAGE_HEADER_SIZE = 8, enumerator
/third_party/vk-gl-cts/executor/
H A DxeTcpIpLink.cpp42 deUint8 hdr[xs::MESSAGE_HEADER_SIZE]; in writeMessageHeader()
43 xs::Message::writeHeader(type, messageSize, &hdr[0], xs::MESSAGE_HEADER_SIZE); in writeMessageHeader()
44 dst.write(xs::MESSAGE_HEADER_SIZE, &hdr[0]); in writeMessageHeader()
49 writeMessageHeader(dst, xs::MESSAGETYPE_KEEPALIVE, xs::MESSAGE_HEADER_SIZE); in writeKeepalive()
59 int totalSize = xs::MESSAGE_HEADER_SIZE + nameSize + paramsSize + workDirSize + caseListSize; in writeExecuteBinary()
71 writeMessageHeader(dst, xs::MESSAGETYPE_STOP_EXECUTION, xs::MESSAGE_HEADER_SIZE); in writeStopExecution()
292 bool hasHeader = m_curMsgPos >= xs::MESSAGE_HEADER_SIZE; in run()
299 xs::Message::parseHeader(&m_curMsgBuf[0], xs::MESSAGE_HEADER_SIZE, messageType, messageSize); in run()
306 handleMessage(messageType, m_curMsgPos > xs::MESSAGE_HEADER_SIZE ? &m_curMsgBuf[xs::MESSAGE_HEADER_SIZE] in run()
[all...]
/third_party/vk-gl-cts/execserver/tools/
H A DxsClient.cpp106 readBytes(socket, header, MESSAGE_HEADER_SIZE); in readMessage()
122 readBytes(socket, messageBuf, messageSize-MESSAGE_HEADER_SIZE); in readMessage()
H A DxsTest.cpp112 readBytes(socket, header, MESSAGE_HEADER_SIZE); in readMessage()
128 readBytes(socket, messageBuf, messageSize-MESSAGE_HEADER_SIZE); in readMessage()

Completed in 5 milliseconds