Lines Matching defs:eventSource
37 // WorkQueue::EventSource
38 class WorkQueue::EventSource {
40 EventSource(PassOwnPtr<WorkItem> workItem, WorkQueue* workQueue, GCancellable* cancellable)
54 static void executeEventSource(EventSource* eventSource)
56 ASSERT(eventSource);
57 WorkQueue* queue = eventSource->m_workQueue;
64 eventSource->m_workItem->execute();
67 static gboolean performWorkOnce(EventSource* eventSource)
69 executeEventSource(eventSource);
73 static gboolean performWork(GSocket* socket, GIOCondition condition, EventSource* eventSource)
76 // EventSource has been cancelled, return FALSE to destroy the source.
80 executeEventSource(eventSource);
84 static gboolean performWorkOnTermination(GPid, gint, EventSource* eventSource)
86 executeEventSource(eventSource);
90 static void deleteEventSource(EventSource* eventSource)
92 ASSERT(eventSource);
93 delete eventSource;
148 EventSource* eventSource = new EventSource(item, this, cancellable.get());
149 ASSERT(eventSource);
151 g_source_set_callback(dispatchSource.get(), reinterpret_cast<GSourceFunc>(&WorkQueue::EventSource::performWork),
152 eventSource, reinterpret_cast<GDestroyNotify>(&WorkQueue::EventSource::deleteEventSource));
157 Vector<EventSource*> sources;
162 sources.append(eventSource);
180 Vector<EventSource*> sources = it->second;
190 EventSource* eventSource = new EventSource(item, this, 0);
192 g_source_set_callback(dispatchSource, sourceCallback, eventSource,
193 reinterpret_cast<GDestroyNotify>(&WorkQueue::EventSource::deleteEventSource));
204 scheduleWorkOnSource(dispatchSource.get(), item, reinterpret_cast<GSourceFunc>(&WorkQueue::EventSource::performWorkOnce));
212 scheduleWorkOnSource(dispatchSource.get(), item, reinterpret_cast<GSourceFunc>(&WorkQueue::EventSource::performWorkOnce));
220 scheduleWorkOnSource(dispatchSource.get(), item, reinterpret_cast<GSourceFunc>(&WorkQueue::EventSource::performWorkOnTermination));
