💾 Archived View for tris.fyi › pydoc › multiprocessing.connection captured on 2023-01-29 at 04:14:53. Gemini links have been rewritten to link to archived content

-=-=-=-=-=-=-

multiprocessing

multiprocessing.connection

This module has no docstring.

Classes

AuthenticationError

with_traceback(...)

  Exception.with_traceback(tb) --
      set self.__traceback__ to tb and return self.

args = <attribute 'args' of 'BaseException' objects>

BufferTooShort

with_traceback(...)

  Exception.with_traceback(tb) --
      set self.__traceback__ to tb and return self.

args = <attribute 'args' of 'BaseException' objects>

Connection


    Connection class based on an arbitrary file descriptor (Unix only), or
    a socket handle (Windows).

close(self)

  Close the connection

fileno(self)

  File descriptor or handle of the connection

poll(self, timeout=0.0)

  Whether there is any input available to be read

recv(self)

  Receive a (picklable) object

recv_bytes(self, maxlength=None)


          Receive bytes data as a bytes object.

recv_bytes_into(self, buf, offset=0)


          Receive bytes data into a writeable bytes-like object.
          Return the number of bytes read.

send(self, obj)

  Send a (picklable) object

send_bytes(self, buf, offset=0, size=None)

  Send the bytes data from a bytes-like object

closed = <property object at 0x7f75e2d45b20>
  True if the connection is closed

readable = <property object at 0x7f75e1c62d90>
  True if the connection is readable

writable = <property object at 0x7f75e1cbb4c0>
  True if the connection is writable

ConnectionWrapper

recv(self)

send(self, obj)

Listener


    Returns a listener object.

    This is a wrapper for a bound socket which is 'listening' for
    connections, or for a Windows named pipe.

accept(self)


          Accept a connection on the bound socket or named pipe of `self`.

          Returns a `Connection` object.

close(self)


          Close the bound socket or named pipe of `self`.

address = <property object at 0x7f75e1c1b6a0>

last_accepted = <property object at 0x7f75e1c1bfb0>

SocketListener


    Representation of a socket which is bound to an address and listening

accept(self)

close(self)

XmlListener

accept(self)

close(self)


          Close the bound socket or named pipe of `self`.

address = <property object at 0x7f75e1c1b6a0>

last_accepted = <property object at 0x7f75e1c1bfb0>

Functions

Client

Client(address, family=None, authkey=None)


      Returns a connection to the address of a `Listener`

Pipe

Pipe(duplex=True)


          Returns pair of connection objects at either end of a pipe

SocketClient

SocketClient(address)


      Return a connection object connected to the socket given by `address`

XmlClient

XmlClient(*args, **kwds)

address_type

address_type(address)


      Return the types of the address

      This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE'

answer_challenge

answer_challenge(connection, authkey)

arbitrary_address

arbitrary_address(family)


      Return an arbitrary free address for the given family

deliver_challenge

deliver_challenge(connection, authkey)

rebuild_connection

rebuild_connection(df, readable, writable)

reduce_connection

reduce_connection(conn)

wait

wait(object_list, timeout=None)


          Wait till an object in object_list is ready/readable.

          Returns list of those objects in object_list which are ready/readable.

Other members

BUFSIZE = 8192

CHALLENGE = b'#CHALLENGE#'

CONNECTION_TIMEOUT = 20.0

FAILURE = b'#FAILURE#'

MESSAGE_LENGTH = 20

WELCOME = b'#WELCOME#'

default_family = 'AF_UNIX'

families = ['AF_INET', 'AF_UNIX']

Modules