| /external/webkit/Source/WebCore/storage/wince/ |
| D | DatabaseThreadWinCE.cpp | 43 m_queue.clear(); in requestTermination()
48 return m_queue.isEmpty(); in terminationRequested()
53 if (!m_queue.isEmpty()) { in timerFired()
54 RefPtr<DatabaseTask> task = m_queue.first(); in timerFired()
56 m_queue.removeFirst(); in timerFired()
57 if (!m_queue.isEmpty()) in timerFired()
64 m_queue.append(task); in scheduleTask()
77 … for (Deque<RefPtr<DatabaseTask> >::const_iterator i = m_queue.begin(); i != m_queue.end(); ++i) { in unscheduleDatabaseTasks()
82 m_queue.swap(reservedTasks); in unscheduleDatabaseTasks()
|
| D | LocalStorageThreadWinCE.cpp | 48 if (!m_queue.isEmpty()) { in timerFired()
49 RefPtr<LocalStorageTask> task = m_queue.first(); in timerFired()
51 m_queue.removeFirst(); in timerFired()
52 if (!m_queue.isEmpty()) in timerFired()
59 m_queue.append(LocalStorageTask::createImport(area)); in scheduleImport()
66 m_queue.append(LocalStorageTask::createSync(area)); in scheduleSync()
73 m_queue.clear(); in terminate()
79 m_queue.clear(); in performTerminate()
|
| D | LocalStorageThreadWinCE.h | 52 Deque<RefPtr<LocalStorageTask> > m_queue; variable
|
| D | DatabaseThreadWinCE.h | 59 Deque<RefPtr<DatabaseTask> > m_queue; variable
|
| /external/webkit/Source/JavaScriptCore/wtf/ |
| D | MessageQueue.h | 82 Deque<DataType*> m_queue; variable
89 deleteAllValues(m_queue); in ~MessageQueue()
96 m_queue.append(message.leakPtr()); in append()
105 bool wasEmpty = m_queue.isEmpty(); in appendAndCheckEmpty()
106 m_queue.append(message.leakPtr()); in appendAndCheckEmpty()
115 m_queue.prepend(message.leakPtr()); in prepend()
135 DequeConstIterator<DataType*> found = m_queue.end(); in waitForMessageFilteredWithTimeout()
136 while (!m_killed && !timedOut && (found = m_queue.findIf(predicate)) == m_queue.end()) in waitForMessageFilteredWithTimeout()
151 ASSERT(found != m_queue.end()); in waitForMessageFilteredWithTimeout()
153 m_queue.remove(found); in waitForMessageFilteredWithTimeout()
[all …]
|
| /external/webkit/Source/WebCore/storage/ |
| D | LocalStorageThread.cpp | 68 while (OwnPtr<LocalStorageTask> task = m_queue.waitForMessage()) in threadEntryPoint()
77 ASSERT(!m_queue.killed() && m_threadID); in scheduleTask()
78 m_queue.append(task); in scheduleTask()
84 ASSERT(!m_queue.killed() && m_threadID); in terminate()
90 m_queue.append(LocalStorageTask::createTerminate(this)); in terminate()
92 ASSERT(m_queue.killed()); in terminate()
99 m_queue.kill(); in performTerminate()
|
| D | DatabaseThread.cpp | 76 m_queue.kill(); in requestTermination()
88 return m_queue.killed(); in terminationRequested()
106 while (OwnPtr<DatabaseTask> task = m_queue.waitForMessage()) { in databaseThread()
153 ASSERT(m_queue.killed() || m_openDatabaseSet.contains(database)); in recordDatabaseClosed()
160 m_queue.append(task); in scheduleTask()
166 m_queue.prepend(task); in scheduleImmediateTask()
182 m_queue.removeIf(predicate); in unscheduleDatabaseTasks()
|
| D | LocalStorageThread.h | 64 MessageQueue<LocalStorageTask> m_queue; variable
|
| D | DatabaseThread.h | 81 MessageQueue<DatabaseTask> m_queue; variable
|
| /external/webkit/Source/WebCore/fileapi/ |
| D | FileThread.cpp | 50 ASSERT(m_queue.killed()); in ~FileThread()
64 m_queue.kill(); in stop()
69 m_queue.append(task); in postTask()
83 m_queue.removeIf(predicate); in unscheduleTasks()
102 while (OwnPtr<Task> task = m_queue.waitForMessage()) { in runLoop()
|
| D | FileThread.h | 80 MessageQueue<Task> m_queue; variable
|
| /external/webkit/Source/WebCore/platform/network/qt/ |
| D | QNetworkReplyHandler.cpp | 202 QueueLocker(QNetworkReplyHandlerCallQueue* queue) : m_queue(queue) { m_queue->lock(); } in QueueLocker()
203 ~QueueLocker() { m_queue->unlock(); } in ~QueueLocker()
205 QNetworkReplyHandlerCallQueue* m_queue; member in WebCore::QueueLocker
211 , m_queue(queue) in QNetworkReplyWrapper()
226 m_queue->clear(); in ~QNetworkReplyWrapper()
262 QueueLocker lock(m_queue); in receiveMetaData()
263 m_queue->push(&QNetworkReplyHandler::sendResponseIfNeeded); in receiveMetaData()
264 m_queue->push(&QNetworkReplyHandler::finish); in receiveMetaData()
299 QueueLocker lock(m_queue); in emitMetaDataChanged()
300 m_queue->push(&QNetworkReplyHandler::sendResponseIfNeeded); in emitMetaDataChanged()
[all …]
|
| D | QNetworkReplyHandler.h | 97 QNetworkReplyHandlerCallQueue* m_queue; variable
117 void setLoadingDeferred(bool deferred) { m_queue.setDeferSignals(deferred); } in setLoadingDeferred()
148 QNetworkReplyHandlerCallQueue m_queue; variable
|
| /external/webkit/Source/WebCore/dom/default/ |
| D | PlatformMessagePortChannel.h | 68 return m_queue.tryGetMessage(); in tryGetMessage()
73 return m_queue.appendAndCheckEmpty(message); in appendAndCheckEmpty()
78 return m_queue.isEmpty(); in isEmpty()
84 MessageQueue<MessagePortChannel::EventData> m_queue; variable
|
| /external/webkit/Source/WebCore/platform/graphics/chromium/cc/ |
| D | CCThread.cpp | 46 m_queue.kill(); in ~CCThread()
56 m_queue.append(task); in postTask()
73 while (OwnPtr<Task> task = m_queue.waitForMessage()) in runLoop()
|
| D | CCThread.h | 68 MessageQueue<Task> m_queue; variable
|
| /external/emma/core/java12/com/vladium/emma/report/lcov/ |
| D | ReportGenerator.java | 78 m_queue = new LinkedList(); in process()
79 for (m_queue.add(m_view.getRoot()); !m_queue.isEmpty(); ) in process()
81 final IItem head = (IItem) m_queue.removeFirst(); in process()
96 m_queue = null; in cleanup()
127 m_queue.addLast(pkg); in visit()
153 m_queue.addLast(srcORcls); in visit()
406 private LinkedList /* IITem */ m_queue; field in ReportGenerator
|
| /external/webkit/Source/WebKit2/Platform/qt/ |
| D | WorkQueueQt.cpp | 41 : m_queue(workQueue) in WorkItemQt()
49 : m_queue(workQueue) in WorkItemQt()
64 if (m_queue->m_isValid) in execute()
74 WorkQueue* m_queue; member in WorkQueue::WorkItemQt
|
| /external/emma/core/java12/com/vladium/emma/report/txt/ |
| D | ReportGenerator.java | 72 m_queue = new LinkedList (); in process()
73 for (m_queue.add (m_view.getRoot ()); ! m_queue.isEmpty (); ) in process()
75 final IItem head = (IItem) m_queue.removeFirst (); in process()
94 m_queue = null; in cleanup()
191 if (deeper) m_queue.addLast (pkg); in visit()
240 if (deeper) m_queue.addLast (srcORcls); in visit()
519 private LinkedList /* IITem */ m_queue; field in ReportGenerator
|
| /external/webkit/Source/WebKit/android/WebCoreSupport/ |
| D | WebUrlLoaderClient.cpp | 194 while (!m_queue.empty()) { in start()
195 OwnPtr<Task> task(m_queue.front()); in start()
196 m_queue.pop_front(); in start()
202 if (m_queue.empty()) { in start()
352 if (m_queue.empty()) { in maybeCallOnMainThread()
355 m_queue.push_back(task); in maybeCallOnMainThread()
|
| /external/webkit/Source/WebKit/android/smoke/ |
| D | MessageThread.h | 87 MessageQueue& queue() { return m_queue; } in queue()
94 MessageQueue m_queue; variable
|
| /external/webkit/Source/WebCore/page/ |
| D | GeolocationPositionCache.cpp | 123 while (OwnPtr<ScriptExecutionContext::Task> task = m_queue.waitForMessage()) { in threadEntryPointImpl()
131 m_queue.append(createCallbackTask(&GeolocationPositionCache::readFromDatabase, this)); in triggerReadFromDatabase()
190 m_queue.append(createCallbackTask(writeToDatabase, this)); in triggerWriteToDatabase()
|
| D | GeolocationPositionCache.h | 73 MessageQueue<ScriptExecutionContext::Task> m_queue; variable
|
| /external/webkit/Source/WebCore/platform/graphics/android/rendering/ |
| D | TilesManager.cpp | 97 , m_queue(0) in TilesManager()
439 if (!m_queue) in transferQueue()
440 m_queue = new TransferQueue(m_useMinimalMemory); in transferQueue()
441 return m_queue; in transferQueue()
|
| /external/webkit/Source/WebKit2/Platform/ |
| D | WorkQueue.h | 118 WorkQueue* queue() const { return m_queue; } in queue()
125 WorkQueue* m_queue; variable
|