

def _prepare_pipe(self):
    " Replaces the trajectory's service with a queue sender and starts the queue process.\n\n        "
    if (self._pipe is None):
        self._pipe = multip.Pipe(True)
    if (pipe_handler._lock is None):
        self._lock = multip.Lock()
    self._logger.info('Starting the Storage Pipe!')
    pipe_handler = PipeStorageServiceWriter(self._storage_service, self._pipe[0], max_buffer_size=self._max_buffer_size)
    self._pipe_process = multip.Process(name='PipeProcess', target=_wrap_handling, args=(dict(handler=pipe_handler, logging_manager=self._logging_manager, graceful_exit=self._graceful_exit),))
    self._pipe_process.start()
    self._pipe_wrapper = PipeStorageServiceSender(self._pipe[1], self._lock)
    self._traj.v_storage_service = self._pipe_wrapper

dataset/ETHPy150Open SmokinCaterpillar/pypet/pypet/environment.py MultiprocContext._prepare_pipe/VarMisuse@37/80 `self`->`pipe_handler`