summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorLV-426 <lv-426@taproot.org.il>2015-04-29 17:45:02 +0300
committerLV-426 <lv-426@taproot.org.il>2015-04-29 17:46:39 +0300
commit3c63ec6518f5f43ca907a56896445383469862f9 (patch)
tree444091016773349a7ad34c365527ece7aa17da2a /src
parente978b71eb92ce375aacba4699e558c991f2cea56 (diff)
db_op: composed op: post_op_exec_hook() - provide room for post-sub-op logic
Diffstat (limited to 'src')
-rw-r--r--src/server/db_controller.py2
-rw-r--r--src/server/db_op.py4
2 files changed, 5 insertions, 1 deletions
diff --git a/src/server/db_controller.py b/src/server/db_controller.py
index 5d3618ff..33b595de 100644
--- a/src/server/db_controller.py
+++ b/src/server/db_controller.py
@@ -32,7 +32,7 @@ class DB_Controller:
for sub_op in op.iter__sub_op():
sub_op_ret = self.exec_op(sub_op) # recursive call
- op.inter_op_exec_hook(sub_op_ret)
+ op.post_sub_op_exec_hook(sub_op, sub_op_ret)
op_ret = op.process_result_set()
return op_ret
diff --git a/src/server/db_op.py b/src/server/db_op.py
index 2fc7cefc..f28dc320 100644
--- a/src/server/db_op.py
+++ b/src/server/db_op.py
@@ -177,8 +177,12 @@ class DB_composed_op(DB_op):
for s_op in self.sub_op_set:
yield s_op
+ def post_sub_op_exec_hook(self, prv_sub_op, prv_sub_op_ret):
"""
+ Called after each successful sub-op execution. Throwing an exception here
+ will prevent the execution of the subsequent sub_op's.
"""
+ pass
def process_result_set(self):
ret = []