[Zodb-checkins] CVS: Zope3/lib/python/ZEO/tests - ConnectionTests.py:1.4

Tim Peters tim.one@comcast.net
Thu, 19 Dec 2002 16:21:57 -0500


Update of /cvs-repository/Zope3/lib/python/ZEO/tests
In directory cvs.zope.org:/tmp/cvs-serv1807/lib/python/ZEO/tests

Modified Files:
	ConnectionTests.py 
Log Message:
Use a class logger for ConnectionTests.py.


=== Zope3/lib/python/ZEO/tests/ConnectionTests.py 1.3 => 1.4 ===
--- Zope3/lib/python/ZEO/tests/ConnectionTests.py:1.3	Mon Dec 16 18:10:57 2002
+++ Zope3/lib/python/ZEO/tests/ConnectionTests.py	Thu Dec 19 16:21:56 2002
@@ -21,8 +21,7 @@
 import asyncore
 import tempfile
 import threading
-
-import zLOG
+import logging
 
 from ZEO.ClientStorage import ClientStorage
 from ZEO.Exceptions import Disconnected
@@ -61,7 +60,8 @@
         for i in 1, 2, ...
         """
         self.__super_setUp()
-        zLOG.LOG("testZEO", zLOG.INFO, "setUp() %s" % self.id())
+        self.logger = logging.getLogger("testZEO")
+        self.logger.warn("setUp() %s", self.id())
         self.file = tempfile.mktemp()
         self.addr = []
         self._pids = []
@@ -71,7 +71,7 @@
 
     def tearDown(self):
         """Try to cause the tests to halt"""
-        zLOG.LOG("testZEO", zLOG.INFO, "tearDown() %s" % self.id())
+        self.logger.warn("tearDown() %s", self.id())
         if getattr(self, '_storage', None) is not None:
             self._storage.close()
             if hasattr(self._storage, 'cleanup'):
@@ -116,9 +116,8 @@
     def startServer(self, create=True, index=0,
                     read_only=False, ro_svr=False, keep=False):
         addr = self.addr[index]
-        zLOG.LOG("testZEO", zLOG.INFO,
-                 "startServer(create=%d, index=%d, read_only=%d) @ %s" %
-                 (create, index, read_only, addr))
+        self.logger.warn("startServer(create=%d, index=%d, read_only=%d) @ %s",
+                         create, index, read_only, addr)
         path = "%s.%d" % (self.file, index)
         conf = self.getConfig(path, create, read_only)
         zeoport, adminaddr, pid = forker.start_zeo_server(
@@ -127,8 +126,8 @@
         self._servers.append(adminaddr)
 
     def shutdownServer(self, index=0):
-        zLOG.LOG("testZEO", zLOG.INFO, "shutdownServer(index=%d) @ %s" %
-                 (index, self._servers[index]))
+        self.logger.warn("shutdownServer(index=%d) @ %s", index,
+                         self._servers[index])
         adminaddr = self._servers[index]
         if adminaddr is not None:
             forker.shutdown_zeo_server(adminaddr)
@@ -322,11 +321,9 @@
         oid = self._storage.new_oid()
         obj = MinPO(12)
         self._dostore(oid, data=obj)
-        zLOG.LOG("checkReconnection", zLOG.INFO,
-                 "About to shutdown server")
+        self.logger.warn("checkReconnection: About to shutdown server")
         self.shutdownServer()
-        zLOG.LOG("checkReconnection", zLOG.INFO,
-                 "About to restart server")
+        self.logger.warn("checkReconnection: About to restart server")
         self.startServer(create=False)
         oid = self._storage.new_oid()
         obj = MinPO(12)
@@ -336,9 +333,9 @@
                 break
             except (Disconnected, select.error,
                     threading.ThreadError, socket.error):
-                zLOG.LOG("checkReconnection", zLOG.INFO,
-                         "Error after server restart; retrying.",
-                         error=sys.exc_info())
+                self.logger.warn("checkReconnection: "
+                                 "Error after server restart; retrying.",
+                                 exc_info=True)
                 get_transaction().abort()
                 time.sleep(0.1) # XXX how long to sleep
             # XXX This is a bloody pain.  We're placing a heavy burden
@@ -346,7 +343,7 @@
             # write robust code.  Need to think about implementing
             # John Heintz's suggestion to make sure all exceptions
             # inherit from POSException.
-        zLOG.LOG("checkReconnection", zLOG.INFO, "finished")
+        self.logger.warn("checkReconnection: finished")
 
     def checkBadMessage1(self):
         # not even close to a real message