[Zodb-checkins] SVN: ZODB/branches/jim-thready-zeo2/src/ZEO/StorageServer.py Don't assume we're sending invalidations in the asyncore thread.

[Jim Fulton]

Log message for revision 104256:
  Don't assume we're sending invalidations in the asyncore thread.
  
  (Also removed an unused import.)
  

Changed:
  U   ZODB/branches/jim-thready-zeo2/src/ZEO/StorageServer.py

-=-
Modified: ZODB/branches/jim-thready-zeo2/src/ZEO/StorageServer.py
===================================================================
--- ZODB/branches/jim-thready-zeo2/src/ZEO/StorageServer.py	2009-09-17 18:06:15 UTC (rev 104255)
+++ ZODB/branches/jim-thready-zeo2/src/ZEO/StorageServer.py	2009-09-17 18:09:51 UTC (rev 104256)
@@ -48,7 +48,7 @@
 from ZODB.POSException import StorageError, StorageTransactionError
 from ZODB.POSException import TransactionError, ReadOnlyError, ConflictError
 from ZODB.serialize import referencesf
-from ZODB.utils import u64, p64, oid_repr, mktemp
+from ZODB.utils import u64, p64, oid_repr
 from ZODB.loglevels import BLATHER
 
 
@@ -1324,7 +1324,7 @@
         self.rpc.callAsync('endVerify')
 
     def invalidateTransaction(self, tid, args):
-        self.rpc.callAsyncNoPoll('invalidateTransaction', tid, args)
+        self.rpc.callAsync('invalidateTransaction', tid, args)
 
     def serialnos(self, arg):
         self.rpc.callAsync('serialnos', arg)
@@ -1350,7 +1350,7 @@
 class ClientStub308(ClientStub):
 
     def invalidateTransaction(self, tid, args):
-        self.rpc.callAsyncNoPoll(
+        self.rpc.callAsync(
             'invalidateTransaction', tid, [(arg, '') for arg in args])
 
     def invalidateVerify(self, oid):