/dports/net/freerdp/freerdp-2.5.0/server/Mac/ |
H A D | mf_event.c | 96 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 D | service_worker_event_queue_test.cc | 159 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 D | rb_event_thread.c | 58 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 D | rb_event_thread.c | 58 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 D | rb_event_thread.c | 60 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 D | rb_event_thread.c | 58 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 D | service_worker_event_queue_test.cc | 142 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 D | darwin-input.c | 47 } 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 D | darwin-input.c | 47 } 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 D | darwin-input.c | 47 } 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 D | event_queue.h | 55 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 D | event_queue.cc | 26 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 D | core_timing.cpp | 73 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 D | core_timing.cpp | 73 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 D | core_timing.cpp | 116 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 D | main_thread_event_queue_unittest.cc | 336 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 D | test_emitter.py | 68 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 D | event.c | 25 } 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 D | main_thread_event_queue_unittest.cc | 327 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 D | event-queue.h | 33 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 D | event-queue.h | 39 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 D | events.h | 31 (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 D | events.h | 30 (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 D | events.h | 31 (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 D | events.h | 31 (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);
|