From: David Stainton Date: Fri, 17 Apr 2015 18:58:08 +0000 (+0100) Subject: Teach uploade deque append to not block (potentially?) X-Git-Url: https://git.rkrishnan.org/vdrive/%22file:/listings/frontends/components/com_hotproperty/css/simplejson/__init__.py.html?a=commitdiff_plain;h=877ddf8901351143e6231c03fd7331965db3d18d;p=tahoe-lafs%2Ftahoe-lafs.git Teach uploade deque append to not block (potentially?) --- diff --git a/src/allmydata/frontends/drop_upload.py b/src/allmydata/frontends/drop_upload.py index 47ab0301..4d51d6b6 100644 --- a/src/allmydata/frontends/drop_upload.py +++ b/src/allmydata/frontends/drop_upload.py @@ -2,7 +2,7 @@ import sys, os from collections import deque -from twisted.internet import defer +from twisted.internet import defer, reactor from twisted.python.failure import Failure from twisted.python.filepath import FilePath from twisted.application import service @@ -136,7 +136,7 @@ class DropUploader(service.MultiService): self._upload_deque.append(path) self._pending.add(path) if self.is_upload_ready: - self._process_deque() + reactor.callLater(0, self._process_deque) def _process_deque(self): while True: