Lines Matching defs:dispatchSource
146 GRefPtr<GSource> dispatchSource = adoptGRef(g_socket_create_source(socket.get(), static_cast<GIOCondition>(condition), cancellable.get()));
147 ASSERT(dispatchSource);
151 g_source_set_callback(dispatchSource.get(), reinterpret_cast<GSourceFunc>(&WorkQueue::EventSource::performWork),
166 g_source_attach(dispatchSource.get(), m_eventContext);
188 void WorkQueue::scheduleWorkOnSource(GSource* dispatchSource, PassOwnPtr<WorkItem> item, GSourceFunc sourceCallback)
192 g_source_set_callback(dispatchSource, sourceCallback, eventSource,
195 g_source_attach(dispatchSource, m_eventContext);
200 GRefPtr<GSource> dispatchSource = adoptGRef(g_idle_source_new());
201 ASSERT(dispatchSource);
202 g_source_set_priority(dispatchSource.get(), G_PRIORITY_DEFAULT);
204 scheduleWorkOnSource(dispatchSource.get(), item, reinterpret_cast<GSourceFunc>(&WorkQueue::EventSource::performWorkOnce));
209 GRefPtr<GSource> dispatchSource = adoptGRef(g_timeout_source_new(static_cast<guint>(delay * 1000)));
210 ASSERT(dispatchSource);
212 scheduleWorkOnSource(dispatchSource.get(), item, reinterpret_cast<GSourceFunc>(&WorkQueue::EventSource::performWorkOnce));
217 GRefPtr<GSource> dispatchSource = adoptGRef(g_child_watch_source_new(process));
218 ASSERT(dispatchSource);
220 scheduleWorkOnSource(dispatchSource.get(), item, reinterpret_cast<GSourceFunc>(&WorkQueue::EventSource::performWorkOnTermination));