Home
last modified time | relevance | path

Searched refs:queue_id (Results 1 – 25 of 31) sorted by relevance

12

/third_party/flutter/engine/flutter/fml/
Dmessage_loop_task_queues_unittests.cc28 auto queue_id = task_queue->CreateTaskQueue(); in TEST() local
29 ASSERT_FALSE(task_queue->HasPendingTasks(queue_id)); in TEST()
36 auto queue_id = task_queue->CreateTaskQueue(); in TEST() local
37 task_queue->SetWakeable(queue_id, in TEST()
43 queue_id, [] {}, time); in TEST()
44 ASSERT_TRUE(task_queue->HasPendingTasks(queue_id)); in TEST()
45 ASSERT_TRUE(task_queue->GetNumPendingTasks(queue_id) == 1); in TEST()
50 auto queue_id = task_queue->CreateTaskQueue(); in TEST() local
52 queue_id, [] {}, fml::TimePoint::Now()); in TEST()
54 queue_id, [] {}, fml::TimePoint::Max()); in TEST()
[all …]
Dmessage_loop_task_queues.cc48 void MessageLoopTaskQueues::Dispose(TaskQueueId queue_id) { in Dispose() argument
50 const auto& queue_entry = queue_entries_.at(queue_id); in Dispose()
53 queue_entries_.erase(queue_id); in Dispose()
59 void MessageLoopTaskQueues::DisposeTasks(TaskQueueId queue_id) { in DisposeTasks() argument
64 const auto& queue_entry = queue_entries_.at(queue_id); in DisposeTasks()
74 void MessageLoopTaskQueues::RegisterTask(TaskQueueId queue_id, in RegisterTask() argument
79 const auto& queue_entry = queue_entries_.at(queue_id); in RegisterTask()
81 TaskQueueId loop_to_wake = queue_id; in RegisterTask()
89 bool MessageLoopTaskQueues::HasPendingTasks(TaskQueueId queue_id) const { in HasPendingTasks()
91 return HasPendingTasksUnlocked(queue_id); in HasPendingTasks()
[all …]
Dmessage_loop_task_queues.h76 void Dispose(TaskQueueId queue_id);
78 void DisposeTasks(TaskQueueId queue_id);
82 void RegisterTask(TaskQueueId queue_id,
86 bool HasPendingTasks(TaskQueueId queue_id) const;
88 void GetTasksToRunNow(TaskQueueId queue_id,
92 size_t GetNumPendingTasks(TaskQueueId queue_id) const;
96 void AddTaskObserver(TaskQueueId queue_id,
100 void RemoveTaskObserver(TaskQueueId queue_id, intptr_t key);
102 std::vector<fml::closure> GetObserversToNotify(TaskQueueId queue_id) const;
106 void SetWakeable(TaskQueueId queue_id, fml::Wakeable* wakeable);
[all …]
/third_party/ltp/testcases/kernel/syscalls/ipc/msgrcv/
Dmsgrcv07.c41 static int queue_id = -1, msg_copy_sup; variable
52 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL | MSG_RW); in prepare_queue()
53 SAFE_MSGSND(queue_id, &snd_buf[0], MSGSIZE, 0); in prepare_queue()
54 SAFE_MSGSND(queue_id, &snd_buf[1], MSGSIZE, 0); in prepare_queue()
62 TEST(msgrcv(queue_id, &rcv_buf, MSGSIZE, MSGTYPE2, MSG_EXCEPT)); in test_msg_except()
76 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in test_msg_except()
77 queue_id = -1; in test_msg_except()
84 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL | MSG_RW); in test_msg_noerror()
85 SAFE_MSGSND(queue_id, &snd_buf[0], MSGSIZE, 0); in test_msg_noerror()
89 TEST(msgrcv(queue_id, &rcv_buf, msg_len, MSGTYPE1, MSG_NOERROR)); in test_msg_noerror()
[all …]
Dmsgrcv02.c36 static int queue_id = -1; variable
54 {&queue_id, &rcv_buf, MSGSIZE - 1, 2, 0, 0, E2BIG},
55 {&queue_id, &rcv_buf, MSGSIZE, 2, 0, 1, EACCES},
56 {&queue_id, NULL, MSGSIZE, 2, 0, 0, EFAULT},
58 {&queue_id, &rcv_buf, -1, 2, 0, 0, EINVAL},
59 {&queue_id, &rcv_buf, MSGSIZE, 3, IPC_NOWAIT, 0, ENOMSG},
60 {&queue_id, &rcv_buf, MSGSIZE, -1, IPC_NOWAIT, 0, ENOMSG},
61 {&queue_id, &rcv_buf, MSGSIZE, -1, IPC_NOWAIT | MSG_EXCEPT, 0, ENOMSG},
75 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL | MSG_RW); in do_test()
77 SAFE_MSGSND(queue_id, &snd_buf, MSGSIZE, 0); in do_test()
[all …]
Dmsgrcv06.c19 static int queue_id = -1; variable
27 TST_EXP_FAIL2(msgrcv(queue_id, &rcv_buf, MSGSIZE, 1, 0), EIDRM, in verify_msgrcv()
28 "msgrcv(%i, %p, %d, 1, 0)", queue_id, &rcv_buf, MSGSIZE); in verify_msgrcv()
35 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL | MSG_RW); in do_test()
42 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in do_test()
53 if (queue_id != -1) in cleanup()
54 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in cleanup()
Dmsgrcv03.c34 static int queue_id = -1; variable
62 …TST_EXP_FAIL2(msgrcv(queue_id, &rcv_buf, MSGSIZE, tc->msg_type, MSG_COPY | tc->msg_flag), tc->exp_… in verify_msgrcv()
63 "msgrcv(%i, %p, %i, %i, %i)", queue_id, &rcv_buf, MSGSIZE, tc->msg_type, MSG_COPY | tc->msg_flag); in verify_msgrcv()
69 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL | MSG_RW); in setup()
70 SAFE_MSGSND(queue_id, &snd_buf, MSGSIZE, 0); in setup()
75 if (queue_id != -1) in cleanup()
76 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in cleanup()
Dmsgrcv01.c16 static int queue_id = -1, pid; variable
27 SAFE_MSGSND(queue_id, &snd_buf, MSGSIZE, 0); in verify_msgrcv()
30 TEST(msgrcv(queue_id, &rcv_buf, MSGSIZE, 1, 0)); in verify_msgrcv()
44 SAFE_MSGCTL(queue_id, IPC_STAT, &qs_buf); in verify_msgrcv()
68 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL | MSG_RW); in setup()
74 if (queue_id != -1) in cleanup()
75 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in cleanup()
Dmsgrcv05.c17 static int queue_id = -1; variable
33 TST_EXP_FAIL2(msgrcv(queue_id, &rcv_buf, MSGSIZE, 1, 0), EINTR, in verify_msgrcv()
34 "msgrcv(%i, %p, %d, 1, 0)", queue_id, &rcv_buf, MSGSIZE); in verify_msgrcv()
54 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL | MSG_RW); in setup()
60 if (queue_id != -1) in cleanup()
61 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in cleanup()
Dmsgrcv08.c34 static int queue_id = -1; variable
43 SAFE_MSGSND(queue_id, &snd_buf, sizeof(snd_buf.mtext), IPC_NOWAIT); in verify_msgrcv()
45 TEST(msgrcv(queue_id, &rcv_buf, sizeof(rcv_buf.mtext), -mtype, IPC_NOWAIT | MSG_NOERROR)); in verify_msgrcv()
66 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL | MSG_RW); in setup()
71 if (queue_id != -1) in cleanup()
72 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in cleanup()
/third_party/ltp/testcases/kernel/syscalls/ipc/msgget/
Dmsgget05.c27 static int queue_id[2], pid; variable
32 SAFE_FILE_PRINTF(NEXT_ID_PATH, "%d", queue_id[0]); in verify_msgget()
34 queue_id[1] = SAFE_MSGGET(msgkey[1], IPC_CREAT | MSG_RW); in verify_msgget()
35 if (queue_id[1] == queue_id[0]) in verify_msgget()
37 " same msg id unexpectedly", queue_id[0]); in verify_msgget()
40 " new msgid %d", queue_id[0], queue_id[1]); in verify_msgget()
42 SAFE_MSGCTL(queue_id[1], IPC_RMID, NULL); in verify_msgget()
51 queue_id[0] = SAFE_MSGGET(msgkey[0], IPC_CREAT | MSG_RW); in setup()
59 if (queue_id[i] != -1) in cleanup()
60 SAFE_MSGCTL(queue_id[i], IPC_RMID, NULL); in cleanup()
Dmsgget04.c28 static int queue_id, pid; variable
35 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | MSG_RW); in verify_msgget()
36 if (queue_id == pid) in verify_msgget()
39 tst_res(TFAIL, "msg_next_id failed, expected id %d, but got %d", pid, queue_id); in verify_msgget()
42 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in verify_msgget()
54 if (queue_id != -1) in cleanup()
55 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in cleanup()
Dmsgget01.c23 static int queue_id = -1; variable
39 queue_id = TST_RET; in verify_msgget()
41 SAFE_MSGSND(queue_id, &snd_buf, MSGSIZE, 0); in verify_msgget()
43 SAFE_MSGRCV(queue_id, &rcv_buf, MSGSIZE, MSGTYPE, IPC_NOWAIT); in verify_msgget()
58 if (queue_id != -1) in cleanup()
59 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in cleanup()
Dmsgget02.c32 static int queue_id = -1; variable
80 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL); in setup()
87 if (queue_id != -1) in cleanup()
88 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in cleanup()
/third_party/ltp/testcases/kernel/syscalls/ipc/msgsnd/
Dmsgsnd06.c23 static int queue_id = -1; variable
31 TST_EXP_FAIL(msgsnd(queue_id, &snd_buf, MSGSIZE, 0), EIDRM, in verify_msgsnd()
32 "msgsnd(%i, %p, %i, 0)", queue_id, &snd_buf, MSGSIZE); in verify_msgsnd()
39 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL | MSG_RW); in do_test()
41 while (msgsnd(queue_id, &snd_buf, MSGSIZE, IPC_NOWAIT) != -1) in do_test()
52 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in do_test()
64 if (queue_id != -1) in cleanup()
65 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in cleanup()
Dmsgsnd02.c34 static int queue_id = -1; variable
54 {&queue_id, &snd_buf[0], MSGSIZE, EACCES, 1},
55 {&queue_id, NULL, MSGSIZE, EFAULT, 0},
57 {&queue_id, &snd_buf[1], MSGSIZE, EINVAL, 0},
58 {&queue_id, &snd_buf[2], MSGSIZE, EINVAL, 0},
59 {&queue_id, &snd_buf[0], -1, EINVAL, 0}
91 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL | MSG_RW); in setup()
98 if (queue_id != -1) in cleanup()
99 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in cleanup()
Dmsgsnd05.c26 static int queue_id = -1; variable
44 TST_EXP_FAIL(msgsnd(queue_id, &snd_buf, MSGSIZE, tc->flag), tc->exp_err, in verify_msgsnd()
45 "msgsnd(%i, %p, %i, %i)", queue_id, &snd_buf, MSGSIZE, tc->flag); in verify_msgsnd()
82 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL | MSG_RW); in setup()
84 while (msgsnd(queue_id, &snd_buf, MSGSIZE, IPC_NOWAIT) != -1) in setup()
90 if (queue_id != -1) in cleanup()
91 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in cleanup()
Dmsgsnd01.c22 static int queue_id = -1, pid; variable
34 TEST(msgsnd(queue_id, &snd_buf, MSGSIZE, 0)); in verify_msgsnd()
41 SAFE_MSGCTL(queue_id, IPC_STAT, &qs_buf); in verify_msgsnd()
63 SAFE_MSGRCV(queue_id, &rcv_buf, MSGSIZE, 1, 0); in verify_msgsnd()
69 queue_id = SAFE_MSGGET(msgkey, IPC_CREAT | IPC_EXCL | MSG_RW); in setup()
75 if (queue_id != -1) in cleanup()
76 SAFE_MSGCTL(queue_id, IPC_RMID, NULL); in cleanup()
/third_party/libdrm/freedreno/msm/
Dmsm_pipe.c84 .queueid = to_msm_pipe(pipe)->queue_id, in msm_pipe_wait()
109 to_msm_pipe(pipe)->queue_id = 0; in open_submitqueue()
124 to_msm_pipe(pipe)->queue_id = req.id; in open_submitqueue()
128 static void close_submitqueue(struct fd_pipe *pipe, uint32_t queue_id) in close_submitqueue() argument
134 &queue_id, sizeof(queue_id)); in close_submitqueue()
140 close_submitqueue(pipe, msm_pipe->queue_id); in msm_pipe_destroy()
Dmsm_priv.h59 uint32_t queue_id; member
/third_party/mesa3d/src/freedreno/drm/
Dmsm_pipe.c57 .id = msm_pipe->queue_id, in query_queue_param()
116 .queueid = to_msm_pipe(pipe)->queue_id, in msm_pipe_wait()
141 to_msm_pipe(pipe)->queue_id = 0; in open_submitqueue()
156 to_msm_pipe(pipe)->queue_id = req.id; in open_submitqueue()
161 close_submitqueue(struct fd_pipe *pipe, uint32_t queue_id) in close_submitqueue() argument
166 drmCommandWrite(pipe->dev->fd, DRM_MSM_SUBMITQUEUE_CLOSE, &queue_id, in close_submitqueue()
167 sizeof(queue_id)); in close_submitqueue()
178 close_submitqueue(pipe, msm_pipe->queue_id); in msm_pipe_destroy()
/third_party/ltp/libs/libltpipc/
Dlibipc.c83 void rm_queue(int queue_id) in rm_queue() argument
85 if (queue_id == -1) { /* no queue to remove */ in rm_queue()
89 if (msgctl(queue_id, IPC_RMID, NULL) == -1) { in rm_queue()
92 tst_resm(TINFO, "id = %d", queue_id); in rm_queue()
/third_party/mesa3d/src/freedreno/vulkan/
Dtu_kgsl.c56 uint32_t *queue_id) in tu_drm_submitqueue_new() argument
68 *queue_id = req.drawctxt_id; in tu_drm_submitqueue_new()
74 tu_drm_submitqueue_close(const struct tu_device *dev, uint32_t queue_id) in tu_drm_submitqueue_close() argument
77 .drawctxt_id = queue_id, in tu_drm_submitqueue_close()
/third_party/gstreamer/gstplugins_bad/sys/wasapi2/
Dgstwasapi2ringbuffer.cpp39 DWORD queue_id, in GstWasapiAsyncCallback() argument
42 , queue_id_(queue_id) in GstWasapiAsyncCallback()
247 DWORD queue_id = 0; in gst_wasapi2_ring_buffer_constructed() local
249 hr = MFLockSharedWorkQueue (L"Pro Audio", 0, &task_id, &queue_id); in gst_wasapi2_ring_buffer_constructed()
255 self->callback_object = new GstWasapiAsyncCallback (self, queue_id, FALSE); in gst_wasapi2_ring_buffer_constructed()
265 new GstWasapiAsyncCallback (self, queue_id, TRUE); in gst_wasapi2_ring_buffer_constructed()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_server.h192 Status PushRequest(int32_t queue_id, CacheServerRequest *rq) { in PushRequest() argument
194 RETURN_IF_NOT_OK(cache_q_->operator[](queue_id)->Add(rq)); in PushRequest()

12