in dubbo/connection/connections.py [0:0]
def __init__(self, host, port):
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.settimeout(5)
sock.connect((host, port))
# 在创建好连接之后设置IO为非阻塞
sock.setblocking(False)
self.__sock = sock
self.__host = '{0}:{1}'.format(host, port)
self.read_length, self.read_type, self.invoke_id = DEFAULT_READ_PARAMS
self.read_buffer = []
self.last_active = time.time()