[Zope3-checkins] CVS: Zope3/src/zodb/zeo - client.py:1.13

Steve Alexander steve@cat-box.net
Fri, 6 Jun 2003 11:24:22 -0400


Update of /cvs-repository/Zope3/src/zodb/zeo
In directory cvs.zope.org:/tmp/cvs-serv25930/src/zodb/zeo

Modified Files:
	client.py 
Log Message:
Changed old style __implements__ declarations to new-style implements()
ones.


=== Zope3/src/zodb/zeo/client.py 1.12 => 1.13 ===
--- Zope3/src/zodb/zeo/client.py:1.12	Thu May 22 11:28:17 2003
+++ Zope3/src/zodb/zeo/client.py	Fri Jun  6 11:24:21 2003
@@ -30,7 +30,7 @@
 import time
 import logging
 
-from zope.interface import directlyProvides
+from zope.interface import directlyProvides, implements
 
 from zodb.zeo import cache
 from zodb.zeo.stubs import StorageServerStub
@@ -98,10 +98,10 @@
 
     # The exact storage interfaces depend on the server that the client
     # connects to.  We know that every storage must implement IStorage,
-    # but once connected we may change the instance's __implements__
-    # to reflect features available on the storage.
+    # but once connected we may change the interfaces that the instance
+    # provides to reflect features available on the storage.
 
-    __implements__ = IStorage
+    implements(IStorage)
 
     def __init__(self, addr, storage='1', cache_size=20 * MB,
                  name='', client=None, var=None,
@@ -408,7 +408,7 @@
             self._wait_sync()
 
     def update_interfaces(self):
-        # Update instance's __implements__ based on the server.
+        # Update what interfaces the instance provides based on the server.
         L = [IStorage]
         for name in self._info.get("implements", ()):
             if name == "IUndoStorage":
@@ -545,7 +545,7 @@
             # but has a read-only fallback connection, _conn_is_read_only
             # will be True.
             return self._conn_is_read_only
-        
+
     # XXX version should really be part of _info
 
     def getVersion(self):
@@ -891,7 +891,7 @@
         # Invalidations are sent by the ZEO server as a sequence of
         # oid, version pairs.  The DB's invalidate() method expects a
         # dictionary of oids.
-        
+
         # versions maps version names to dictionary of invalidations
         versions = {}
         for oid, version in invs:
@@ -901,7 +901,7 @@
         if self._db is not None:
             for v, d in versions.items():
                 self._db.invalidate(d, version=v)
-                
+
     def endVerify(self):
         """Server callback to signal end of cache validation."""
         if self._pickler is None: