encode: delay completion until all our messages have been delivered

diff --git a/allmydata/encode.py b/allmydata/encode.py
index 946db1e04a4df258a041b685eb1ad0bc5a1444d4..a9b3d4759b7591dd9210ad72c8c514eac3ec1bc1 100644 (file)
--- a/allmydata/encode.py
+++ b/allmydata/encode.py
@@ -7,9 +7,10 @@ class Encoder(object):
         self.m = m
 
     def do_upload(self, landlords):
+        dl = []
         data = self.infile.read()
         for (peerid, bucket_num, remotebucket) in landlords:
-            remotebucket.callRemote('write', data)
-            remotebucket.callRemote('finalise')
+            dl.append(remotebucket.callRemote('write', data))
+            dl.append(remotebucket.callRemote('close'))
 
-        return defer.succeed()
+        return defer.DeferredList(dl)