Lines Matching refs:reporter

46 from testdriver import reporter;
72 reporter.errorXcpt('getSZ(,%u)' % (off));
101 reporter.error("invalid opcode length: %s" % (len(sOpcode)));
105 reporter.error("invalid opcode char #%u: %s" % (i, sOpcode));
109 reporter.error("invalid opcode char #%u: %s" % (i, sOpcode));
237 reporter.fatal('sendMsgInt: invalid opcode length: %d (\"%s\")' % (len(sOpcode), sOpcode));
241 reporter.fatal('sendMsgInt: invalid opcode encoding: \"%s\"' % (sOpcode));
262 reporter.fatalXcpt('sendMsgInt: packing problem...');
272 reporter.log2('sendMsgInt: op=%s len=%d to=%d' % (sOpcode, len(abMsg), cMsTimeout));
293 reporter.fatal('recvBytes(16) returns %d bytes!' % (len(abHdr)));
302 reporter.fatal('recvMsg: message length is out of range: %s (min 16 bytes)' % (cbMsg));
305 reporter.fatal('recvMsg: message length is out of range: %s (max 1MB)' % (cbMsg));
308 reporter.fatal('recvMsg: invalid opcode \"%s\"' % (sOpcode));
322 reporter.log('recvMsg: failed to recv payload bytes!');
336 reporter.fatal('recvMsg: crc error: expected %s, got %s' % (hex(uCrc32), hex(uActualCrc32)));
339 reporter.log2('recvMsg: op=%s len=%d' % (sOpcode, len(abPayload)));
362 reporter.fatal('sendMsg: uint32_t payload is out of range: %s' % (hex(o)));
368 reporter.fatal('sendMsg: unexpected payload type: %s (%s) (aoPayload=%s)' % (type(o), o, aoPayload));
371 reporter.fatalXcpt('sendMsg: screwed up the encoding code...');
433 reporter.maybeErr(not fIgnoreErrors, 'txsclient.Session.startTask: failed to cancel previous task.');
440 reporter.maybeErr(not fIgnoreErrors, 'txsclient.Session.startTask: race.');
480 reporter.log('txsclient: cancelling "%s"...' % (self.sStatus));
504 reporter.fatalXcpt('taskThread', 15);
507 reporter.log('taskThread: cancelled already');
511 reporter.log('taskThread: signalling task with status "%s", oTaskRc=%s' % (self.sStatus, oTaskRc));
587 reporter.maybeErr(self.fErr, 'recvAckLogged: %s transport error' % (sCommand));
589 reporter.maybeErr(self.fErr, 'recvAckLogged: %s response was %s: %s' % (sCommand, rc[0], rc[1]));
600 reporter.maybeErr(self.fErr, 'recvAckLogged: %s transport error' % (sCommand));
608 reporter.maybeErr(self.fErr, 'recvAckLogged: %s response was %s: %s' % (sCommand, sOpcode, getSZ(abPayload, 0, sOpcode)));
627 reporter.log2('asyncToSync(%s): returns False (#1)' % (fnAsync));
632 reporter.maybeErrXcpt(self.fErr, 'asyncToSync: waitForTask failed...');
634 #reporter.log2('asyncToSync(%s): returns False (#2)' % (fnAsync, rc));
638 #reporter.log2('asyncToSync(%s): returns %s' % (fnAsync, rc));
648 reporter.log2('taskConnect: connecting ...');
651 reporter.log('taskConnect: succeeded');
654 reporter.log2('taskConnect: unable to connect');
657 reporter.log2('taskConnect: timed out');
659 reporter.maybeErr(self.fErr, 'taskConnect: timed out');
663 reporter.maybeErr(self.fErr, 'taskConnect: cancelled');
703 reporter.errorXcpt('taskUuid got an invalid UUID string %s' % (sUuid,));
705 reporter.maybeErr(self.fErr, 'taskUuid did not get a UUID string.');
707 reporter.maybeErr(self.fErr, 'taskUuid got a bad reply: %s' % (sOpcode,));
709 reporter.maybeErr(self.fErr, 'taskUuid got 3xNone from recvReply.');
754 reporter.errorXcpt('read standard in');
778 reporter.maybeErr(self.fErr, 'taskExecEx: timed out');
804 reporter.maybeErr(self.fErr, 'taskExecEx: %s' % (sFailure));
812 reporter.maybeErr(self.fErr, 'taskExecEx: %s' % (sFailure));
819 reporter.errorXcpt('taskExecEx: %s' % (sFailure));
825 reporter.log('taskExecEx: Standard input is ignored... why?');
834 reporter.maybeErr(self.fErr, 'taskExecEx: %s' % (sFailure));
845 reporter.maybeErr(self.fErr, 'taskExecEx: %s' % (sFailure));
858 reporter.log('taskExecEx: Out of order STDIN, got reply: %s, %s, %s [ignored]'
862 reporter.maybeErr(self.fErr, 'taskExecEx: Pending STDIN, no reply after 5 secs!');
877 reporter.log('taskExecEx: sending ABORT...');
882 reporter.maybeErr(self.fErr, 'taskExecEx: Pending ABORT, no reply after 30 secs!')
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));
905 reporter.log('taskExecEx: returns %s' % (rc));
1023 reporter.errorXcpt('taskUpload: failed to open "%s"' % (sLocalFile));
1092 reporter.maybeErr(self.fErr, 'taskUpload: transport error waiting for ACK');
1094 reporter.maybeErr(self.fErr, 'taskUpload: DATA response was %s: %s' % (rc[0], rc[1]));
1114 reporter.errorXcpt('taskDownload: failed to open "%s"' % (sLocalFile));
1124 reporter.errorXcpt();
1157 reporter.maybeErr(self.fErr, 'taskDownload got 3xNone from recvReply.');
1164 reporter.maybeErr(self.fErr, 'taskDownload got a error reply: opcode="%s" details="%s"'
1169 reporter.maybeErr(self.fErr, 'taskDownload got a bad DATA packet: len=%u' % (len(abPayload)));
1173 reporter.maybeErr(self.fErr, 'taskDownload got a bad EOF packet: len=%u' % (len(abPayload)));
1182 reporter.maybeErr(self.fErr, 'taskDownload got a bad CRC: mycrc=%s remotecrc=%s'
1194 reporter.errorXcpt('I/O error writing to "%s"' % (sRemoteFile));
1340 standard error goes directly to reporter.log(). The testpipe is piped
1341 to reporter.xxxx.
1345 oStdOut = reporter.FileWrapper('%sstdout' % sPrefix);
1346 oStdErr = reporter.FileWrapper('%sstderr' % sPrefix);
1347 if fWithTestPipe: oTestPipe = reporter.FileWrapperTestPipe();
1714 reporter.log2('TransportTcp::cancelConnect: fIsConnecting=%s oSocket=%s' % (self.fIsConnecting, self.oSocket));
1720 reporter.log2('TransportTcp::cancelConnect: closing the socket');
1726 reporter.log2('TransportTcp::cancelConnect: wakeup call');
1728 except: reporter.logXcpt();
1730 except: reporter.logXcpt();
1738 reporter.log2('TransportTcp::_connectAsServer: oSocket=%s, cMsTimeout=%u' % (oSocket, cMsTimeout));
1744 reporter.errorXcpt('socket.listen(1) failed');
1751 reporter.errorXcpt('socket.bind((%s,%s)) failed' % (self.sHostname, self.uPort));
1756 reporter.errorXcpt('socket.listen(1) failed');
1769 reporter.log2('TransportTcp::accept: operation in progress (%s)...' % (e,));
1775 reporter.log('socket.select() on accept was canceled');
1778 reporter.logXcpt('socket.select() on accept');
1787 reporter.log('socket.accept() was canceled');
1789 reporter.log('socket.accept() timed out');
1792 reporter.errorXcpt('socket.accept() failed');
1795 reporter.errorXcpt('socket.accept() failed');
1820 reporter.log2('TransportTcp::connect: operation in progress (%s)...' % (e,));
1831 reporter.fatalXcpt('socket.select() on connect failed');
1844 reporter.fatalXcpt('socket.connect((%s,%s)) failed; iRc=%s' % (self.sHostname, self.uPort, iRc));
1845 reporter.log2('TransportTcp::connect: rc=%s iRc=%s' % (rc, iRc));
1847 reporter.fatalXcpt('socket.connect((%s,%s)) failed' % (self.sHostname, self.uPort));
1853 reporter.log2('TransportTcp::connect: cMsTimeout=%s sHostname=%s uPort=%s' % (cMsTimeout, self.sHostname, self.uPort));
1857 reporter.fatalXcpt('socket.socket() failed');
1863 reporter.fatalXcpt('socket.socket() failed');
1871 except: reporter.logXcpt('socket.socketpair() failed');
1905 reporter.log2('TransportTcp::connect: returning %s' % (rc,));
1917 reporter.error('shutdown(SHUT_WR)');
1939 reporter.error('TransportTcp.sendBytes: No connection.');
1949 reporter.errorXcpt('TranportTcp.sendBytes: %s bytes' % (len(abMsg)));
1958 reporter.error('TranportTcp.sendBytes: %s bytes timed out (1)' % (len(abMsg)));
1965 reporter.error('TranportTcp.sendBytes: select returned with exception');
1968 reporter.error('TranportTcp.sendBytes: %s bytes timed out (2)' % (len(abMsg)));
1971 reporter.errorXcpt('TranportTcp.sendBytes: select failed');
1981 reporter.errorXcpt('TranportTcp.sendBytes: %s bytes' % (len(abMsg)));
1995 reporter.error('TransportTcp.recvBytes(%s,%s): No connection.' % (cb, cMsTimeout));
2006 reporter.errorXcpt('TranportTcp.recvBytes: 0/%s bytes' % (cb,));
2018 reporter.error('TranportTcp.recvBytes: %s/%s bytes timed out (1)' % (len(self.abReadAhead), cb));
2025 reporter.error('TranportTcp.recvBytes: select returned with exception');
2029 reporter.error('TranportTcp.recvBytes: %s/%s bytes timed out (2) fNoDataOk=%s'
2033 reporter.errorXcpt('TranportTcp.recvBytes: select failed');
2040 reporter.error('TranportTcp.recvBytes: %s/%s bytes (%s) - connection has been shut down'
2048 reporter.log('recv => exception %s' % (oXcpt,));
2051 reporter.errorXcpt('TranportTcp.recvBytes: %s/%s bytes (%s)' % (len(self.abReadAhead), cb, fNoDataOk));
2058 #reporter.log('recv => None len(self.abReadAhead) -> %d' % (len(self.abReadAhead), ));
2088 reporter.log2('openTcpSession(%s, %s, %s, %s, %s)' % \
2094 reporter.errorXcpt(None, 15);
2110 reporter.errorXcpt(None, 15);