Home
last modified time | relevance | path

Searched refs:event_queue (Results 1 – 25 of 1345) sorted by relevance

12345678910>>...54

/dports/net/freerdp/freerdp-2.5.0/server/Mac/
H A Dmf_event.c96 if (event_queue->count >= event_queue->size) in mf_event_push()
98 event_queue->size *= 2; in mf_event_push()
99 event_queue->events = in mf_event_push()
103 event_queue->events[(event_queue->count)++] = event; in mf_event_push()
139 (event_queue->count)--; in mf_event_pop()
141 memmove(&event_queue->events[0], &event_queue->events[1], event_queue->count * sizeof(void*)); in mf_event_pop()
186 if (event_queue != NULL) in mf_event_queue_new()
191 event_queue->size = 16; in mf_event_queue_new()
192 event_queue->count = 0; in mf_event_queue_new()
197 free(event_queue); in mf_event_queue_new()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/modules/service_worker/
H A Dservice_worker_event_queue_test.cc159 event_queue.Start(); in TEST_F()
218 event_queue.Start(); in TEST_F()
252 event_queue.Start(); in TEST_F()
265 event_queue.Start(); in TEST_F()
289 event_queue.Start(); in TEST_F()
318 event_queue.Start(); in TEST_F()
362 event_queue.Start(); in TEST_F()
383 event_queue.Start(); in TEST_F()
410 event_queue.Start(); in TEST_F()
524 event_queue.Start(); in TEST_F()
[all …]
/dports/devel/grpc130/grpc-1.30.2/src/ruby/ext/grpc/
H A Drb_event_thread.c58 gpr_mu_lock(&event_queue.mu); in grpc_rb_event_queue_enqueue()
60 event_queue.head = event_queue.tail = event; in grpc_rb_event_queue_enqueue()
63 event_queue.tail = event; in grpc_rb_event_queue_enqueue()
74 event = event_queue.head; in grpc_rb_event_queue_dequeue()
76 event_queue.head = event_queue.tail = NULL; in grpc_rb_event_queue_dequeue()
78 event_queue.head = event_queue.head->next; in grpc_rb_event_queue_dequeue()
93 while (!event_queue.abort) { in grpc_rb_wait_for_event_no_gil()
98 gpr_cv_wait(&event_queue.cv, &event_queue.mu, in grpc_rb_wait_for_event_no_gil()
108 event_queue.abort = true; in grpc_rb_event_unblocking_func()
137 event_queue.head = event_queue.tail = NULL; in grpc_rb_event_queue_thread_start()
[all …]
/dports/devel/grpc134/grpc-1.34.1/src/ruby/ext/grpc/
H A Drb_event_thread.c58 gpr_mu_lock(&event_queue.mu); in grpc_rb_event_queue_enqueue()
60 event_queue.head = event_queue.tail = event; in grpc_rb_event_queue_enqueue()
63 event_queue.tail = event; in grpc_rb_event_queue_enqueue()
74 event = event_queue.head; in grpc_rb_event_queue_dequeue()
76 event_queue.head = event_queue.tail = NULL; in grpc_rb_event_queue_dequeue()
78 event_queue.head = event_queue.head->next; in grpc_rb_event_queue_dequeue()
93 while (!event_queue.abort) { in grpc_rb_wait_for_event_no_gil()
98 gpr_cv_wait(&event_queue.cv, &event_queue.mu, in grpc_rb_wait_for_event_no_gil()
108 event_queue.abort = true; in grpc_rb_event_unblocking_func()
137 event_queue.head = event_queue.tail = NULL; in grpc_rb_event_queue_thread_start()
[all …]
/dports/devel/grpc/grpc-1.42.0/src/ruby/ext/grpc/
H A Drb_event_thread.c60 gpr_mu_lock(&event_queue.mu); in grpc_rb_event_queue_enqueue()
62 event_queue.head = event_queue.tail = event; in grpc_rb_event_queue_enqueue()
65 event_queue.tail = event; in grpc_rb_event_queue_enqueue()
76 event = event_queue.head; in grpc_rb_event_queue_dequeue()
78 event_queue.head = event_queue.tail = NULL; in grpc_rb_event_queue_dequeue()
80 event_queue.head = event_queue.head->next; in grpc_rb_event_queue_dequeue()
95 while (!event_queue.abort) { in grpc_rb_wait_for_event_no_gil()
100 gpr_cv_wait(&event_queue.cv, &event_queue.mu, in grpc_rb_wait_for_event_no_gil()
110 event_queue.abort = true; in grpc_rb_event_unblocking_func()
139 event_queue.head = event_queue.tail = NULL; in grpc_rb_event_queue_thread_start()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/ruby/ext/grpc/
H A Drb_event_thread.c58 gpr_mu_lock(&event_queue.mu); in grpc_rb_event_queue_enqueue()
60 event_queue.head = event_queue.tail = event; in grpc_rb_event_queue_enqueue()
63 event_queue.tail = event; in grpc_rb_event_queue_enqueue()
74 event = event_queue.head; in grpc_rb_event_queue_dequeue()
76 event_queue.head = event_queue.tail = NULL; in grpc_rb_event_queue_dequeue()
78 event_queue.head = event_queue.head->next; in grpc_rb_event_queue_dequeue()
93 while (!event_queue.abort) { in grpc_rb_wait_for_event_no_gil()
98 gpr_cv_wait(&event_queue.cv, &event_queue.mu, in grpc_rb_wait_for_event_no_gil()
108 event_queue.abort = true; in grpc_rb_event_unblocking_func()
137 event_queue.head = event_queue.tail = NULL; in grpc_rb_event_queue_thread_start()
[all …]
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/modules/service_worker/
H A Dservice_worker_event_queue_test.cc142 event_queue.Start(); in TEST_F()
201 event_queue.Start(); in TEST_F()
235 event_queue.Start(); in TEST_F()
248 event_queue.Start(); in TEST_F()
272 event_queue.Start(); in TEST_F()
301 event_queue.Start(); in TEST_F()
321 event_queue.Start(); in TEST_F()
345 event_queue.Start(); in TEST_F()
367 event_queue.Start(); in TEST_F()
481 event_queue.Start(); in TEST_F()
[all …]
/dports/devel/etl/synfig-1.2.2/synfig-osx/launcher/
H A Ddarwin-input.c47 } event_queue; variable
58 pthread_mutex_lock (&event_queue.mutex); in DarwinEnqueueEvent()
63 && event_queue.tail != event_queue.head in DarwinEnqueueEvent()
74 if (newtail != event_queue.head) in DarwinEnqueueEvent()
76 memcpy (&event_queue.events[event_queue.tail], e, sizeof (xEvent)); in DarwinEnqueueEvent()
77 event_queue.tail = newtail; in DarwinEnqueueEvent()
96 if (event_queue.head != event_queue.tail) in DarwinDequeueEvent()
98 memcpy (e, &event_queue.events[event_queue.head], sizeof (xEvent)); in DarwinDequeueEvent()
99 event_queue.head = (event_queue.head + 1) % QUEUE_SIZE; in DarwinDequeueEvent()
120 event_queue.head = event_queue.tail = 0; in DarwinInputPreInit()
[all …]
/dports/graphics/synfig/synfig-1.2.2/synfig-osx/launcher/
H A Ddarwin-input.c47 } event_queue; variable
58 pthread_mutex_lock (&event_queue.mutex); in DarwinEnqueueEvent()
63 && event_queue.tail != event_queue.head in DarwinEnqueueEvent()
74 if (newtail != event_queue.head) in DarwinEnqueueEvent()
76 memcpy (&event_queue.events[event_queue.tail], e, sizeof (xEvent)); in DarwinEnqueueEvent()
77 event_queue.tail = newtail; in DarwinEnqueueEvent()
96 if (event_queue.head != event_queue.tail) in DarwinDequeueEvent()
98 memcpy (e, &event_queue.events[event_queue.head], sizeof (xEvent)); in DarwinDequeueEvent()
99 event_queue.head = (event_queue.head + 1) % QUEUE_SIZE; in DarwinDequeueEvent()
120 event_queue.head = event_queue.tail = 0; in DarwinInputPreInit()
[all …]
/dports/graphics/synfigstudio/synfig-1.2.2/synfig-osx/launcher/
H A Ddarwin-input.c47 } event_queue; variable
58 pthread_mutex_lock (&event_queue.mutex); in DarwinEnqueueEvent()
63 && event_queue.tail != event_queue.head in DarwinEnqueueEvent()
74 if (newtail != event_queue.head) in DarwinEnqueueEvent()
76 memcpy (&event_queue.events[event_queue.tail], e, sizeof (xEvent)); in DarwinEnqueueEvent()
77 event_queue.tail = newtail; in DarwinEnqueueEvent()
96 if (event_queue.head != event_queue.tail) in DarwinDequeueEvent()
98 memcpy (e, &event_queue.events[event_queue.head], sizeof (xEvent)); in DarwinDequeueEvent()
99 event_queue.head = (event_queue.head + 1) % QUEUE_SIZE; in DarwinDequeueEvent()
120 event_queue.head = event_queue.tail = 0; in DarwinInputPreInit()
[all …]
/dports/security/doscan/doscan-0.3.3/src/
H A Devent_queue.h55 class event_queue {
70 friend class event_queue; variable
78 event_queue& m_queue;
87 handler(event_queue&);
90 event_queue& queue() const;
174 event_queue();
175 virtual ~event_queue();
197 event_queue::handler::compare_timeout(const event_queue::handler& that) const in compare_timeout()
202 inline event_queue&
203 event_queue::handler::queue() const in queue()
[all …]
H A Devent_queue.cc26 event_queue::handler::handler(event_queue& q) in handler()
32 event_queue::handler::~handler() in ~handler()
54 event_queue::fd_handler::fd_handler(event_queue& q, int fd, watch_options w) in fd_handler()
62 event_queue::fd_handler::~fd_handler() in ~fd_handler()
85 event_queue::fd_handler::unwatch() in unwatch()
95 event_queue::event_queue() in event_queue() function in event_queue
99 event_queue::~event_queue() in ~event_queue()
108 event_queue::dispatch_end() in dispatch_end()
132 event_queue::next_timeout() in next_timeout()
152 event_queue::remove_fd(fd_handler*) in remove_fd()
[all …]
/dports/emulators/citra/citra-ac98458e0/src/core/
H A Dcore_timing.cpp73 std::push_heap(timer->event_queue.begin(), timer->event_queue.end(), std::greater<>()); in ScheduleEvent()
86 timer->event_queue.begin(), timer->event_queue.end(), in UnscheduleEvent()
91 timer->event_queue.erase(itr, timer->event_queue.end()); in UnscheduleEvent()
92 std::make_heap(timer->event_queue.begin(), timer->event_queue.end(), std::greater<>()); in UnscheduleEvent()
103 auto itr = std::remove_if(timer->event_queue.begin(), timer->event_queue.end(), in RemoveEvent()
108 timer->event_queue.erase(itr, timer->event_queue.end()); in RemoveEvent()
173 std::push_heap(event_queue.begin(), event_queue.end(), std::greater<>()); in MoveEvents()
197 while (!event_queue.empty() && event_queue.front().time <= executed_ticks) { in Advance()
199 std::pop_heap(event_queue.begin(), event_queue.end(), std::greater<>()); in Advance()
200 event_queue.pop_back(); in Advance()
[all …]
/dports/emulators/citra-qt5/citra-ac98458e0/src/core/
H A Dcore_timing.cpp73 std::push_heap(timer->event_queue.begin(), timer->event_queue.end(), std::greater<>()); in ScheduleEvent()
86 timer->event_queue.begin(), timer->event_queue.end(), in UnscheduleEvent()
91 timer->event_queue.erase(itr, timer->event_queue.end()); in UnscheduleEvent()
92 std::make_heap(timer->event_queue.begin(), timer->event_queue.end(), std::greater<>()); in UnscheduleEvent()
103 auto itr = std::remove_if(timer->event_queue.begin(), timer->event_queue.end(), in RemoveEvent()
108 timer->event_queue.erase(itr, timer->event_queue.end()); in RemoveEvent()
173 std::push_heap(event_queue.begin(), event_queue.end(), std::greater<>()); in MoveEvents()
197 while (!event_queue.empty() && event_queue.front().time <= executed_ticks) { in Advance()
199 std::pop_heap(event_queue.begin(), event_queue.end(), std::greater<>()); in Advance()
200 event_queue.pop_back(); in Advance()
[all …]
/dports/emulators/yuzu/yuzu-0b47f7a46/src/core/
H A Dcore_timing.cpp116 std::push_heap(event_queue.begin(), event_queue.end(), std::greater<>()); in ScheduleEvent()
130 event_queue.erase(itr, event_queue.end()); in UnscheduleEvent()
131 std::make_heap(event_queue.begin(), event_queue.end(), std::greater<>()); in UnscheduleEvent()
141 if (!event_queue.empty()) { in Idle()
171 event_queue.clear(); in ClearPendingEvents()
183 event_queue.erase(itr, event_queue.end()); in RemoveEvent()
184 std::make_heap(event_queue.begin(), event_queue.end(), std::greater<>()); in RemoveEvent()
192 while (!event_queue.empty() && event_queue.front().time <= global_timer) { in Advance()
194 std::pop_heap(event_queue.begin(), event_queue.end(), std::greater<>()); in Advance()
195 event_queue.pop_back(); in Advance()
[all …]
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/content/renderer/input/
H A Dmain_thread_event_queue_unittest.cc336 EXPECT_EQ(0u, event_queue().size()); in TEST_F()
345 EXPECT_EQ(2u, event_queue().size()); in TEST_F()
352 EXPECT_EQ(0u, event_queue().size()); in TEST_F()
439 EXPECT_EQ(3u, event_queue().size()); in TEST_F()
446 EXPECT_EQ(0u, event_queue().size()); in TEST_F()
557 EXPECT_EQ(1u, event_queue().size()); in TEST_F()
582 EXPECT_EQ(0u, event_queue().size()); in TEST_F()
589 EXPECT_EQ(2u, event_queue().size()); in TEST_F()
596 EXPECT_EQ(0u, event_queue().size()); in TEST_F()
645 EXPECT_EQ(0u, event_queue().size()); in TEST_F()
[all …]
/dports/devel/py-watchdog/watchdog-2.1.6/tests/
H A Dtest_emitter.py68 global p, emitter, event_queue
70 event_queue = Queue()
138 event = event_queue.get(timeout=5)[0]
142 event = event_queue.get(timeout=5)[0]
149 assert event_queue.empty()
445 event_queue.get(timeout=5)
459 event_queue.get(timeout=5)
462 event_queue.get(timeout=5)
505 if event_queue.empty():
554 if event_queue.empty():
[all …]
/dports/comms/mgetty+sendfax/mgetty-1.1.37/voice/libvoice/
H A Devent.c25 } event_queue[MAX_EVENTS]; variable
300 event_queue[event_number].write_lock++; in queue_event()
319 event_queue[event_number].event = event; in queue_event()
320 event_queue[event_number].write_lock--; in queue_event()
330 event_queue[event_number].read_lock++; in unqueue_event()
335 event_queue[event_number].read_lock--; in unqueue_event()
342 event_queue[event_number].read_lock--; in unqueue_event()
344 event_queue[event_number].read_lock++; in unqueue_event()
349 event_queue[event_number].read_lock--; in unqueue_event()
355 event_queue[event_number].read_lock--; in unqueue_event()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/platform/widget/input/
H A Dmain_thread_event_queue_unittest.cc327 EXPECT_EQ(0u, event_queue().size()); in TEST_F()
336 EXPECT_EQ(2u, event_queue().size()); in TEST_F()
343 EXPECT_EQ(0u, event_queue().size()); in TEST_F()
426 EXPECT_EQ(3u, event_queue().size()); in TEST_F()
433 EXPECT_EQ(0u, event_queue().size()); in TEST_F()
549 EXPECT_EQ(1u, event_queue().size()); in TEST_F()
574 EXPECT_EQ(0u, event_queue().size()); in TEST_F()
585 EXPECT_EQ(2u, event_queue().size()); in TEST_F()
592 EXPECT_EQ(0u, event_queue().size()); in TEST_F()
641 EXPECT_EQ(0u, event_queue().size()); in TEST_F()
[all …]
/dports/devel/libinotify/libinotify-20180201/
H A Devent-queue.h33 typedef struct event_queue { struct
39 } event_queue; argument
41 void event_queue_init (event_queue *eq);
42 void event_queue_free (event_queue *eq);
44 int event_queue_set_max_events (event_queue *eq, int max_events);
46 int event_queue_enqueue (event_queue *eq,
51 void event_queue_flush (event_queue *eq, size_t sbspace);
52 void event_queue_reset_last (event_queue *eq);
/dports/math/octave/octave-6.4.0/libinterp/corefcn/
H A Devent-queue.h39 event_queue : public action_container
43 event_queue (void) : fifo () { } in event_queue() function
47 event_queue (const event_queue&) = delete;
49 event_queue& operator = (const event_queue&) = delete;
55 ~event_queue (void) { run (); } in ~event_queue()
95 event_queue_safe : public event_queue
103 event_queue_safe (void) : event_queue () { } in event_queue_safe()
/dports/devel/avr-gdb/gdb-7.3.1/sim/ppc/
H A Devents.h31 (event_queue *) event_queue_create
36 (event_queue *queue);
43 (event_queue *queue,
50 (event_queue *queue,
57 (event_queue *queue,
66 (event_queue *queue);
70 (event_queue *events);
77 (event_queue *queue);
/dports/devel/gdb761/gdb-7.6.1/sim/ppc/
H A Devents.h30 (event_queue *) event_queue_create
35 (event_queue *queue);
42 (event_queue *queue,
49 (event_queue *queue,
56 (event_queue *queue,
65 (event_queue *queue);
69 (event_queue *events);
76 (event_queue *queue);
/dports/devel/zpu-binutils/zpu-toolchain-1.0/toolchain/gdb/sim/ppc/
H A Devents.h31 (event_queue *) event_queue_create
36 (event_queue *queue);
43 (event_queue *queue,
50 (event_queue *queue,
57 (event_queue *queue,
66 (event_queue *queue);
70 (event_queue *events);
77 (event_queue *queue);
/dports/devel/zpu-gcc/zpu-toolchain-1.0/toolchain/gdb/sim/ppc/
H A Devents.h31 (event_queue *) event_queue_create
36 (event_queue *queue);
43 (event_queue *queue,
50 (event_queue *queue,
57 (event_queue *queue,
66 (event_queue *queue);
70 (event_queue *events);
77 (event_queue *queue);

12345678910>>...54