Commit 86ecb4bd authored by Vincent Pelletier's avatar Vincent Pelletier

Exception handling is only meant for storeObject call.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@2078 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 8706262a
...@@ -48,7 +48,6 @@ class ClientOperationHandler(BaseClientAndStorageOperationHandler): ...@@ -48,7 +48,6 @@ class ClientOperationHandler(BaseClientAndStorageOperationHandler):
try: try:
self.app.tm.storeObject(uuid, tid, serial, oid, compression, self.app.tm.storeObject(uuid, tid, serial, oid, compression,
checksum, data, None) checksum, data, None)
conn.answer(Packets.AnswerStoreObject(0, oid, serial))
except ConflictError, err: except ConflictError, err:
# resolvable or not # resolvable or not
tid_or_serial = err.getTID() tid_or_serial = err.getTID()
...@@ -57,6 +56,8 @@ class ClientOperationHandler(BaseClientAndStorageOperationHandler): ...@@ -57,6 +56,8 @@ class ClientOperationHandler(BaseClientAndStorageOperationHandler):
# locked by a previous transaction, retry later # locked by a previous transaction, retry later
self.app.queueEvent(self.askStoreObject, conn, oid, serial, self.app.queueEvent(self.askStoreObject, conn, oid, serial,
compression, checksum, data, tid) compression, checksum, data, tid)
else:
conn.answer(Packets.AnswerStoreObject(0, oid, serial))
def askTIDs(self, conn, first, last, partition): def askTIDs(self, conn, first, last, partition):
# This method is complicated, because I must return TIDs only # This method is complicated, because I must return TIDs only
......
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