Bug #12301.
Reported-by: Mike Kruze <mkruze@nicira.com>
Signed-off-by: Ben Pfaff <blp@nicira.com>
if not self.status:
self.stream.run_wait(poller)
if len(self.output):
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
def get_status(self):
return self.status
break
stream.run()
poller = ovs.poller.Poller()
break
stream.run()
poller = ovs.poller.Poller()
+ stream.run_wait(poller)
stream.connect_wait(poller)
poller.block()
assert error != errno.EINPROGRESS
stream.connect_wait(poller)
poller.block()
assert error != errno.EINPROGRESS