import os
import select
import socket
-import sys
import ovs.poller
import ovs.socket_util
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)
def send_wait(self, poller):
self.wait(poller, Stream.W_SEND)
- def get_name(self):
- return self.name
-
def __del__(self):
# Don't delete the file: we might have forked.
self.socket.close()
# Don't delete the file: we might have forked.
self.socket.close()
-def usage(name, active, passive, bootstrap):
+def usage(name, active, passive):
print
if active:
print("Active %s connection methods:" % name)