diff options
| -rw-r--r-- | python/ovs/jsonrpc.py | 2 | ||||
| -rw-r--r-- | python/ovs/stream.py | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/python/ovs/jsonrpc.py b/python/ovs/jsonrpc.py index cf081313..a054401b 100644 --- a/python/ovs/jsonrpc.py +++ b/python/ovs/jsonrpc.py @@ -210,7 +210,7 @@ class Connection(object): if not self.status: self.stream.run_wait(poller) if len(self.output): - self.stream.send_wait() + self.stream.send_wait(poller) def get_status(self): return self.status diff --git a/python/ovs/stream.py b/python/ovs/stream.py index 82ea0c12..aa512f62 100644 --- a/python/ovs/stream.py +++ b/python/ovs/stream.py @@ -113,7 +113,7 @@ class Stream(object): break stream.run() poller = ovs.poller.Poller() - stream.run_wait() + stream.run_wait(poller) stream.connect_wait(poller) poller.block() assert error != errno.EINPROGRESS |