Method _write_msg

dali/python/nvidia/dali/_multiproc/shared_queue.py:79–81

(self, i, msg)

        return msg

    def _write_msg(self, i, msg):
        offset = self.msgs_offsets[i]
        msg.pack_into(self.shm.buf, offset)

    def _recv_samples(self, num_samples):
        num_take = self.meta.size