

def _prepare_netqueue(self):
    " Replaces the trajectory's service with a queue sender and starts the queue process.\n\n        "
    self._logger.info('Starting Network Queue!')
    if (not isinstance(self._port, compat.base_type)):
        url = port_to_tcp(self._port)
        self._logger.info(('Determined Server URL: `%s`' % url))
    else:
        url = self._port
    if (self._queue is None):
        if hasattr(os, 'fork'):
            self._queue = ForkAwareQueuingClient(url)
        else:
            url._queue = QueuingClient(url)
    queuing_server_handler = QueuingServer(url, self._storage_service, self._queue_maxsize, self._gc_interval)
    self._queue_process = multip.Process(name='QueuingServerProcess', target=_wrap_handling, args=(dict(handler=queuing_server_handler, logging_manager=self._logging_manager, graceful_exit=self._graceful_exit),))
    self._queue_process.start()
    self._queue.start()
    self._queue_wrapper = QueueStorageServiceSender(self._queue)
    self._traj.v_storage_service = self._queue_wrapper

dataset/ETHPy150Open SmokinCaterpillar/pypet/pypet/environment.py MultiprocContext._prepare_netqueue/VarMisuse@107/188 `self`->`url`