Home | History | Annotate | Download | only in multiprocessing

Lines Matching full:none

165         self.id_to_obj = {'0': (None, ())}
195 funcname = result = request = None
239 methodname = obj = None
257 typeid = gettypeid and gettypeid.get(methodname, None)
266 if methodname is None:
348 c.send(('#RETURN', None))
382 if callable is None:
388 if exposed is None:
390 if method_to_typeid is not None:
422 c.send(('#RETURN', None))
473 def __init__(self, address=None, authkey=None, serializer='pickle'):
474 if authkey is None:
501 dispatch(conn, None, 'dummy')
504 def start(self, initializer=None, initargs=()):
510 if initializer is not None and not hasattr(initializer, '__call__'):
542 initializer=None, initargs=()):
546 if initializer is not None:
567 id, exposed = dispatch(conn, None, 'create', (typeid,)+args, kwds)
572 def join(self, timeout=None):
584 return dispatch(conn, None, 'debug_info')
594 return dispatch(conn, None, 'number_of_objects')
614 dispatch(conn, None, 'shutdown')
639 def register(cls, typeid, callable=None, proxytype=None, exposed=None,
640 method_to_typeid=None, create_method=True):
647 if proxytype is None:
650 exposed = exposed or getattr(proxytype, '_exposed_', None)
653 getattr(proxytype, '_method_to_typeid_', None)
673 dispatch(conn, None, 'decref', (token.id,))
699 def __init__(self, token, serializer, manager=None,
700 authkey=None, exposed=None, incref=True):
703 tls_idset = BaseProxy._address_to_local.get(token.address, None)
704 if tls_idset is None:
725 if authkey is not None:
727 elif self._manager is not None:
743 dispatch(conn, None, 'accept_connection', (name,))
771 dispatch(conn, None, 'decref', (token.id,))
783 dispatch(conn, None, 'incref', (self._id,))
802 if state is None or state.value == State.STARTED:
807 dispatch(conn, None, 'decref', (token.id,))
823 self._manager = None
869 server = getattr(current_process(), '_manager_server', None)
906 def AutoProxy(token, serializer, manager=None, authkey=None,
907 exposed=None, incref=True):
913 if exposed is None:
916 exposed = dispatch(conn, None, 'get_methods', (token,))
920 if authkey is None and manager is not None:
922 if authkey is None:
998 def wait(self, timeout=None):
1013 def wait(self, timeout=None):