| /dports/audio/ardour6/Ardour-6.8.0/libs/pbd/ |
| H A D | event_loop.cc | 38 Glib::Threads::Private<EventLoop> EventLoop::thread_event_loop (do_not_delete_the_loop_pointer);
41 EventLoop::ThreadRequestBufferList EventLoop::thread_buffer_requests;
42 EventLoop::RequestBufferSuppliers EventLoop::request_buffer_suppliers;
44 EventLoop::EventLoop (string const& name) in EventLoop() function in EventLoop
49 EventLoop::~EventLoop () in ~EventLoop()
61 EventLoop*
62 EventLoop::get_event_loop_for_thread() in get_event_loop_for_thread()
68 EventLoop::set_event_loop_for_thread (EventLoop* loop) in set_event_loop_for_thread()
74 EventLoop::invalidate_request (void* data) in invalidate_request()
112 vector<EventLoop::ThreadBufferMapping>
[all …]
|
| /dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/src/ |
| H A D | event_loop.cpp | 47 EventLoop::EventLoop() in EventLoop() function in EventLoop
57 EventLoop::~EventLoop() { in ~EventLoop()
92 int EventLoop::run() { in run()
98 void EventLoop::close_handles() { in close_handles()
103 void EventLoop::join() { in join()
112 void EventLoop::add(Task* task) { in add()
117 void EventLoop::maybe_start_io_time() { in maybe_start_io_time()
125 void EventLoop::on_run() { in on_run()
156 bool EventLoop::TaskQueue::is_empty() { in is_empty()
162 EventLoop* thread = static_cast<EventLoop*>(arg); in internal_on_run()
[all …]
|
| H A D | event_loop.hpp | 37 class EventLoop;
45 virtual void run(EventLoop* event_loop) = 0;
51 class EventLoop : public Allocated { class
53 EventLoop();
55 virtual ~EventLoop();
186 virtual EventLoop* add(Task* task) = 0;
195 virtual EventLoop* get(size_t index) = 0;
213 , threads_(new EventLoop[num_threads]) in RoundRobinEventLoopGroup()
221 virtual EventLoop* add(Task* task);
222 virtual EventLoop* get(size_t index) { return &threads_[index]; } in get()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/platform/scheduler/common/ |
| H A D | event_loop.cc | 17 EventLoop::EventLoop(v8::Isolate* isolate, in EventLoop() function in blink::scheduler::EventLoop
26 EventLoop::~EventLoop() { in ~EventLoop()
30 void EventLoop::EnqueueMicrotask(base::OnceClosure task) { in EnqueueMicrotask()
36 isolate_->EnqueueMicrotask(&EventLoop::RunPendingMicrotask, this); in EnqueueMicrotask()
40 void EventLoop::PerformMicrotaskCheckpoint() { in PerformMicrotaskCheckpoint()
50 void EventLoop::Disable() { in Disable()
60 void EventLoop::Enable() { in Enable()
70 void EventLoop::AttachScheduler(FrameOrWorkerScheduler* scheduler) { in AttachScheduler()
76 void EventLoop::DetachScheduler(FrameOrWorkerScheduler* scheduler) { in DetachScheduler()
87 void EventLoop::RunPendingMicrotask(void* data) { in RunPendingMicrotask()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/platform/scheduler/common/ |
| H A D | event_loop.cc | 17 EventLoop::EventLoop(v8::Isolate* isolate, in EventLoop() function in blink::scheduler::EventLoop
26 EventLoop::~EventLoop() { in ~EventLoop()
30 void EventLoop::EnqueueMicrotask(base::OnceClosure task) { in EnqueueMicrotask()
36 isolate_->EnqueueMicrotask(&EventLoop::RunPendingMicrotask, this); in EnqueueMicrotask()
40 void EventLoop::PerformMicrotaskCheckpoint() { in PerformMicrotaskCheckpoint()
50 void EventLoop::Disable() { in Disable()
60 void EventLoop::Enable() { in Enable()
70 void EventLoop::AttachScheduler(FrameOrWorkerScheduler* scheduler) { in AttachScheduler()
76 void EventLoop::DetachScheduler(FrameOrWorkerScheduler* scheduler) { in DetachScheduler()
87 void EventLoop::RunPendingMicrotask(void* data) { in RunPendingMicrotask()
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/plasma/ |
| H A D | events.cc | 41 int EventLoop::TimerEventCallback(aeEventLoop* loop, TimerID timer_id, void* context) { in TimerEventCallback()
48 EventLoop::EventLoop() { loop_ = aeCreateEventLoop(kInitialEventLoopSize); } in EventLoop() function in plasma::EventLoop
50 bool EventLoop::AddFileEvent(int fd, int events, const FileCallback& callback) { in AddFileEvent()
64 err = aeCreateFileEvent(loop_, fd, events, EventLoop::FileEventCallback, context); in AddFileEvent()
74 void EventLoop::RemoveFileEvent(int fd) { in RemoveFileEvent()
79 void EventLoop::Start() { aeMain(loop_); } in Start()
81 void EventLoop::Stop() { aeStop(loop_); } in Stop()
83 void EventLoop::Shutdown() { in Shutdown()
90 EventLoop::~EventLoop() { Shutdown(); } in ~EventLoop()
92 int64_t EventLoop::AddTimer(int64_t timeout, const TimerCallback& callback) { in AddTimer()
[all …]
|
| /dports/databases/arrow/apache-arrow-6.0.1/cpp/src/plasma/ |
| H A D | events.cc | 41 int EventLoop::TimerEventCallback(aeEventLoop* loop, TimerID timer_id, void* context) { in TimerEventCallback()
48 EventLoop::EventLoop() { loop_ = aeCreateEventLoop(kInitialEventLoopSize); } in EventLoop() function in plasma::EventLoop
50 bool EventLoop::AddFileEvent(int fd, int events, const FileCallback& callback) { in AddFileEvent()
64 err = aeCreateFileEvent(loop_, fd, events, EventLoop::FileEventCallback, context); in AddFileEvent()
74 void EventLoop::RemoveFileEvent(int fd) { in RemoveFileEvent()
79 void EventLoop::Start() { aeMain(loop_); } in Start()
81 void EventLoop::Stop() { aeStop(loop_); } in Stop()
83 void EventLoop::Shutdown() { in Shutdown()
90 EventLoop::~EventLoop() { Shutdown(); } in ~EventLoop()
92 int64_t EventLoop::AddTimer(int64_t timeout, const TimerCallback& callback) { in AddTimer()
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/plasma/ |
| H A D | events.cc | 41 int EventLoop::TimerEventCallback(aeEventLoop* loop, TimerID timer_id, void* context) { in TimerEventCallback()
48 EventLoop::EventLoop() { loop_ = aeCreateEventLoop(kInitialEventLoopSize); } in EventLoop() function in plasma::EventLoop
50 bool EventLoop::AddFileEvent(int fd, int events, const FileCallback& callback) { in AddFileEvent()
64 err = aeCreateFileEvent(loop_, fd, events, EventLoop::FileEventCallback, context); in AddFileEvent()
74 void EventLoop::RemoveFileEvent(int fd) { in RemoveFileEvent()
79 void EventLoop::Start() { aeMain(loop_); } in Start()
81 void EventLoop::Stop() { aeStop(loop_); } in Stop()
83 void EventLoop::Shutdown() { in Shutdown()
90 EventLoop::~EventLoop() { Shutdown(); } in ~EventLoop()
92 int64_t EventLoop::AddTimer(int64_t timeout, const TimerCallback& callback) { in AddTimer()
[all …]
|
| /dports/devel/cxxtools/cxxtools-2.2.1/src/ |
| H A D | eventloop.cpp | 34 EventLoop::EventLoop() in EventLoop() function in cxxtools::EventLoop
42 EventLoop::~EventLoop() in ~EventLoop()
60 void EventLoop::onAdd( Selectable& s ) in onAdd()
66 void EventLoop::onRemove( Selectable& s ) in onRemove()
72 void EventLoop::onReinit(Selectable& s) in onReinit()
77 void EventLoop::onChanged(Selectable& s) in onChanged()
83 void EventLoop::onRun() in onRun()
112 bool EventLoop::onWait(std::size_t msecs) in onWait()
131 void EventLoop::onWake() in onWake()
137 void EventLoop::onExit() in onExit()
[all …]
|
| /dports/net/bredbandskollen/bbk-7b810a6/src/framework/ |
| H A D | eventloop.cpp | 17 volatile int EventLoop::got_signal = 0;
21 EventLoop::interrupt(); in signalHandler()
49 EventLoop::interrupt(); in signalHandler()
90 void EventLoop::daemonize() { in daemonize()
172 EventLoop eventloop("Worker"); in createWorker()
200 EventLoop::~EventLoop() { in ~EventLoop()
207 void EventLoop::do_init(EventLoop *parent) {
210 void EventLoop::do_init() {
246 void EventLoop::addSignalHandler(int signum, void (*handler)(int, EventLoop &)) { argument
575 EventLoop loop(name, parent);
[all …]
|
| /dports/audio/musicpd/mpd-0.23.6/src/event/ |
| H A D | Loop.cxx | 36 EventLoop::EventLoop( in EventLoop() function in EventLoop
53 EventLoop::~EventLoop() noexcept in ~EventLoop()
74 EventLoop::GetUring() noexcept in GetUring()
92 EventLoop::Break() noexcept in Break()
169 EventLoop::HandleTimers() noexcept in HandleTimers()
183 EventLoop::AddDefer(DeferEvent &d) noexcept in AddDefer()
194 EventLoop::AddIdle(DeferEvent &e) noexcept in AddIdle()
201 EventLoop::RunDeferred() noexcept in RunDeferred()
211 EventLoop::RunOneIdle() noexcept in RunOneIdle()
267 EventLoop::Run() noexcept in Run()
[all …]
|
| H A D | Loop.hxx | 61 class EventLoop final class
154 explicit EventLoop(ThreadId _thread);
156 EventLoop():EventLoop(ThreadId::GetCurrent()) {} in EventLoop() function in EventLoop
158 EventLoop();
161 ~EventLoop() noexcept;
163 EventLoop(const EventLoop &other) = delete;
164 EventLoop &operator=(const EventLoop &other) = delete;
|
| /dports/www/squid/squid-4.15/src/ |
| H A D | EventLoop.cc | 19 EventLoop *EventLoop::Running = NULL;
21 EventLoop::EventLoop() : errcount(0), last_loop(false), timeService(NULL), in EventLoop() function in EventLoop
29 EventLoop::checkEngine(AsyncEngine * engine, bool const primary) in checkEngine()
63 EventLoop::prepareToRun() in prepareToRun()
70 EventLoop::registerEngine(AsyncEngine *engine) in registerEngine()
76 EventLoop::run() in run()
89 EventLoop::runOnce() in runOnce()
142 EventLoop::dispatchCalls() in dispatchCalls()
149 EventLoop::setPrimaryEngine(AsyncEngine * engine) in setPrimaryEngine()
162 EventLoop::setTimeService(TimeEngine *engine) in setTimeService()
[all …]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/dop251/goja_nodejs/eventloop/ |
| H A D | eventloop.go | 27 type EventLoop struct { struct
34 func NewEventLoop() *EventLoop {
37 loop := &EventLoop{
80 func (loop *EventLoop) Run(fn func(*goja.Runtime)) { argument
86 func (loop *EventLoop) Start() { argument
92 func (loop *EventLoop) Stop() { argument
113 func (loop *EventLoop) run(inBackground bool) { argument
150 func (loop *EventLoop) doTimeout(t *timer) { argument
158 func (loop *EventLoop) doInterval(i *interval) { argument
164 func (loop *EventLoop) clearTimeout(t *timer) { argument
[all …]
|
| /dports/mail/emailrelay/emailrelay-1.9/src/gnet/ |
| H A D | geventloop.cpp | 27 GNet::EventLoop * GNet::EventLoop::m_this = NULL ;
29 GNet::EventLoop::EventLoop() in EventLoop() function in GNet::EventLoop
37 GNet::EventLoop::~EventLoop() in ~EventLoop()
43 GNet::EventLoop & GNet::EventLoop::instance() in instance()
51 bool GNet::EventLoop::exists() in exists()
|
| /dports/audio/ncmpc/ncmpc-0.41/src/event/ |
| H A D | Loop.cxx | 43 EventLoop::EventLoop( in EventLoop() function in EventLoop
66 EventLoop::~EventLoop() noexcept in ~EventLoop()
75 EventLoop::GetUring() noexcept in GetUring()
93 EventLoop::Break() noexcept in Break()
104 EventLoop::AbandonFD(int _fd) noexcept in AbandonFD()
114 EventLoop::RemoveFD(int _fd) noexcept in RemoveFD()
124 EventLoop::AddIdle(IdleEvent &i) noexcept in AddIdle()
133 EventLoop::RemoveIdle(IdleEvent &i) noexcept in RemoveIdle()
151 EventLoop::HandleTimers() noexcept in HandleTimers()
204 EventLoop::Run() noexcept in Run()
[all …]
|
| /dports/mail/archiveopteryx/archiveopteryx-3.2.0/server/ |
| H A D | eventloop.cpp | 39 static EventLoop * loop;
68 if ( !EventLoop::global() || EventLoop::global()->inShutdown() ) in execute()
95 void EventLoop::setup( EventLoop * l ) in setup()
99 ::loop = new EventLoop; in setup()
106 EventLoop::EventLoop() in EventLoop() function in EventLoop
114 EventLoop::~EventLoop() in ~EventLoop()
195 void EventLoop::start() in start()
385 void EventLoop::freeMemory() in freeMemory()
600 void EventLoop::flushAll() in flushAll()
646 EventLoop * EventLoop::global() in global()
[all …]
|
| /dports/mail/archiveopteryx-devel/aox-96ab17e/server/ |
| H A D | eventloop.cpp | 39 static EventLoop * loop;
68 if ( !EventLoop::global() || EventLoop::global()->inShutdown() ) in execute()
95 void EventLoop::setup( EventLoop * l ) in setup()
99 ::loop = new EventLoop; in setup()
106 EventLoop::EventLoop() in EventLoop() function in EventLoop
114 EventLoop::~EventLoop() in ~EventLoop()
195 void EventLoop::start() in start()
385 void EventLoop::freeMemory() in freeMemory()
601 void EventLoop::flushAll() in flushAll()
647 EventLoop * EventLoop::global() in global()
[all …]
|
| /dports/multimedia/zoneminder/zoneminder-1.36.5/dep/RtspServer/src/net/ |
| H A D | EventLoop.cpp | 17 EventLoop::EventLoop(uint32_t num_threads) in EventLoop() function in EventLoop
28 EventLoop::~EventLoop() in ~EventLoop()
33 std::shared_ptr<TaskScheduler> EventLoop::GetTaskScheduler() in GetTaskScheduler()
51 void EventLoop::Loop() in Loop()
101 void EventLoop::Quit() in Quit()
117 void EventLoop::UpdateChannel(ChannelPtr channel) in UpdateChannel()
125 void EventLoop::RemoveChannel(ChannelPtr& channel) in RemoveChannel()
133 TimerId EventLoop::AddTimer(TimerEvent timerEvent, uint32_t msec) in AddTimer()
142 void EventLoop::RemoveTimer(TimerId timerId) in RemoveTimer()
150 bool EventLoop::AddTriggerEvent(TriggerEvent callback) in AddTriggerEvent()
|
| H A D | EventLoop.h | 30 class EventLoop
33 EventLoop(const EventLoop&) = delete;
34 EventLoop &operator = (const EventLoop&) = delete;
35 EventLoop(uint32_t num_threads =1); //std::thread::hardware_concurrency()
36 virtual ~EventLoop();
|
| /dports/audio/spectmorph/spectmorph-0.5.2/glui/ |
| H A D | smeventloop.cc | 11 EventLoop::wait_event_fps() in wait_event_fps()
23 EventLoop::process_events() in process_events()
56 EventLoop::level() const in level()
62 EventLoop::window_alive (Window *window) const in window_alive()
78 EventLoop::add_window (Window *window) in add_window()
84 EventLoop::remove_window (Window *window) in remove_window()
95 EventLoop::add_delete_later (Widget *widget) in add_delete_later()
101 EventLoop::on_widget_deleted (Widget *widget) in on_widget_deleted()
|
| /dports/games/abstreet/winit-a87ae2661263ff241e8868cbf3ce65aab205863a/src/ |
| H A D | event_loop.rs | 32 pub struct EventLoop<T: 'static> { struct
33 pub(crate) event_loop: platform_impl::EventLoop<T>, argument
48 impl<T> fmt::Debug for EventLoop<T> { implementation
96 impl EventLoop<()> { impl
114 pub fn new() -> EventLoop<()> { in new()
115 EventLoop::<()>::with_user_event() in new()
119 impl<T> EventLoop<T> { implementation
127 pub fn with_user_event() -> EventLoop<T> { in with_user_event()
128 EventLoop { in with_user_event()
129 event_loop: platform_impl::EventLoop::new(), in with_user_event()
[all …]
|
| /dports/x11/alacritty/alacritty-0.9.0/cargo-crates/winit-0.24.0/src/ |
| H A D | event_loop.rs | 32 pub struct EventLoop<T: 'static> { struct
33 pub(crate) event_loop: platform_impl::EventLoop<T>, argument
48 impl<T> fmt::Debug for EventLoop<T> { implementation
101 impl EventLoop<()> { implementation
119 pub fn new() -> EventLoop<()> { in new()
120 EventLoop::<()>::with_user_event() in new()
124 impl<T> EventLoop<T> { implementation
132 pub fn with_user_event() -> EventLoop<T> { in with_user_event()
133 EventLoop { in with_user_event()
134 event_loop: platform_impl::EventLoop::new(), in with_user_event()
[all …]
|
| /dports/devel/capnproto080/capnproto-0.8.0/c++/src/kj/ |
| H A D | async-test.c++ | 37 EventLoop loop; in TEST()
49 EventLoop loop; in TEST()
61 EventLoop loop; in TEST()
74 EventLoop loop; in TEST()
87 EventLoop loop; in TEST()
99 EventLoop loop; in TEST()
114 EventLoop loop; in TEST()
131 EventLoop loop; in TEST()
148 EventLoop loop; in TEST()
166 EventLoop loop; in TEST()
[all …]
|
| /dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/tests/src/unit/tests/ |
| H A D | test_event_loop.cpp | 32 virtual void run(EventLoop* event_loop) { event_loop_unit_test_->mark_task_completed(); } in run()
40 MarkIsRunningOn(EventLoopUnitTest* event_loop_unit_test, EventLoop* event_loop) in MarkIsRunningOn()
43 virtual void run(EventLoop* event_loop) { in run()
49 EventLoop* event_loop_;
54 virtual void run(EventLoop* event_loop) { event_loop->maybe_start_io_time(); } in run()
61 virtual void run(EventLoop* event_loop) { in run()
90 class TestEventLoop : public EventLoop {
109 EventLoop event_loop; in TEST_F()
123 EventLoop event_loop; in TEST_F()
137 EventLoop event_loop; in TEST_F()
[all …]
|