| /external/chromium_org/net/base/ |
| priority_queue_unittest.cc | 26 PriorityQueueTest() : queue_(kNumPriorities) {}
31 EXPECT_EQ(i, queue_.size());
32 pointers_[i] = queue_.Insert(static_cast<int>(i), kPriorities[i]);
33 EXPECT_FALSE(queue_.empty());
35 EXPECT_EQ(kNumElements, queue_.size());
39 EXPECT_TRUE(queue_.empty());
40 EXPECT_EQ(0u, queue_.size());
41 EXPECT_TRUE(queue_.FirstMin().is_null());
42 EXPECT_TRUE(queue_.LastMin().is_null());
43 EXPECT_TRUE(queue_.FirstMax().is_null())
47 PriorityQueue<int> queue_; member in class:net::__anon8915::PriorityQueueTest
[all...] |
| prioritized_dispatcher.cc | 18 : queue_(limits.reserved_slots.size()),
35 return queue_.Insert(job, priority);
47 return queue_.InsertAtFront(job, priority);
51 queue_.Erase(handle);
55 Handle handle = queue_.FirstMin();
76 queue_.Erase(handle);
77 return queue_.Insert(job, priority);
100 DCHECK_EQ(queue_.num_priorities(), limits.reserved_slots.size());
121 SetLimits(Limits(queue_.num_priorities(), 0));
130 queue_.Erase(handle)
[all...] |
| /external/chromium_org/mojo/public/bindings/lib/ |
| message_queue.cc | 18 while (!queue_.empty())
23 return queue_.empty();
27 assert(!queue_.empty());
28 return queue_.front();
32 queue_.push(new Message());
33 queue_.back()->Swap(message);
37 assert(!queue_.empty());
38 queue_.front()->Swap(message);
43 assert(!queue_.empty());
44 delete queue_.front()
[all...] |
| /external/chromium_org/media/mp4/ |
| offset_byte_queue_unittest.cc | 21 queue_.reset(new OffsetByteQueue);
22 queue_->Push(buf, sizeof(buf));
23 queue_->Push(buf, sizeof(buf));
24 queue_->Pop(384);
31 scoped_ptr<OffsetByteQueue> queue_; member in class:media::OffsetByteQueueTest
35 EXPECT_EQ(384, queue_->head());
36 EXPECT_EQ(512, queue_->tail());
41 queue_->Peek(&buf, &size);
51 queue_->PeekAt(400, &buf, &size);
52 EXPECT_EQ(queue_->tail() - 400, size)
[all...] |
| offset_byte_queue.cc | 16 queue_.Reset();
23 queue_.Push(buf, size);
34 queue_.Pop(count);
61 queue_.Peek(&buf_, &size_);
|
| /external/chromium_org/base/mac/ |
| libdispatch_task_runner.cc | 13 : queue_(dispatch_queue_create(name, NULL)),
15 dispatch_set_context(queue_, this);
16 dispatch_set_finalizer_f(queue_, &LibDispatchTaskRunner::Finalizer);
23 if (!queue_)
38 dispatch_after(time, queue_, run_task);
40 dispatch_async(queue_, run_task);
46 return queue_ == dispatch_get_current_queue();
57 dispatch_release(queue_);
58 queue_ = NULL;
63 return queue_;
[all...] |
| /external/chromium_org/chrome/browser/chromeos/drive/ |
| job_queue.cc | 17 queue_(num_priority_levels) {
24 DCHECK_LT(accepted_priority, static_cast<int>(queue_.size()));
32 if (!queue_[priority].empty()) {
33 *id = queue_[priority].front();
34 queue_[priority].pop_front();
43 DCHECK_LT(priority, static_cast<int>(queue_.size()));
45 jobs->assign(queue_[priority].begin(), queue_[priority].end());
49 DCHECK_LT(priority, static_cast<int>(queue_.size()));
51 queue_[priority].push_back(id)
[all...] |
| /external/chromium_org/net/spdy/ |
| spdy_read_queue.cc | 20 DCHECK_EQ(queue_.empty(), total_size_ == 0);
21 return queue_.empty();
31 queue_.push_back(buffer.release());
37 while (!queue_.empty() && bytes_copied < len) {
38 SpdyBuffer* buffer = queue_.front();
44 delete queue_.front();
45 queue_.pop_front();
55 STLDeleteElements(&queue_);
56 queue_.clear();
|
| spdy_write_queue.cc | 37 if (!queue_[i].empty())
51 queue_[priority].push_back(
59 if (!queue_[i].empty()) {
60 PendingWrite pending_write = queue_[i].front();
61 queue_[i].pop_front();
86 for (std::deque<PendingWrite>::const_iterator it = queue_[i].begin();
87 it != queue_[i].end(); ++it) {
94 std::deque<PendingWrite>* queue = &queue_[priority];
112 std::deque<PendingWrite>* queue = &queue_[i];
130 for (std::deque<PendingWrite>::iterator it = queue_[i].begin()
[all...] |
| /external/chromium/base/ |
| task_queue.cc | 14 // We own all the pointes in |queue_|. It is our job to delete them.
15 STLDeleteElements(&queue_);
22 queue_.push_back(task);
27 STLDeleteElements(&queue_);
31 return queue_.empty();
36 if (queue_.empty())
40 queue_.swap(ready);
|
| /external/chromium_org/chrome/browser/sync_file_system/drive_backend_v1/ |
| origin_operation_queue.cc | 22 queue_.push_back(OriginOperation(origin, type));
26 DCHECK(!queue_.empty());
27 OriginOperation operation = queue_.front();
28 queue_.pop_front();
33 if (queue_.empty())
36 for (std::deque<OriginOperation>::const_iterator iter = queue_.begin();
37 iter != queue_.end(); ++iter) {
|
| origin_operation_queue.h | 42 size_t size() const { return queue_.size(); }
43 bool empty() const { return queue_.empty(); }
46 std::deque<OriginOperation> queue_; member in class:sync_file_system::OriginOperationQueue
|
| /external/chromium_org/cc/resources/ |
| resource_update_controller.cc | 44 queue_(queue.Pass()),
82 queue_->ClearUploadsToEvictedResources();
97 while (queue_->FullUploadSize())
98 UpdateTexture(queue_->TakeFirstFullUpload());
100 while (queue_->PartialUploadSize())
101 UpdateTexture(queue_->TakeFirstPartialUpload());
127 if (!queue_->FullUploadSize())
150 queue_->FullUploadSize(), UpdateMoreTexturesSize());
155 while (queue_->FullUploadSize() && uploads--)
156 UpdateTexture(queue_->TakeFirstFullUpload())
[all...] |
| /external/chromium_org/media/base/ |
| decoder_buffer_queue.cc | 22 queue_.push_back(buffer);
49 scoped_refptr<DecoderBuffer> buffer = queue_.front();
50 queue_.pop_front();
61 queue_.clear();
67 return queue_.empty();
|
| /external/chromium_org/remoting/protocol/ |
| buffered_socket_writer.cc | 54 queue_.push_back(new PendingPacket(data, done_task));
140 STLDeleteElements(&queue_);
151 return queue_.size();
163 STLDeleteElements(&queue_);
167 base::Closure result = queue_.front()->done_task;
168 delete queue_.front();
169 queue_.pop_front();
179 if (queue_.empty()) {
183 current_buf_ = new net::DrainableIOBuffer(queue_.front()->data.get(),
184 queue_.front()->data->size())
[all...] |
| /external/chromium_org/chrome/third_party/chromevox/closure/ |
| closure_preinit.js | 38 window.queue_ = [];
55 if (goog.global.queue_.length == 0)
58 var src = goog.global.queue_[0];
70 goog.global.queue_ = goog.global.queue_.slice(1);
90 goog.global.queue_ = goog.global.queue_.slice(1);
97 goog.global.queue_.push(src);
98 if (goog.global.queue_.length == 1) {
|
| /external/chromium_org/remoting/host/ |
| screen_capturer_fake.cc | 50 queue_.MoveToNextFrame();
52 if (!queue_.current_frame()) {
64 queue_.ReplaceCurrentFrame(frame.release());
67 DCHECK(queue_.current_frame());
70 queue_.current_frame()->mutable_updated_region()->SetRect(
72 queue_.current_frame()->set_capture_time_ms(
75 callback_->OnCaptureCompleted(queue_.current_frame()->Share());
86 webrtc::DesktopFrame* frame = queue_.current_frame();
124 queue_.Reset();
|
| /external/chromium/base/threading/ |
| thread_collision_warner_unittest.cc | 152 : queue_(queue) {}
155 queue_.push(0);
156 queue_.pop();
160 NonThreadSafeQueue& queue_; member in class:QueueUser
210 : queue_(queue) {}
213 queue_.push(0);
214 queue_.pop();
218 NonThreadSafeQueue& queue_; member in class:QueueUser
270 : queue_(queue),
276 queue_.push(0)
284 NonThreadSafeQueue& queue_; member in class:QueueUser
362 NonThreadSafeQueue& queue_; member in class:QueueUser
[all...] |
| /external/chromium_org/base/threading/ |
| thread_collision_warner_unittest.cc | 152 : queue_(queue) {}
155 queue_.push(0);
156 queue_.pop();
160 NonThreadSafeQueue& queue_; member in class:QueueUser
210 : queue_(queue) {}
213 queue_.push(0);
214 queue_.pop();
218 NonThreadSafeQueue& queue_; member in class:QueueUser
270 : queue_(queue),
276 queue_.push(0)
284 NonThreadSafeQueue& queue_; member in class:QueueUser
362 NonThreadSafeQueue& queue_; member in class:QueueUser
[all...] |
| /external/chromium/net/websockets/ |
| websocket_throttle.h | 34 // Puts |job| in |queue_| and queues for the destination addresses
39 // Removes |job| from |queue_| and queues for the destination addresses
43 // Checks sockets waiting in |queue_| and check the socket is the front of
61 ConnectingQueue queue_; member in class:net::WebSocketThrottle
|
| /external/chromium_org/media/midi/ |
| midi_message_queue.cc | 38 queue_.insert(queue_.end(), data.begin(), data.end());
42 queue_.insert(queue_.end(), data, data + length);
49 if (queue_.empty())
52 const uint8 next = queue_.front();
53 queue_.pop_front();
|
| /external/chromium_org/net/websockets/ |
| websocket_throttle.cc | 33 DCHECK(queue_.empty());
43 if (queue_.size() >= kMaxWebSocketJobsThrottled)
46 queue_.push_back(job);
75 std::find(queue_.begin(), queue_.end(), job);
76 if (queue_iter == queue_.end())
78 queue_.erase(queue_iter);
|
| /external/chromium_org/chrome/browser/printing/ |
| print_job_manager.cc | 75 if (!queue_)
76 queue_ = new PrintQueriesQueue();
77 return queue_;
86 if (queue_)
87 queue_->Shutdown();
88 queue_ = NULL;
|
| /external/openfst/src/include/fst/ |
| queue.h | 448 : QueueBase<S>(SCC_QUEUE), queue_(queue), scc_(scc), front_(0),
453 (((*queue_)[front_] && (*queue_)[front_]->Empty())
454 || (((*queue_)[front_] == 0) &&
458 if ((*queue_)[front_])
459 return (*queue_)[front_]->Head();
468 if ((*queue_)[scc_[s]]) {
469 (*queue_)[scc_[s]]->Enqueue(s);
478 if ((*queue_)[front_])
479 (*queue_)[front_]->Dequeue()
512 vector<Queue*> *queue_; member in class:fst::SccQueue
648 QueueBase<StateId> *queue_; member in class:fst::AutoQueue
858 Q *queue_; member in class:fst::PruneQueue
930 Q *queue_; member in class:fst::FilterQueue
[all...] |
| /external/srec/tools/thirdparty/OpenFst/fst/lib/ |
| queue.h | 411 : QueueBase<S>(SCC_QUEUE), queue_(queue), scc_(scc), front_(0),
416 (((*queue_)[front_] && (*queue_)[front_]->Empty())
417 || (((*queue_)[front_] == 0) &&
423 if ((*queue_)[front_])
424 return (*queue_)[front_]->Head();
433 if ((*queue_)[scc_[s]]) {
434 (*queue_)[scc_[s]]->Enqueue(s);
445 if ((*queue_)[front_])
446 (*queue_)[front_]->Dequeue()
479 vector<Queue*> *queue_; member in class:fst::SccQueue
611 QueueBase<StateId> *queue_; member in class:fst::AutoQueue
[all...] |
