diff options
| author | OHMURA Kei <ohmura.kei@lab.ntt.co.jp> | 2013-01-24 10:56:19 +0900 |
|---|---|---|
| committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2013-01-25 07:16:50 +0900 |
| commit | abd1039801b1fc0b2754b0fbc8097670f11678d9 (patch) | |
| tree | bbeb8c305b538c2b1a8577799fa663024338bebc | |
| parent | 63c8a15e7ca404aba91c2d8ac3510f41b1abfede (diff) | |
ofctl_v1_0: fix stats timeout handling
This patch fixes a issue reported by https://github.com/osrg/ryu/issues/7
Signed-off-by: OHMURA Kei <ohmura.kei@lab.ntt.co.jp>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
| -rw-r--r-- | ryu/lib/ofctl_v1_0.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ryu/lib/ofctl_v1_0.py b/ryu/lib/ofctl_v1_0.py index 8553c9a2..1184b9b5 100644 --- a/ryu/lib/ofctl_v1_0.py +++ b/ryu/lib/ofctl_v1_0.py @@ -172,15 +172,15 @@ def match_to_str(m): def send_stats_request(dp, stats, waiters, msgs): dp.set_xid(stats) - waiters = waiters.setdefault(dp.id, {}) + waiters_per_dp = waiters.setdefault(dp.id, {}) lock = gevent.event.AsyncResult() - waiters[stats.xid] = (lock, msgs) + waiters_per_dp[stats.xid] = (lock, msgs) dp.send_msg(stats) try: lock.get(timeout=DEFAULT_TIMEOUT) except gevent.Timeout: - del waiters[dp.id][stats.xid] + del waiters_per_dp[stats.xid] def get_desc_stats(dp, waiters): |