diff options
| -rw-r--r-- | python/ovs/stream.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/python/ovs/stream.py b/python/ovs/stream.py index 5954c3148..82d4557e9 100644 --- a/python/ovs/stream.py +++ b/python/ovs/stream.py @@ -206,10 +206,10 @@ class Stream(object): if self.state == Stream.__S_CONNECTING: wait = Stream.W_CONNECT - if wait in (Stream.W_CONNECT, Stream.W_SEND): - poller.fd_wait(self.socket, select.POLLOUT) - else: + if wait == Stream.W_RECV: poller.fd_wait(self.socket, select.POLLIN) + else: + poller.fd_wait(self.socket, select.POLLOUT) def connect_wait(self, poller): self.wait(poller, Stream.W_CONNECT) |