multiprocessing.connection.wait()

multiprocessing.connection.wait(object_list, timeout=None) Wait till an object in object_list is ready. Returns the list of those objects in object_list which are ready. If timeout is a float then the call blocks for at most that many seconds. If timeout is None then it will block for an unlimited period. A negative timeout is equivalent to a zero timeout. For both Unix and Windows, an object can appear in object_list if it is a readable Connection object; a connected and readable socket.soc

multiprocessing.Connection.send_bytes()

send_bytes(buffer[, offset[, size]]) Send byte data from a bytes-like object as a complete message. If offset is given then data is read from that position in buffer. If size is given then that many bytes will be read from buffer. Very large buffers (approximately 32 MB+, though it depends on the OS) may raise a ValueError exception

multiprocessing.Connection.send()

send(obj) Send an object to the other end of the connection which should be read using recv(). The object must be picklable. Very large pickles (approximately 32 MB+, though it depends on the OS) may raise a ValueError exception.

multiprocessing.Connection.recv_bytes_into()

recv_bytes_into(buffer[, offset]) Read into buffer a complete message of byte data sent from the other end of the connection and return the number of bytes in the message. Blocks until there is something to receive. Raises EOFError if there is nothing left to receive and the other end was closed. buffer must be a writable bytes-like object. If offset is given then the message will be written into the buffer from that position. Offset must be a non-negative integer less than the length of buf

multiprocessing.Connection.recv_bytes()

recv_bytes([maxlength]) Return a complete message of byte data sent from the other end of the connection as a string. Blocks until there is something to receive. Raises EOFError if there is nothing left to receive and the other end has closed. If maxlength is specified and the message is longer than maxlength then OSError is raised and the connection will no longer be readable. Changed in version 3.3: This function used to raise IOError, which is now an alias of OSError.

multiprocessing.Connection.recv()

recv() Return an object sent from the other end of the connection using send(). Blocks until there its something to receive. Raises EOFError if there is nothing left to receive and the other end was closed.

multiprocessing.Connection.poll()

poll([timeout]) Return whether there is any data available to be read. If timeout is not specified then it will return immediately. If timeout is a number then this specifies the maximum time in seconds to block. If timeout is None then an infinite timeout is used. Note that multiple connection objects may be polled at once by using multiprocessing.connection.wait().

multiprocessing.connection.Listener.last_accepted

last_accepted The address from which the last accepted connection came. If this is unavailable then it is None.

multiprocessing.connection.Listener.close()

close() Close the bound socket or named pipe of the listener object. This is called automatically when the listener is garbage collected. However it is advisable to call it explicitly.

multiprocessing.connection.Listener.address

address The address which is being used by the Listener object.