def _connect(self):
"""Connect to a local server, return True on success."""
_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# No Nagle since we are going for as close to realtime as possible
_socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
# Set the timeout for initial connect, as default is too high
_socket.settimeout(5.0)
log.debug('connecting to %s:%d', *self.host_port)
try:
_socket.connect(self.host_port)
except socket.timeout:
log.error('timed out connecting to server')
return False
except IOError as e:
log.error('IO Error when connecting, %s', e)
return False
except:
log.exception('error connecting')
return False
else:
log.debug("connected to %s:%d", *self.host_port)
self.socket = _socket
self._flush_buffer()
return True
评论列表
文章目录