326
326
while len(self._buffer) >= tosize:
327
327
buffer = self._buffer.value()
328
pos, fcks, cks = rolling_search(self._known_blocks, self._block_already_exists, buffer, BLOCK_SIZE)
328
pos, cks = rolling_search(self._known_blocks, self._block_already_exists, buffer, BLOCK_SIZE)
330
330
if pos > 0: self.commit_buffer(buffer[:pos], 0)
331
331
data = buffer[pos:tosize]