Home | History | Annotate | Download | only in multiprocessing

Lines Matching full:address

85     Return an arbitrary free address for the given family
98 def address_type(address):
100 Return the types of the address
104 if type(address) == tuple:
106 elif type(address) is str and address.startswith('\\\\'):
108 elif type(address) is str:
111 raise ValueError('address type of %r unrecognized' % address)
124 def __init__(self, address=None, family=None, backlog=1, authkey=None):
125 family = family or (address and address_type(address)) \
127 address = address or arbitrary_address(family)
130 self._listener = PipeListener(address, backlog)
132 self._listener = SocketListener(address, family, backlog)
157 address = property(lambda self: self._listener._address)
161 def Client(address, family=None, authkey=None):
163 Returns a connection to the address of a `Listener`
165 family = family or address_type(address)
167 c = PipeClient(address)
169 c = SocketClient(address)
209 address = arbitrary_address('AF_PIPE')
220 address, openmode,
226 address, access, 0, win32.NULL, win32.OPEN_EXISTING, 0, win32.NULL
249 Representation of a socket which is bound to an address and listening
251 def __init__(self, address, family, backlog=1):
256 self._socket.bind(address)
267 self, os.unlink, args=(address,), exitpriority=0
286 def SocketClient(address):
288 Return a connection object connected to the socket given by `address`
290 family = address_type(address)
297 s.connect(address)
300 debug('failed to connect to address %s', address)
323 def __init__(self, address, backlog=None):
324 self._address = address
326 address, win32.PIPE_ACCESS_DUPLEX,
335 sub_debug('listener created with address=%r', self._address)
363 def _finalize_pipe_listener(queue, address):
364 sub_debug('closing listener with address=%r', address)
368 def PipeClient(address):
370 Return a connection object connected to the pipe given by `address`
375 win32.WaitNamedPipe(address, 1000)
377 address, win32.GENERIC_READ | win32.GENERIC_WRITE,