(write_message, **kwargs)
| 1120 | closeFid(tid, fid, offset = offset) |
| 1121 | |
| 1122 | def writeCB(write_message, **kwargs): |
| 1123 | # To avoid crazy memory usage when saving large files, we do not save every write_message in messages_history. |
| 1124 | if write_message.status == 0: |
| 1125 | sendWrite(kwargs['tid'], kwargs['fid'], kwargs['offset']) |
| 1126 | else: |
| 1127 | if self.pbar: |
| 1128 | self.pbar.close() |
| 1129 | self.pbar = None |
| 1130 | self._pushToArray(messages_history, write_message) |
| 1131 | closeFid(kwargs['tid'], kwargs['fid']) |
| 1132 | errback(OperationFailure('Failed to store %s on %s: Write failed' % ( path, service_name ), messages_history)) |
| 1133 | |
| 1134 | def closeFid(tid, fid, error = None, offset = None): |
| 1135 | m = SMB2Message(SMB2CloseRequest(fid)) |
nothing calls this directly
no test coverage detected