accept() Accept a connection on the bound socket or named pipe of the listener object and return a Connection object. If authentication is attempted and fails, then AuthenticationError is raised.

class multiprocessing.connection.Listener([address[, family[, backlog[, authenticate[, authkey]]]]]) A wrapper for a bound socket or Windows named pipe which is ‘listening’ for connections. address is the address to be used by the bound socket or named pipe of the listener object. Note If an address of ‘0.0.0.0’ is used, the address will not be a connectable end point on Windows. If you require a connectable end-point, you should use ‘127.0.0.1’. family is the type of socket (or named pipe

fileno() Return the file descriptor or handle used by the connection.

multiprocessing.connection.deliver_challenge(connection, authkey) Send a randomly generated message to the other end of the connection and wait for a reply. If the reply matches the digest of the message using authkey as the key then a welcome message is sent to the other end of the connection. Otherwise AuthenticationError is raised.

close() Close the connection. This is called automatically when the connection is garbage collected.

multiprocessing.connection.Client(address[, family[, authenticate[, authkey]]]) Attempt to set up a connection to the listener which is using address address, returning a Connection. The type of the connection is determined by family argument, but this can generally be omitted since it can usually be inferred from the format of address. (See Address Formats) If authenticate is True or authkey is a byte string then digest authentication is used. The key used for authentication will be either

multiprocessing.connection.answer_challenge(connection, authkey) Receive a message, calculate the digest of the message using authkey as the key, and then send the digest back. If a welcome message is not received, then AuthenticationError is raised.

class multiprocessing.Connection 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. 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. fileno() Re

class multiprocessing.Condition([lock]) A condition variable: an alias for threading.Condition. If lock is specified then it should be a Lock or RLock object from multiprocessing. Changed in version 3.3: The wait_for() method was added.

exception multiprocessing.BufferTooShort Exception raised by Connection.recv_bytes_into() when the supplied buffer object is too small for the message read. If e is an instance of BufferTooShort then e.args[0] will give the message as a byte string.