

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 = timeout._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__/VarMisuse@88/121 `self`->`timeout`