Home
last modified time | relevance | path

Searched refs:MESSAGE_HEADER_SIZE (Results 1 – 8 of 8) sorted by relevance

/external/deqp/execserver/
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()
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()
DxsProtocol.cpp111 DE_ASSERT(m_buf.size() >= MESSAGE_HEADER_SIZE); in finalize()
143 XS_CHECK_MSG(dataSize >= MESSAGE_HEADER_SIZE, "Incomplete header"); in parseHeader()
151 XS_CHECK_MSG(bufSize >= MESSAGE_HEADER_SIZE, "Incomplete header"); in writeHeader()
DxsProtocol.hpp38 MESSAGE_HEADER_SIZE = 8, enumerator
/external/deqp/executor/
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 …ype, m_curMsgPos > xs::MESSAGE_HEADER_SIZE ? &m_curMsgBuf[xs::MESSAGE_HEADER_SIZE] : DE_NULL, mess… in run()
312 size_t curSize = hasHeader ? messageSize : (size_t)xs::MESSAGE_HEADER_SIZE; in run()
/external/mtpd/
Dl2tp.c93 #define MESSAGE_HEADER_SIZE 20 macro
148 outgoing.length = MESSAGE_HEADER_SIZE; in set_message()
203 if ((incoming.length != ACK_SIZE && incoming.length < MESSAGE_HEADER_SIZE) in recv_packet()
243 int offset = MESSAGE_HEADER_SIZE; in get_attribute_raw()
/external/deqp/execserver/tools/
DxsClient.cpp106 readBytes(socket, header, MESSAGE_HEADER_SIZE); in readMessage()
122 readBytes(socket, messageBuf, messageSize-MESSAGE_HEADER_SIZE); in readMessage()
DxsTest.cpp112 readBytes(socket, header, MESSAGE_HEADER_SIZE); in readMessage()
128 readBytes(socket, messageBuf, messageSize-MESSAGE_HEADER_SIZE); in readMessage()