(read_message, **kwargs)
| 561 | tid = tid, fid = fid, data_bytes = data_bytes) |
| 562 | |
| 563 | def readCB(read_message, **kwargs): |
| 564 | self._pushToArray(messages_history, read_message) |
| 565 | if read_message.status == 0: |
| 566 | data_bytes = read_message.payload.data |
| 567 | |
| 568 | if data_bytes[3] & 0x02 == 0: |
| 569 | sendReadRequest(kwargs['tid'], kwargs['fid'], kwargs['data_bytes'] + data_bytes[24:]) |
| 570 | else: |
| 571 | decodeResults(kwargs['tid'], kwargs['fid'], kwargs['data_bytes'] + data_bytes[24:]) |
| 572 | else: |
| 573 | closeFid(kwargs['tid'], kwargs['fid']) |
| 574 | errback(OperationFailure('Failed to list shares: Unable to retrieve shared device list', messages_history)) |
| 575 | |
| 576 | def closeFid(tid, fid, results = None, error = None): |
| 577 | m = SMB2Message(SMB2CloseRequest(fid)) |
nothing calls this directly
no test coverage detected