Commit 38002828 authored by Jim Fulton's avatar Jim Fulton

Added missing pack support to the StorageServer.

parent 85f201d4
...@@ -41,7 +41,7 @@ ...@@ -41,7 +41,7 @@
# SUCH DAMAGE. # SUCH DAMAGE.
###################################################################### ######################################################################
__version__ = "$Revision: 1.6 $"[11:-2] __version__ = "$Revision: 1.7 $"[11:-2]
import asyncore, socket, string, sys, cPickle import asyncore, socket, string, sys, cPickle
from smac import SizedMessageAsyncConnection from smac import SizedMessageAsyncConnection
...@@ -49,6 +49,8 @@ from ZODB import POSException ...@@ -49,6 +49,8 @@ from ZODB import POSException
from ZODB.Transaction import Transaction from ZODB.Transaction import Transaction
import traceback import traceback
from zLOG import LOG, INFO, ERROR from zLOG import LOG, INFO, ERROR
from ZODB.referencesf import referencesf
from thread import start_new_thread
class StorageServerError(POSException.StorageError): pass class StorageServerError(POSException.StorageError): pass
...@@ -227,7 +229,9 @@ class Connection(SizedMessageAsyncConnection): ...@@ -227,7 +229,9 @@ class Connection(SizedMessageAsyncConnection):
self.message_output('I'+dumps(((oid, osv, v),))) self.message_output('I'+dumps(((oid, osv, v),)))
return _noreturn return _noreturn
def pack(self, t):
start_new_thread(self.__storage.pack, (t, referencesf))
def store(self, oid, serial, data, version, id): def store(self, oid, serial, data, version, id):
t=self._transaction t=self._transaction
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment