projects
/
tahoe-lafs
/
tahoe-lafs.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
| inline |
side by side
(parent:
af9a9fb
)
Teach uploade deque append to not block (potentially?)
author
David Stainton
<dstainton415@gmail.com>
Fri, 17 Apr 2015 18:58:08 +0000
(19:58 +0100)
committer
Daira Hopwood
<daira@jacaranda.org>
Tue, 28 Apr 2015 18:39:37 +0000
(19:39 +0100)
src/allmydata/frontends/drop_upload.py
patch
|
blob
|
history
diff --git
a/src/allmydata/frontends/drop_upload.py
b/src/allmydata/frontends/drop_upload.py
index ed16c893c800909a626ff015c27d96dba9bb3a84..337128976ecd2917007d6028f01827d0df081b6a 100644
(file)
--- 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
@@
-141,7
+141,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: