[Checkins] SVN: zc.resumelb/trunk/src/zc/resumelb/util.py Some easy micro-optimizations.

[jim]

Log message for revision 125308:
  Some easy micro-optimizations.
  

Changed:
  U   zc.resumelb/trunk/src/zc/resumelb/util.py

-=-
Modified: zc.resumelb/trunk/src/zc/resumelb/util.py
===================================================================
--- zc.resumelb/trunk/src/zc/resumelb/util.py	2012-04-26 18:22:06 UTC (rev 125307)
+++ zc.resumelb/trunk/src/zc/resumelb/util.py	2012-04-26 18:29:08 UTC (rev 125308)
@@ -1,8 +1,8 @@
 from struct import pack, unpack
+from marshal import loads, dumps, dump, load
 import errno
 import gevent.queue
 import logging
-import marshal
 import socket
 import tempfile
 
@@ -41,12 +41,12 @@
             raise Disconnected()
         data += recieved
 
-    return rno, marshal.loads(data)
+    return rno, loads(data)
 
 def write_message(sock, rno, *a):
     to_send = []
     for data in a:
-        data = marshal.dumps(data)
+        data = dumps(data)
         to_send.append(pack(">II", rno, len(data)))
         to_send.append(data)
 
@@ -63,10 +63,12 @@
         data = data[sent:]
 
 def writer(writeq, sock, multiplexer):
+    get = writeq.get
+    write_message_ = write_message
     while 1:
-        rno, data = writeq.get()
+        rno, data = get()
         try:
-            write_message(sock, rno, data)
+            write_message_(sock, rno, data)
         except Disconnected:
             multiplexer.disconnected()
             return
@@ -158,7 +160,7 @@
 
         file = self.file
         file.seek(self.write_position)
-        marshal.dump(data, file)
+        dump(data, file)
         self.write_position = file.tell()
         if data:
             self.size_bytes += len(data)
@@ -170,7 +172,7 @@
                 queue = self.queue
                 while self.size > 0:
                     file.seek(self.read_position)
-                    data = marshal.load(file)
+                    data = load(file)
                     self.read_position = file.tell()
                     queue.put(data)
                     if self.size > 0:
@@ -182,7 +184,6 @@
                         assert size == -1
 
 
-
 class Worker:
 
     ReadQueue = gevent.queue.Queue