+def inet_parse_active(target, default_port):
+ address = target.split(":")
+ host_name = address[0]
+ if not host_name:
+ raise Exception("%s: bad peer name format" % target)
+ if len(address) >= 2:
+ port = int(address[1])
+ elif default_port:
+ port = default_port
+ else:
+ raise Exception("%s: port number must be specified" % target)
+ return (host_name, port)
+
+
+def inet_open_active(style, target, default_port, dscp):
+ address = inet_parse_active(target, default_port)
+ try:
+ sock = socket.socket(socket.AF_INET, style, 0)
+ except socket.error, e:
+ return get_exception_errno(e), None
+
+ try:
+ set_nonblocking(sock)
+ set_dscp(sock, dscp)
+ try:
+ sock.connect(address)
+ except socket.error, e:
+ if get_exception_errno(e) != errno.EINPROGRESS:
+ raise
+ return 0, sock
+ except socket.error, e:
+ sock.close()
+ return get_exception_errno(e), None
+
+