Back to index

python3.2  3.2.2
Public Member Functions | Public Attributes | Static Private Member Functions | Private Attributes
multiprocessing.connection.PipeListener Class Reference
Inheritance diagram for multiprocessing.connection.PipeListener:
Inheritance graph
[legend]
Collaboration diagram for multiprocessing.connection.PipeListener:
Collaboration graph
[legend]

List of all members.

Public Member Functions

def __init__
def accept

Public Attributes

 close
_PyObject_HEAD_EXTRA Py_ssize_t ob_refcnt
struct _typeobjectob_type

Static Private Member Functions

def _finalize_pipe_listener

Private Attributes

 _address
 _handle_queue
 _last_accepted

Detailed Description

Representation of a named pipe

Definition at line 310 of file connection.py.


Constructor & Destructor Documentation

def multiprocessing.connection.PipeListener.__init__ (   self,
  address,
  backlog = None 
)

Definition at line 314 of file connection.py.

00314 
00315         def __init__(self, address, backlog=None):
00316             self._address = address
00317             handle = win32.CreateNamedPipe(
00318                 address, win32.PIPE_ACCESS_DUPLEX,
00319                 win32.PIPE_TYPE_MESSAGE | win32.PIPE_READMODE_MESSAGE |
00320                 win32.PIPE_WAIT,
00321                 win32.PIPE_UNLIMITED_INSTANCES, BUFSIZE, BUFSIZE,
00322                 win32.NMPWAIT_WAIT_FOREVER, win32.NULL
00323                 )
00324             self._handle_queue = [handle]
00325             self._last_accepted = None
00326 
00327             sub_debug('listener created with address=%r', self._address)
00328 
00329             self.close = Finalize(
00330                 self, PipeListener._finalize_pipe_listener,
00331                 args=(self._handle_queue, self._address), exitpriority=0
00332                 )

Here is the caller graph for this function:


Member Function Documentation

def multiprocessing.connection.PipeListener._finalize_pipe_listener (   queue,
  address 
) [static, private]

Definition at line 351 of file connection.py.

00351 
00352         def _finalize_pipe_listener(queue, address):
00353             sub_debug('closing listener with address=%r', address)
00354             for handle in queue:
00355                 close(handle)
00356 
    def PipeClient(address):

Here is the call graph for this function:

Definition at line 333 of file connection.py.

00333 
00334         def accept(self):
00335             newhandle = win32.CreateNamedPipe(
00336                 self._address, win32.PIPE_ACCESS_DUPLEX,
00337                 win32.PIPE_TYPE_MESSAGE | win32.PIPE_READMODE_MESSAGE |
00338                 win32.PIPE_WAIT,
00339                 win32.PIPE_UNLIMITED_INSTANCES, BUFSIZE, BUFSIZE,
00340                 win32.NMPWAIT_WAIT_FOREVER, win32.NULL
00341                 )
00342             self._handle_queue.append(newhandle)
00343             handle = self._handle_queue.pop(0)
00344             try:
00345                 win32.ConnectNamedPipe(handle, win32.NULL)
00346             except WindowsError as e:
00347                 if e.args[0] != win32.ERROR_PIPE_CONNECTED:
00348                     raise
00349             return _multiprocessing.PipeConnection(handle)


Member Data Documentation

Definition at line 315 of file connection.py.

Definition at line 323 of file connection.py.

Definition at line 324 of file connection.py.

Definition at line 328 of file connection.py.

Definition at line 107 of file object.h.

struct _typeobject* _object::ob_type [inherited]

Definition at line 108 of file object.h.


The documentation for this class was generated from the following file: