(trans_message, **kwargs)
| 465 | errback(OperationFailure('Failed to list shares: Unable to locate Server Service RPC endpoint', messages_history)) |
| 466 | |
| 467 | def rpcBindCB(trans_message, **kwargs): |
| 468 | self._pushToArray(messages_history, trans_message) |
| 469 | if trans_message.status == 0: |
| 470 | m = SMB2Message(SMB2ReadRequest(kwargs['fid'], read_len = 1024, read_offset = 0)) |
| 471 | m.tid = kwargs['tid'] |
| 472 | self._sendSMBMessage(m) |
| 473 | self.pending_requests[m.mid] = _PendingRequest(m.mid, expiry_time, rpcReadCB, errback, tid = kwargs['tid'], fid = kwargs['fid']) |
| 474 | self._pushToArray(messages_history, m) |
| 475 | else: |
| 476 | closeFid(kwargs['tid'], kwargs['fid'], error = 'Failed to list shares: Unable to read from Server Service RPC endpoint') |
| 477 | |
| 478 | def rpcReadCB(read_message, **kwargs): |
| 479 | self._pushToArray(messages_history, read_message) |
nothing calls this directly
no test coverage detected