Files
@ 83dc5e1e183e
Branch filter:
Location: Morevna/src/datafile.py - annotation
83dc5e1e183e
604 B
text/x-python
regularly flushing the hash tree to the disk during a data transfer
bb3b53ee15d6 bb3b53ee15d6 bb3b53ee15d6 5c80ca07f00c bb3b53ee15d6 bb3b53ee15d6 bb3b53ee15d6 6a0ab4fe9f5e 6a0ab4fe9f5e 6a0ab4fe9f5e bb3b53ee15d6 bb3b53ee15d6 5c80ca07f00c 5c80ca07f00c bb3b53ee15d6 6a0ab4fe9f5e 6a0ab4fe9f5e bb3b53ee15d6 6a0ab4fe9f5e 6a0ab4fe9f5e bb3b53ee15d6 6a0ab4fe9f5e 6a0ab4fe9f5e bb3b53ee15d6 6a0ab4fe9f5e 6a0ab4fe9f5e bb3b53ee15d6 bb3b53ee15d6 bb3b53ee15d6 | from hashtree import HashTree
BLOCK_SIZE = HashTree.BLOCK_SIZE
class DataFile:
def __init__(self, file_handle):
self._last_index = 0
self._f = file_handle
@staticmethod
def open(filename, mode="rb"):
return DataFile(open(filename, mode=mode))
def write_at(self, i, block_data):
if i!=self._last_index+1:
self._f.seek(i*BLOCK_SIZE)
self._f.write(block_data)
self._last_index = i
def read_from(self, i, byte_count=BLOCK_SIZE):
if i!=self._last_index+1:
self._f.seek(i*BLOCK_SIZE)
self._last_index = i
return self._f.read(byte_count)
def close(self):
self._f.close()
|