Searched refs:req_queue (Results 1 – 4 of 4) sorted by relevance
| /external/pytorch/test/cpp_extensions/open_registration_extension/pytorch_openreg/ |
| D | _device_daemon.py | 92 self.req_queue = mp_context.Queue()
96 target=self.run_forever, args=(self.req_queue, self.ans_queue), daemon=True
105 self.req_queue.put((cmd,) + args)
114 def run_forever(req_queue, ans_queue): argument
122 cmd, *args = req_queue.get()
|
| /external/crosvm/devices/src/virtio/ |
| D | iommu.rs | 652 let req_queue = queues.remove(&0).unwrap(); in run() localVariable
653 let req_evt = req_queue in run()
676 let f_request = request_queue(&state, req_queue, req_evt); in run()
|
| /external/mesa3d/src/freedreno/decode/ |
| D | replay.c | 481 struct drm_msm_submitqueue req_queue = { in device_create() local
486 ret = drmCommandWriteRead(dev->fd, DRM_MSM_SUBMITQUEUE_NEW, &req_queue, in device_create()
487 sizeof(req_queue)); in device_create()
492 dev->queue_id = req_queue.id; in device_create()
|
| /external/pigweed/pw_bluetooth_sapphire/host/att/ |
| D | bearer.cc | 343 TransactionQueue req_queue(std::move(request_queue_)); in ShutDownInternal() local
361 req_queue.InvokeErrorAll(error); in ShutDownInternal()
|