Lines Matching full:messagebuffer
84 bool TestDriver::poll (ByteBuffer& messageBuffer)
93 if (writeMessage(messageBuffer, ProcessLaunchFailedMessage(m_lastLaunchFailure.c_str())))
104 if (writeMessage(messageBuffer, ProcessStartedMessage()))
118 gotProcessData = pollLogFile(messageBuffer) || gotProcessData;
119 gotProcessData = pollInfo(messageBuffer) || gotProcessData;
143 gotProcessData = pollLogFile(messageBuffer) || gotProcessData;
144 gotProcessData = pollInfo(messageBuffer) || gotProcessData;
164 if (writeMessage(messageBuffer, ProcessFinishedMessage(m_lastExitCode)))
182 bool TestDriver::pollLogFile (ByteBuffer& messageBuffer)
184 return pollBuffer(messageBuffer, MESSAGETYPE_PROCESS_LOG_DATA);
187 bool TestDriver::pollInfo (ByteBuffer& messageBuffer)
189 return pollBuffer(messageBuffer, MESSAGETYPE_INFO);
192 bool TestDriver::pollBuffer (ByteBuffer& messageBuffer, MessageType msgType)
196 if (messageBuffer.getNumFree() < minBytesAvailable)
199 const int maxMsgSize = de::min((int)m_dataMsgTmpBuf.size(), messageBuffer.getNumFree());
219 // Write to messagebuffer.
220 messageBuffer.pushFront(&m_dataMsgTmpBuf[0], msgSize);
227 bool TestDriver::writeMessage (ByteBuffer& messageBuffer, const Message& message)
232 if (messageBuffer.getNumFree() < (int)buf.size())
235 messageBuffer.pushFront(&buf[0], (int)buf.size());
