Method _wait_for_samples

dali/python/nvidia/dali/_multiproc/shared_queue.py:95–102

(self)

        return recv

    def _wait_for_samples(self):
        waited = False
        self._read_meta()
        while not self.meta.size > 0 and not self.meta.is_closed:
            self.cv_not_empty.wait()
            waited = True
            self._read_meta()
        return waited

    def open_shm(self, handle, close_handle=True):
        try: