Searched refs:request_queue (Results 1 - 6 of 6) sorted by relevance
| /third_party/ffmpeg/libavfilter/dnn/ |
| H A D | dnn_backend_openvino.c | 58 SafeQueue *request_queue; // holds OVRequestItem member
206 SafeQueue *requestq = ov_model->request_queue; in infer_completion_callback()
299 av_log(ctx, AV_LOG_ERROR, "Failed to push back request_queue.\n"); in infer_completion_callback()
389 ov_model->request_queue = ff_safe_queue_create(); in init_model_ov()
390 if (!ov_model->request_queue) { in init_model_ov()
404 if (ff_safe_queue_push_back(ov_model->request_queue, item) < 0) { in init_model_ov()
496 if (ff_safe_queue_push_back(ov_model->request_queue, request) < 0) { in execute_model_ov()
710 request = ff_safe_queue_pop_front(ov_model->request_queue); in get_output_ov()
830 request = ff_safe_queue_pop_front(ov_model->request_queue); in ff_dnn_execute_model_ov()
857 request = ff_safe_queue_pop_front(ov_model->request_queue); in ff_dnn_execute_model_ov()
[all...] |
| H A D | dnn_backend_tf.c | 60 SafeQueue *request_queue; member
179 if (ff_safe_queue_push_back(tf_model->request_queue, request) < 0) { in tf_start_inference()
344 request = ff_safe_queue_pop_front(tf_model->request_queue); in get_output_tf()
896 tf_model->request_queue = ff_safe_queue_create(); in ff_dnn_load_model_tf()
897 if (!tf_model->request_queue) { in ff_dnn_load_model_tf()
918 if (ff_safe_queue_push_back(tf_model->request_queue, item) < 0) { in ff_dnn_load_model_tf()
1093 if (ff_safe_queue_push_back(tf_model->request_queue, request) < 0) { in infer_completion_callback()
1095 av_log(ctx, AV_LOG_ERROR, "Failed to push back request_queue.\n"); in infer_completion_callback()
1138 if (ff_safe_queue_push_back(tf_model->request_queue, request) < 0) { in execute_model_tf()
1181 request = ff_safe_queue_pop_front(tf_model->request_queue); in ff_dnn_execute_model_tf()
[all...] |
| /third_party/ltp/testcases/kernel/device-drivers/tbio/tbio_kernel/ |
| H A D | ltp_tbio.c | 74 struct request_queue *q;
77 static int send_request(struct request_queue *q, struct bio *bio, in send_request()
125 struct request_queue *q = bdev_get_queue(bdev); in tbio_io()
292 struct request_queue *q = bdev_get_queue(bdev); in test_bio_split()
462 static void tbio_request(struct request_queue *q) in tbio_request()
|
| /third_party/ltp/testcases/kernel/device-drivers/nls/ |
| H A D | nlsTest.c | 140 static void test_request(struct request_queue *q) in test_request()
148 struct request_queue *queue; in test_init_module()
|
| /third_party/python/Lib/idlelib/ |
| H A D | rpc.py | 124 request_queue = queue.Queue(0) variable
197 request_queue.put((seq, (method, args, kwargs)))
408 request_queue by self.localcall(). Responses to queued requests are
412 from the request_queue is responsible for returning the correct
|
| H A D | run.py | 157 request = rpc.request_queue.get(block=True, timeout=0.05)
|
Completed in 7 milliseconds