Method _init_offsets

dali/python/nvidia/dali/_multiproc/shared_queue.py:64–65

(self)

        self._init_offsets()

    def _init_offsets(self):
        self.msgs_offsets = [i * self.msg_size + self.meta_size for i in range(self.capacity)]

    def _read_meta(self):
        self.meta.unpack_from(self.shm.buf, 0)