Searched refs:m_queue (Results 1 – 13 of 13) sorted by relevance
81 Deque<DataType*> m_queue; variable88 deleteAllValues(m_queue); in ~MessageQueue()95 m_queue.append(message.release()); in append()104 bool wasEmpty = m_queue.isEmpty(); in appendAndCheckEmpty()105 m_queue.append(message.release()); in appendAndCheckEmpty()114 m_queue.prepend(message.release()); in prepend()134 DequeConstIterator<DataType*> found = m_queue.end(); in waitForMessageFilteredWithTimeout()135 while (!m_killed && !timedOut && (found = m_queue.findIf(predicate)) == m_queue.end()) in waitForMessageFilteredWithTimeout()150 ASSERT(found != m_queue.end()); in waitForMessageFilteredWithTimeout()152 m_queue.remove(found); in waitForMessageFilteredWithTimeout()[all …]
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()
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()
52 Deque<RefPtr<LocalStorageTask> > m_queue; variable
59 Deque<RefPtr<DatabaseTask> > m_queue; variable
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()
75 m_queue.kill(); in requestTermination()80 return m_queue.killed(); in terminationRequested()98 while (OwnPtr<DatabaseTask> task = m_queue.waitForMessage()) { in databaseThread()145 ASSERT(m_queue.killed() || m_openDatabaseSet.contains(database)); in recordDatabaseClosed()151 m_queue.append(task); in scheduleTask()156 m_queue.prepend(task); in scheduleImmediateTask()172 m_queue.removeIf(predicate); in unscheduleDatabaseTasks()
63 MessageQueue<LocalStorageTask> m_queue; variable
81 MessageQueue<DatabaseTask> m_queue; variable
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
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
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