from ..common.results import TransferGreenletResult
from ..realistic import FileVerifier
+
# Make sure context has somewhere to store what we need
context.update(bunch.Bunch(
neads_first_read = collections.deque(),
files_iter = None,
))
+
class SafeTransferGreenlet(gevent.Greenlet):
def __init__(self, timeout=120):
gevent.Greenlet.__init__(self)
)
def _mark_chunk(self):
- ctime = time.time()
- self.chunks.append([self.offset, (ctime - self.last_seek) * 1000000000, ctime])
+ self.chunks.append([self.offset, (time.time() - self.last_seek) * 1000000000])
def seek(self, offset):
assert offset == 0
self.hash = hashlib.md5()
self.digest_size = self.hash.digest_size
self.digest = None
-
- # Save the last seek time as our start time, and the last chunks
+
+ # Save the last seek time as our start time, and the last chunks
self.start_time = self.last_seek
self.last_chunks = self.chunks
# Before emptying.
self.chunks = []
def _mark_chunk(self):
- ctime = time.time()
- self.chunks.append([self.size, (ctime - self.created_at) * 1000000000, ctime])
+ self.chunks.append([self.size, (time.time() - self.created_at) * 1000000000])
def write(self, data):
self.size += len(data)