def _run_server(local_addr, local_addr_family, local_socket_type, local_linger_args, remote_addr, remote_addr_family, remote_socket_type, queue):
 class _ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer, object, ):
  'Threaded streaming server for forwarding'
  address_family = local_addr_family
  socket_type = local_socket_type
  allow_reuse_address = True
  def __init__(self):
   handler_class_factory = partial(_TCPHandler, local_linger_args=local_linger_args, remote_addr=remote_addr, remote_addr_family=remote_addr_family, remote_socket_type=remote_socket_type)
   super(_ThreadedTCPServer, self).__init__(local_addr, handler_class_factory, bind_and_activate=True)
 server = _ThreadedTCPServer()
 queue.put([server.socket.family, server.server_address])
 queue.close()
 server.serve_forever()

def _run_server ( local_addr , local_addr_family , local_socket_type , local_linger_args , remote_addr , remote_addr_family , remote_socket_type , queue ) : class _ThreadedTCPServer ( SocketServer . ThreadingMixIn , SocketServer . TCPServer , object , ) : address_family = local_addr_family socket_type = local_socket_type allow_reuse_address = True def __init__ ( self ) : handler_class_factory = partial ( _TCPHandler , local_linger_args = local_linger_args , remote_addr = remote_addr , remote_addr_family = remote_addr_family , remote_socket_type = remote_socket_type ) super ( _ThreadedTCPServer , self ) . __init__ ( local_addr , handler_class_factory , bind_and_activate = True ) server = _ThreadedTCPServer ( ) queue . put ( [ server . socket . family , server . server_address ] ) queue . close ( ) server . serve_forever ( )
run the server; executed in the subprocess .