(tid, fid, offset)
| 1103 | errback(OperationFailure('Failed to store %s on %s: Unable to open file' % ( path, service_name ), messages_history)) |
| 1104 | |
| 1105 | def sendWrite(tid, fid, offset): |
| 1106 | write_count = self.max_write_size |
| 1107 | data = file_obj.read(write_count) |
| 1108 | data_len = len(data) |
| 1109 | if data_len > 0: |
| 1110 | m = SMB2Message(SMB2WriteRequest(fid, data, offset)) |
| 1111 | m.tid = tid |
| 1112 | self._sendSMBMessage(m) |
| 1113 | if self.pbar: |
| 1114 | self.pbar.update(data_len) |
| 1115 | self.pending_requests[m.mid] = _PendingRequest(m.mid, int(time.time()) + timeout, writeCB, errback, tid = tid, fid = fid, offset = offset+data_len) |
| 1116 | else: |
| 1117 | if self.pbar: |
| 1118 | self.pbar.close() |
| 1119 | self.pbar = None |
| 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. |
nothing calls this directly
no test coverage detected