Searched refs:m_queue (Results 1 – 7 of 7) sorted by relevance
65 Deque<DataType> m_queue; variable73 m_queue.append(message); in append()81 m_queue.prepend(message); in prepend()90 while (!m_killed && m_queue.isEmpty()) in waitForMessage()96 ASSERT(!m_queue.isEmpty()); in waitForMessage()97 result = m_queue.first(); in waitForMessage()98 m_queue.removeFirst(); in waitForMessage()108 while (!m_killed && !timedOut && m_queue.isEmpty()) in waitForMessageTimed()117 ASSERT(!m_queue.isEmpty()); in waitForMessageTimed()118 result = m_queue.first(); in waitForMessageTimed()[all …]
72 if (!m_queue.waitForMessage(task)) in localStorageThread()90 ASSERT(!m_queue.killed() && m_threadID); in scheduleImport()91 m_queue.append(LocalStorageTask::createImport(storage)); in scheduleImport()96 ASSERT(!m_queue.killed() && m_threadID); in scheduleSync()97 m_queue.append(LocalStorageTask::createSync(storage)); in scheduleSync()102 ASSERT(!m_queue.killed() && m_threadID); in scheduleImport()103 m_queue.append(LocalStorageTask::createImport(area)); in scheduleImport()108 ASSERT(!m_queue.killed() && m_threadID); in scheduleSync()109 m_queue.append(LocalStorageTask::createSync(area)); in scheduleSync()118 ASSERT(!m_queue.killed() && m_threadID); in terminate()[all …]
65 m_queue.kill(); in requestTermination()70 return m_queue.killed(); in terminationRequested()90 if (!m_queue.waitForMessage(task)) in databaseThread()111 m_queue.append(task); in scheduleTask()116 m_queue.prepend(task); in scheduleImmediateTask()126 while (m_queue.tryGetMessage(task)) { in unscheduleDatabaseTasks()132 m_queue.append(filteredReverseQueue.first()); in unscheduleDatabaseTasks()
68 MessageQueue<RefPtr<DatabaseTask> > m_queue; variable
66 MessageQueue<RefPtr<LocalStorageTask> > m_queue; variable
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
103 m_queue = new LinkedList (); in process()106 for (m_queue.add (m_view.getRoot ()); ! m_queue.isEmpty (); ) in process()108 final IItem head = (IItem) m_queue.removeFirst (); in process()126 m_queue = null; in cleanup()302 if (deeper) m_queue.addLast (pkg); in visit()419 if (deeper) m_queue.addLast (srcORcls); in visit()1482 private LinkedList /* IITem */ m_queue; local