SVN: ZODB/branches/jim-transform-wrapping/src/ZODB/ checkpoint

Jim Fulton <[email protected]>
Newsgroups gmane.comp.python.zope.zodb.cvs
Message-ID <20100517214356.0F59B941B7__3420.3180148781$1274132644$gmane$org@cvs.zope.org>
Log message for revision 112433:
  checkpoint

Changed:
  U   ZODB/branches/jim-transform-wrapping/src/ZODB/tests/hexstorage.py
  U   ZODB/branches/jim-transform-wrapping/src/ZODB/utils.py

-=-
Modified: ZODB/branches/jim-transform-wrapping/src/ZODB/tests/hexstorage.py
===================================================================
--- ZODB/branches/jim-transform-wrapping/src/ZODB/tests/hexstorage.py	2010-05-17 21:32:33 UTC (rev 112432)
+++ ZODB/branches/jim-transform-wrapping/src/ZODB/tests/hexstorage.py	2010-05-17 21:43:55 UTC (rev 112433)
@@ -46,22 +46,22 @@
 
     def load(self, oid, version=''):
         data, serial = self.base.load(oid, version)
-        return data.decode('hex'), serial
+        return data[2:].decode('hex'), serial
 
     def loadBefore(self, oid, tid):
         r = self.base.loadBefore(oid, tid)
         if r is not None:
             data, serial, after = r
-            return data.decode('hex'), serial, after
+            return data[2:].decode('hex'), serial, after
         else:
             return r
 
     def loadSerial(self, oid, serial):
-        return self.base.loadSerial(oid, serial).decode('hex')
+        return self.base.loadSerial(oid, serial)[2:].decode('hex')
 
     def pack(self, pack_time, referencesf, gc=True):
         def refs(p, oids=None):
-            return referencesf(p.decode('hex'), oids)
+            return referencesf(p[2:].decode('hex'), oids)
         return self.base.pack(pack_time, refs, gc)
 
     def registerDB(self, db):
@@ -73,11 +73,11 @@
 
     def store(self, oid, serial, data, version, transaction):
         return self.base.store(
-            oid, serial, data.encode('hex'), version, transaction)
+            oid, serial, '.h'+data.encode('hex'), version, transaction)
 
     def restore(self, oid, serial, data, version, prev_txn, transaction):
         return self.base.restore(
-            oid, serial, data and data.encode('hex'), version, prev_txn,
+            oid, serial, data and ('.h'+data.encode('hex')), version, prev_txn,
             transaction)
 
     def iterator(self, start=None, stop=None):
@@ -86,12 +86,13 @@
 
     def storeBlob(self, oid, oldserial, data, blobfilename, version,
                   transaction):
-        return self.base.storeBlob(oid, oldserial, data.encode('hex'),
+        return self.base.storeBlob(oid, oldserial, '.h'+data.encode('hex'),
                                    blobfilename, version, transaction)
 
     def restoreBlob(self, oid, serial, data, blobfilename, prev_txn,
                     transaction):
-        return self.base.restoreBlob(oid, serial, data and data.encode('hex'),
+        return self.base.restoreBlob(oid, serial,
+                                     data and ('.h'+data.encode('hex')),
                                      blobfilename, prev_txn, transaction)
 
     def invalidateCache(self):
@@ -101,17 +102,17 @@
         return self.db.invalidate(transaction_id, oids, version)
 
     def references(self, record, oids=None):
-        return self.db.references(record.decode('hex'), oids)
+        return self.db.references(record[2:].decode('hex'), oids)
 
     def transform_record_data(self, data):
-        return self._db_transform(data).encode('hex')
+        return '.h'+self._db_transform(data).encode('hex')
 
     def untransform_record_data(self, data):
-        return self._db_untransform(data.decode('hex'))
+        return self._db_untransform(data[2:].decode('hex'))
 
     def record_iternext(self, next=None):
         oid, tid, data, next = self.base.record_iternext(next)
-        return oid, tid, data.decode('hex'), next
+        return oid, tid, data[2:].decode('hex'), next
 
     def copyTransactionsFrom(self, other):
         ZODB.blob.copyTransactionsFromTo(other, self)

Modified: ZODB/branches/jim-transform-wrapping/src/ZODB/utils.py
===================================================================
--- ZODB/branches/jim-transform-wrapping/src/ZODB/utils.py	2010-05-17 21:32:33 UTC (rev 112432)
+++ ZODB/branches/jim-transform-wrapping/src/ZODB/utils.py	2010-05-17 21:43:55 UTC (rev 112433)
@@ -87,10 +87,10 @@
 
 def cp(f1, f2, length=None):
     """Copy all data from one file to another.
-    
+
     It copies the data from the current position of the input file (f1)
-    appending it to the current position of the output file (f2). 
-    
+    appending it to the current position of the output file (f2).
+
     It copies at most 'length' bytes. If 'length' isn't given, it copies
     until the end of the input file.
     """
@@ -103,7 +103,7 @@
         f1.seek(0,2)
         length = f1.tell()
         f1.seek(old_pos)
-    
+
     while length > 0:
         if n > length:
             n = length
@@ -206,7 +206,6 @@
     try:
         class_info = u.load()
     except Exception, err:
-        print "Error", err
         return '', ''
     if isinstance(class_info, tuple):
         if isinstance(class_info[0], tuple):
@@ -251,7 +250,7 @@
                     raise AssertionError(
                         "Failed precondition: ",
                         precondition.__doc__.strip())
-            
+
             return func(*args, **kw)
         finally:
             inst._lock_release()
@@ -269,4 +268,4 @@
 
     def __call__(self, func):
         return Locked(func, preconditions=self.preconditions)
-        
+
lmpx.com only provides a reader for public news (NNTP) servers. It is not affiliated with the servers or forums shown here and is not responsible for the content of articles, which is written by their respective authors.