Lines Matching refs:util
33 from . import util
181 util.debug('resetting stdout, stderr')
222 util.info('Failure to send message: %r', msg)
223 util.info(' ... request was %r', request)
224 util.info(' ... exception was %r', e)
242 util.debug('starting server thread to service %r',
299 util.debug('got EOF -- exiting thread serving %r',
312 util.info('exception in thread serving %r',
314 util.info(' ... message was %r', msg)
315 util.info(' ... exception was %r', e)
365 util.debug('manager received shutdown message')
400 util.debug('%r callable returned object with id %r', typeid, ident)
437 util.debug('Server re-enabled tracking & INCREF %r', ident)
444 util.debug('Server DECREF skipping %r', ident)
464 util.debug('disposing of obj with id %r', ident)
572 self.shutdown = util.Finalize(
599 util.info('manager serving at %r', server.address)
666 util.info('sending shutdown message to manager')
678 util.info('manager still alive')
680 util.info('trying to `terminate()` manager process')
684 util.info('manager still alive after terminate')
726 util.debug('requesting creation of a shared %r object', typeid)
744 util.register_after_fork(self, lambda obj: obj.clear())
757 _mutex = util.ForkAwareThreadLock()
764 tls_idset = util.ForkAwareLocal(), ProcessLocalSet()
798 util.register_after_fork(self, BaseProxy._after_fork)
801 util.debug('making connection to manager')
816 util.debug('thread %r does not own a connection',
847 util.debug('owned_by_manager skipped INCREF of %r', self._token.id)
852 util.debug('INCREF %r', self._token.id)
858 self._close = util.Finalize(
873 util.debug('DECREF %r', token.id)
877 util.debug('... decref failed %s', e)
880 util.debug('DECREF %r -- manager already shutdown', token.id)
885 util.debug('thread %r has no more proxies so closing conn',
896 util.info('incref failed: %s' % e)
937 util.debug('Rebuild a proxy owned by manager, token=%r', token)
1246 util.debug(f"Register segment {segment_name!r} in pid {getpid()}")
1252 util.debug(f"Destroy segment {segment_name!r} in pid {getpid()}")
1264 util.debug(f"Call {self.__class__.__name__}.__del__ in {getpid()}")
1287 util.debug(f"SharedMemoryServer started by pid {getpid()}")
1341 util.debug(f"{self.__class__.__name__} created by pid {getpid()}")
1344 util.debug(f"{self.__class__.__name__}.__del__ by pid {getpid()}")