diff options
Diffstat (limited to 'ryu/lib/ofctl_v1_2.py')
| -rw-r--r-- | ryu/lib/ofctl_v1_2.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/ryu/lib/ofctl_v1_2.py b/ryu/lib/ofctl_v1_2.py index 2a2a7c05..0789bf68 100644 --- a/ryu/lib/ofctl_v1_2.py +++ b/ryu/lib/ofctl_v1_2.py @@ -16,11 +16,11 @@ import struct import socket import logging -import gevent from ryu.ofproto import inet from ryu.ofproto import ofproto_v1_2 from ryu.ofproto import ofproto_v1_2_parser +from ryu.lib import hub from ryu.lib import mac @@ -187,13 +187,13 @@ def match_ip_to_str(value, mask): def send_stats_request(dp, stats, waiters, msgs): dp.set_xid(stats) waiters_per_dp = waiters.setdefault(dp.id, {}) - lock = gevent.event.AsyncResult() + lock = hub.Event() waiters_per_dp[stats.xid] = (lock, msgs) dp.send_msg(stats) try: - lock.get(timeout=DEFAULT_TIMEOUT) - except gevent.Timeout: + lock.wait(timeout=DEFAULT_TIMEOUT) + except hub.Timeout: del waiters_per_dp[stats.xid] |