Lines Matching full:conn
65 def send_handle(conn, handle, destination_pid):
71 conn.send(new_handle)
75 def recv_handle(conn):
76 return conn.recv()
79 def send_handle(conn, handle, destination_pid):
80 _multiprocessing.sendfd(conn.fileno(), handle)
82 def recv_handle(conn):
83 return _multiprocessing.recvfd(conn.fileno())
124 conn = _listener.accept()
125 handle_wanted, destination_pid = conn.recv()
127 send_handle(conn, handle_wanted, destination_pid)
129 conn.close()
155 conn = Client(address, authkey=current_process().authkey)
156 conn.send((handle, os.getpid()))
157 new_handle = recv_handle(conn)
158 conn.close()
165 def reduce_connection(conn):
166 rh = reduce_handle(conn.fileno())
167 return rebuild_connection, (rh, conn.readable, conn.writable)
205 def reduce_pipe_connection(conn):
206 rh = reduce_handle(conn.fileno())
207 return rebuild_pipe_connection, (rh, conn.readable, conn.writable)
