(tid, fid, data_bytes)
| 553 | callback(results) |
| 554 | |
| 555 | def sendReadRequest(tid, fid, data_bytes): |
| 556 | read_count = min(4280, self.max_read_size) |
| 557 | m = SMB2Message(SMB2ReadRequest(fid, 0, read_count)) |
| 558 | m.tid = tid |
| 559 | self._sendSMBMessage(m) |
| 560 | self.pending_requests[m.mid] = _PendingRequest(m.mid, int(time.time()) + timeout, readCB, errback, |
| 561 | tid = tid, fid = fid, data_bytes = data_bytes) |
| 562 | |
| 563 | def readCB(read_message, **kwargs): |
| 564 | self._pushToArray(messages_history, read_message) |
nothing calls this directly
no test coverage detected