def __init__(self, trajectory,
                 wrap_mode=pypetconstants.WRAP_MODE_LOCK,
                 full_copy=None,
                 manager=None,
                 use_manager=True,
                 lock=None,
                 queue=None,
                 queue_maxsize=0,
                 port=None,
                 timeout=None,
                 gc_interval=None,
                 log_config=None,
                 log_stdout=False,
                 graceful_exit=False):

        self._set_logger()

        self._manager = manager
        self._traj = trajectory
        self._storage_service = self._traj.v_storage_service
        self._queue_process = None
        self._pipe_process = None
        self._lock_wrapper = None
        self._queue_wrapper = None
        self._reference_wrapper = None
        self._wrap_mode = wrap_mode
        self._queue = queue
        self._queue_maxsize = queue_maxsize
        self._pipe = queue
        self._max_buffer_size = queue_maxsize
        self._lock = lock
        self._lock_process = None
        self._port = port
        self._timeout = timeout
        self._use_manager = use_manager
        self._logging_manager = None
        self._gc_interval = gc_interval
        self._graceful_exit = graceful_exit

        if (self._wrap_mode == pypetconstants.WRAP_MODE_QUEUE or
                        self._wrap_mode == pypetconstants.WRAP_MODE_PIPE or
                            self._wrap_mode == pypetconstants.WRAP_MODE_NETLOCK or
                                self._wrap_mode == pypetconstants.WRAP_MODE_NETQUEUE):
            self._logging_manager = LoggingManager(log_config=log_config,
                                                   log_stdout=log_stdout)
            self._logging_manager.extract_replacements(self._traj)
            self._logging_manager.check_log_config()

        if full_copy is not None:
            self._traj.v_full_copy=full_copy
dataset/ETHPy150Open SmokinCaterpillar/pypet/pypet/environment.py/MultiprocContext.__init__/original