Commit 4bcc37c1 authored by Aurel's avatar Aurel

fix method parameter


git-svn-id: https://svn.erp5.org/repos/neo/branches/prototype3@118 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 7a0d83e5
...@@ -360,7 +360,6 @@ class OperationEventHandler(StorageEventHandler): ...@@ -360,7 +360,6 @@ class OperationEventHandler(StorageEventHandler):
if uuid is None: if uuid is None:
self.handleUnexpectedPacket(conn, packet) self.handleUnexpectedPacket(conn, packet)
return return
# First, check for the locking state. # First, check for the locking state.
app = self.app app = self.app
locking_tid = app.store_lock_dict.get(oid) locking_tid = app.store_lock_dict.get(oid)
...@@ -368,7 +367,7 @@ class OperationEventHandler(StorageEventHandler): ...@@ -368,7 +367,7 @@ class OperationEventHandler(StorageEventHandler):
if locking_tid < tid: if locking_tid < tid:
# Delay the response. # Delay the response.
app.queueEvent(self.handleAskStoreObject, conn, packet, app.queueEvent(self.handleAskStoreObject, conn, packet,
packet.getId(), oid, serial, compression, data, oid, serial, compression, data,
checksum, tid) checksum, tid)
else: else:
# If a newer transaction already locks this object, # If a newer transaction already locks this object,
...@@ -385,7 +384,6 @@ class OperationEventHandler(StorageEventHandler): ...@@ -385,7 +384,6 @@ class OperationEventHandler(StorageEventHandler):
conn.addPacket(Packet().answerStoreObject(packet.getId(), 1, conn.addPacket(Packet().answerStoreObject(packet.getId(), 1,
oid, last_serial)) oid, last_serial))
return return
# Now store the object. # Now store the object.
t = app.transaction_dict.setdefault(tid, TransactionInformation(uuid)) t = app.transaction_dict.setdefault(tid, TransactionInformation(uuid))
t.addObject(oid, compression, checksum, data) t.addObject(oid, compression, checksum, data)
......
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