Commit 7c315e8b authored by Vincent Pelletier's avatar Vincent Pelletier

Split _load for future extensions.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@2487 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 3a396e67
...@@ -499,6 +499,20 @@ class Application(object): ...@@ -499,6 +499,20 @@ class Application(object):
if not self.local_var.barrier_done: if not self.local_var.barrier_done:
self.invalidationBarrier() self.invalidationBarrier()
self.local_var.barrier_done = True self.local_var.barrier_done = True
data, start_serial, end_serial = self._loadFromStorage(oid, serial,
tid)
if cache:
self._cache_lock_acquire()
try:
self.mq_cache[oid] = start_serial, data
finally:
self._cache_lock_release()
if data == '':
raise NEOStorageCreationUndoneError(dump(oid))
return data, start_serial, end_serial
@profiler_decorator
def _loadFromStorage(self, oid, serial, tid):
cell_list = self._getCellListForOID(oid, readable=True) cell_list = self._getCellListForOID(oid, readable=True)
if len(cell_list) == 0: if len(cell_list) == 0:
# No cells available, so why are we running ? # No cells available, so why are we running ?
...@@ -551,16 +565,6 @@ class Application(object): ...@@ -551,16 +565,6 @@ class Application(object):
# Uncompress data # Uncompress data
if compression: if compression:
data = decompress(data) data = decompress(data)
# Put in cache only when using load
if cache:
self._cache_lock_acquire()
try:
self.mq_cache[oid] = start_serial, data
finally:
self._cache_lock_release()
if data == '':
raise NEOStorageCreationUndoneError(dump(oid))
return data, start_serial, end_serial return data, start_serial, end_serial
......
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