(enum_message, **kwargs)
| 1721 | self._pushToArray(messages_history, m) |
| 1722 | |
| 1723 | def enumSnapshotsCB(enum_message, **kwargs): |
| 1724 | self._pushToArray(messages_history, enum_message) |
| 1725 | if enum_message.status == 0: |
| 1726 | results = [ ] |
| 1727 | snapshots_count = struct.unpack('<I', enum_message.payload.out_data[4:8])[0] |
| 1728 | for i in range(0, snapshots_count): |
| 1729 | s = DataFaultToleranceStrategy.data_bytes_decode(enum_message.payload.out_data[12+i*50:12+48+i*50]) |
| 1730 | results.append(datetime(*list(map(int, ( s[5:9], s[10:12], s[13:15], s[16:18], s[19:21], s[22:24] ))))) |
| 1731 | closeFid(kwargs['tid'], kwargs['fid'], results = results) |
| 1732 | else: |
| 1733 | closeFid(kwargs['tid'], kwargs['fid'], status = enum_message.status) |
| 1734 | |
| 1735 | def closeFid(tid, fid, status = None, results = None): |
| 1736 | m = SMB2Message(SMB2CloseRequest(fid)) |
nothing calls this directly
no test coverage detected