Cross Reference: /vbox/src/VBox/ValidationKit/testdriver/txsclient.py

Lines Matching refs:cbMsg
245         cbMsg = 16 + len(abPayload);
247         abMsg.extend(u32ToByteArray(cbMsg));
297         cbMsg   = getU32(abHdr, 0);
301         if cbMsg < 16:
302             reporter.fatal('recvMsg: message length is out of range: %s (min 16 bytes)' % (cbMsg));
304         if cbMsg > 1024*1024:
305             reporter.fatal('recvMsg: message length is out of range: %s (max 1MB)' % (cbMsg));
313         if cbMsg > 16:
314             if cbMsg % 16:
315                 cbPadding = 16 - (cbMsg % 16);
318             abPayload = self.recvBytes(cbMsg - 16 + cbPadding, cMsTimeout, False);
332             if cbMsg > 16:
340         return (cbMsg, sOpcode, abPayload);
555         cbMsg, sOpcode, abPayload = self.oTransport.recvMsg(cMsTimeout, fNoDataOk);
557         self.t3oReply = (cbMsg, sOpcode, abPayload);
559         return (cbMsg, sOpcode, abPayload);
570         cbMsg, sOpcode, abPayload = self.recvReply(None, fNoDataOk);
571         if cbMsg is None:
598         cbMsg, sOpcode, abPayload = self.recvReply();
599         if cbMsg is None:
692             cbMsg, sOpcode, abPayload = self.recvReply();
693             if cbMsg is not None:
745             cbMsg, sOpcode, abPayload = (None, None, None);
768                 if cbMsg is None:
769                     cbMsg, sOpcode, abPayload = self.recvReply(cMsTimeout=500, fNoDataOk=True);
770                     if cbMsg == None:
803                         sFailure = 'malformed output packet (%s, %u bytes)' % (sOpcode, cbMsg);
811                             % (oOut.uTxsClientCrc32 & 0xffffffff, uStreamCrc32, sOpcode, cbMsg);
849                 cbMsg, sOpcode, abPayload = (None, None, None);
880                         cbMsg, sOpcode, abPayload = self.oTransport.recvMsg(30000);
881                         if cbMsg is None:
886                             reporter.log('taskExecEx: ABORT reply: %s, %s, %s [ignored]' % (cbMsg, sOpcode, abPayload));
888                         reporter.log('taskExecEx: ABORT in process, ignoring reply: %s, %s, %s' % (cbMsg, sOpcode, abPayload));
1155                 cbMsg, sOpcode, abPayload = self.recvReply();
1156                 if cbMsg is None:
1245         Returns the last reply three-tuple: cbMsg, sOpcode, abPayload.