[Zodb-checkins] SVN: ZODB/branches/jim-thready-zeo/src/ZEO/ Got thready blob retrieval working.

[Jim Fulton]

Log message for revision 103725:
  Got thready blob retrieval working.
  

Changed:
  U   ZODB/branches/jim-thready-zeo/src/ZEO/StorageServer.py
  U   ZODB/branches/jim-thready-zeo/src/ZEO/zrpc/connection.py

-=-
Modified: ZODB/branches/jim-thready-zeo/src/ZEO/StorageServer.py
===================================================================
--- ZODB/branches/jim-thready-zeo/src/ZEO/StorageServer.py	2009-09-10 20:03:43 UTC (rev 103724)
+++ ZODB/branches/jim-thready-zeo/src/ZEO/StorageServer.py	2009-09-10 20:21:10 UTC (rev 103725)
@@ -640,7 +640,8 @@
         self.blob_log.append((oid, serial, data, filename))
 
     def sendBlob(self, oid, serial):
-        self.client.storeBlob(oid, serial, self.storage.loadBlob(oid, serial))
+        return self.client.storeBlob(
+            oid, serial, self.storage.loadBlob(oid, serial))
 
     def _delete(self, oid, serial):
         err = None
@@ -1369,7 +1370,6 @@
 
     @ZEO.thready.delayed
     def storeBlob(self, oid, serial, blobfilename):
-
         self.rpc.callAsync('receiveBlobStart', oid, serial)
 
         f = open(blobfilename, 'rb')

Modified: ZODB/branches/jim-thready-zeo/src/ZEO/zrpc/connection.py
===================================================================
--- ZODB/branches/jim-thready-zeo/src/ZEO/zrpc/connection.py	2009-09-10 20:03:43 UTC (rev 103724)
+++ ZODB/branches/jim-thready-zeo/src/ZEO/zrpc/connection.py	2009-09-10 20:21:10 UTC (rev 103725)
@@ -733,6 +733,7 @@
         client.
         """
         self.message_output(self.__outputIterator(iterator))
+        self.poll()
 
     def __outputIterator(self, iterator):
         for method, args in iterator: