[Zope-Checkins] CVS: ZODB3/ZEO - ServerStub.py:1.9.28.1
Jeremy Hylton
jeremy@zope.com
Thu, 12 Jun 2003 14:58:53 -0400
Update of /cvs-repository/ZODB3/ZEO
In directory cvs.zope.org:/tmp/cvs-serv12655/ZEO
Modified Files:
Tag: jeremy-more-mysteries-branch
ServerStub.py
Log Message:
Expose method to make deferred calls rather than accessing rpc directly.
=== ZODB3/ZEO/ServerStub.py 1.9 => 1.9.28.1 ===
--- ZODB3/ZEO/ServerStub.py:1.9 Tue Oct 1 14:49:12 2002
+++ ZODB3/ZEO/ServerStub.py Thu Jun 12 14:58:53 2003
@@ -33,6 +33,12 @@
"""
self.rpc = rpc
+ def deferred_call(self, method, release, *args):
+ return self.rpc.deferred_call(method, release, *args)
+
+ def deferred_result(self, msgid):
+ return self.rpc.deferred_wait(msgid)
+
def _update(self):
"""Handle pending incoming messages.
@@ -72,6 +78,9 @@
def zeoLoad(self, oid):
return self.rpc.call('zeoLoad', oid)
+ def tpc_finish(self, id):
+ return self.rpc.call('tpc_finish', id)
+
def storea(self, oid, serial, data, version, id):
self.rpc.callAsync('storea', oid, serial, data, version, id)
@@ -80,9 +89,6 @@
def vote(self, trans_id):
return self.rpc.call('vote', trans_id)
-
- def tpc_finish(self, id):
- return self.rpc.call('tpc_finish', id)
def tpc_abort(self, id):
self.rpc.callAsync('tpc_abort', id)