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