summaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2009-11-16 12:21:54 +0000
committerRafael H. Schloming <rhs@apache.org>2009-11-16 12:21:54 +0000
commit00033f8338a647d79580ca2356345074d84c7476 (patch)
tree993e536eafedc8a6111169e2d2b7d5a137fbfdec /python
parentb08f16897e3f5c65c155d6d63c380003510430c9 (diff)
downloadqpid-python-00033f8338a647d79580ca2356345074d84c7476.tar.gz
better name for completion actions
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@880726 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python')
-rw-r--r--python/qpid/driver.py12
1 files changed, 6 insertions, 6 deletions
diff --git a/python/qpid/driver.py b/python/qpid/driver.py
index 21d2b432f4..3cc69921bb 100644
--- a/python/qpid/driver.py
+++ b/python/qpid/driver.py
@@ -90,7 +90,7 @@ class SessionState:
# sender state
self.sent = Serial(0)
self.acknowledged = RangedSet()
- self.completions = {}
+ self.actions = {}
self.min_completion = self.sent
self.max_completion = self.sent
self.results = {}
@@ -105,14 +105,14 @@ class SessionState:
id = self.sent
self.write_cmd(query, lambda: handler(self.results.pop(id)))
- def write_cmd(self, cmd, completion=noop):
- if completion != noop:
+ def write_cmd(self, cmd, action=noop):
+ if action != noop:
cmd.sync = True
if self.detached:
raise Exception("detached")
cmd.id = self.sent
self.sent += 1
- self.completions[cmd.id] = completion
+ self.actions[cmd.id] = action
self.max_completion = cmd.id
self.write_op(cmd)
@@ -333,8 +333,8 @@ class Driver:
if not sc.commands.empty():
while sst.min_completion in sc.commands:
- if sst.completions.has_key(sst.min_completion):
- sst.completions.pop(sst.min_completion)()
+ if sst.actions.has_key(sst.min_completion):
+ sst.actions.pop(sst.min_completion)()
sst.min_completion += 1
def session_known_completed(self, kcmp):