diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2009-11-16 12:21:54 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2009-11-16 12:21:54 +0000 |
| commit | 00033f8338a647d79580ca2356345074d84c7476 (patch) | |
| tree | 993e536eafedc8a6111169e2d2b7d5a137fbfdec /python | |
| parent | b08f16897e3f5c65c155d6d63c380003510430c9 (diff) | |
| download | qpid-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.py | 12 |
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): |
