def _do_wrap(self):

        # First take care that the storage is initialised
        self._traj.f_store(only_init=True)
        if self._wrap_mode == pypetconstants.WRAP_MODE_QUEUE:
            self._prepare_queue()
        elif self._wrap_mode == pypetconstants.WRAP_MODE_LOCK:
            self._prepare_lock()
        elif self._wrap_mode == pypetconstants.WRAP_MODE_PIPE:
            self._prepare_pipe()
        elif self._wrap_mode == pypetconstants.WRAP_MODE_LOCAL:
            self._prepare_local()
        elif self._wrap_mode == pypetconstants.WRAP_MODE_NETLOCK:
            self._prepare_netlock()
        elif self._wrap_mode == pypetconstants.WRAP_MODE_NETQUEUE:
            self._prepare_netqueue()
        else:
            raise RuntimeError('The mutliprocessing mode %s, your choice is '
                                           'not supported, use %s`, `%s`, %s, `%s`, or `%s`.'
                                           % (self._wrap_mode, pypetconstants.WRAP_MODE_QUEUE,
                                              pypetconstants.WRAP_MODE_LOCK,
                                              pypetconstants.WRAP_MODE_PIPE,
                                              pypetconstants.WRAP_MODE_LOCAL,
                                              pypetconstants.WRAP_MODE_NETLOCK))
Wraps a Storage Service
dataset/ETHPy150Open SmokinCaterpillar/pypet/pypet/environment.py/MultiprocContext._do_wrap