| /external/chromium_org/net/base/ |
| D | priority_queue_unittest.cc | 26 PriorityQueueTest() : queue_(kNumPriorities) {} in PriorityQueueTest()
31 EXPECT_EQ(i, queue_.size()); in SetUp()
32 pointers_[i] = queue_.Insert(static_cast<int>(i), kPriorities[i]); in SetUp()
33 EXPECT_FALSE(queue_.empty()); in SetUp()
35 EXPECT_EQ(kNumElements, queue_.size()); in SetUp()
39 EXPECT_TRUE(queue_.empty()); in CheckEmpty()
40 EXPECT_EQ(0u, queue_.size()); in CheckEmpty()
41 EXPECT_TRUE(queue_.FirstMin().is_null()); in CheckEmpty()
42 EXPECT_TRUE(queue_.LastMin().is_null()); in CheckEmpty()
43 EXPECT_TRUE(queue_.FirstMax().is_null()); in CheckEmpty()
[all …]
|
| D | prioritized_dispatcher.cc | 18 : queue_(limits.reserved_slots.size()), in PrioritizedDispatcher()
35 return queue_.Insert(job, priority); in Add()
47 return queue_.InsertAtFront(job, priority); in AddAtHead()
51 queue_.Erase(handle); in Cancel()
55 Handle handle = queue_.FirstMin(); in EvictOldestLowest()
76 queue_.Erase(handle); in ChangePriority()
77 return queue_.Insert(job, priority); in ChangePriority()
100 DCHECK_EQ(queue_.num_priorities(), limits.reserved_slots.size()); in SetLimits()
121 SetLimits(Limits(queue_.num_priorities(), 0)); in SetLimitsToZero()
130 queue_.Erase(handle); in MaybeDispatchJob()
[all …]
|
| /external/chromium_org/media/formats/common/ |
| D | offset_byte_queue_unittest.cc | 21 queue_.reset(new OffsetByteQueue); in SetUp()
22 queue_->Push(buf, sizeof(buf)); in SetUp()
23 queue_->Push(buf, sizeof(buf)); in SetUp()
24 queue_->Pop(384); in SetUp()
31 scoped_ptr<OffsetByteQueue> queue_; member in media::OffsetByteQueueTest
35 EXPECT_EQ(384, queue_->head()); in TEST_F()
36 EXPECT_EQ(512, queue_->tail()); in TEST_F()
41 queue_->Peek(&buf, &size); in TEST_F()
51 queue_->PeekAt(400, &buf, &size); in TEST_F()
52 EXPECT_EQ(queue_->tail() - 400, size); in TEST_F()
[all …]
|
| /external/chromium_org/chrome/browser/chromeos/drive/ |
| D | job_queue.cc | 17 queue_(num_priority_levels) { in JobQueue()
24 DCHECK_LT(accepted_priority, static_cast<int>(queue_.size())); in PopForRun()
32 if (!queue_[priority].empty()) { in PopForRun()
33 *id = queue_[priority].front(); in PopForRun()
34 queue_[priority].pop_front(); in PopForRun()
43 DCHECK_LT(priority, static_cast<int>(queue_.size())); in GetQueuedJobs()
45 jobs->assign(queue_[priority].begin(), queue_[priority].end()); in GetQueuedJobs()
49 DCHECK_LT(priority, static_cast<int>(queue_.size())); in Push()
51 queue_[priority].push_back(id); in Push()
61 for (size_t i = 0; i < queue_.size(); ++i) in ToString()
[all …]
|
| /external/chromium_org/sync/internal_api/attachments/ |
| D | task_queue_unittest.cc | 29 queue_.reset(new TaskQueue<int>( in TaskQueueTest()
43 scoped_ptr<TaskQueue<int> > queue_; member in syncer::TaskQueueTest
50 queue_->AddToQueue(1); in TEST_F()
51 queue_->AddToQueue(2); in TEST_F()
63 queue_->MarkAsSucceeded(1); in TEST_F()
69 queue_->MarkAsSucceeded(2); in TEST_F()
77 queue_->AddToQueue(1); in TEST_F()
78 queue_->AddToQueue(1); in TEST_F()
79 queue_->AddToQueue(2); in TEST_F()
80 queue_->AddToQueue(1); in TEST_F()
[all …]
|
| /external/chromium_org/base/mac/ |
| D | libdispatch_task_runner.cc | 13 : queue_(dispatch_queue_create(name, NULL)), in LibDispatchTaskRunner()
15 dispatch_set_context(queue_, this); in LibDispatchTaskRunner()
16 dispatch_set_finalizer_f(queue_, &LibDispatchTaskRunner::Finalizer); in LibDispatchTaskRunner()
23 if (!queue_) in PostDelayedTask()
38 dispatch_after(time, queue_, run_task); in PostDelayedTask()
40 dispatch_async(queue_, run_task); in PostDelayedTask()
46 return queue_ == dispatch_get_current_queue(); in RunsTasksOnCurrentThread()
57 dispatch_release(queue_); in Shutdown()
58 queue_ = NULL; in Shutdown()
63 return queue_; in GetDispatchQueue()
[all …]
|
| /external/chromium_org/mojo/public/cpp/bindings/lib/ |
| D | message_queue.cc | 17 while (!queue_.empty()) in ~MessageQueue()
22 return queue_.empty(); in IsEmpty()
26 MOJO_DCHECK(!queue_.empty()); in Peek()
27 return queue_.front(); in Peek()
31 queue_.push(new Message()); in Push()
32 queue_.back()->Swap(message); in Push()
36 MOJO_DCHECK(!queue_.empty()); in Pop()
37 queue_.front()->Swap(message); in Pop()
42 MOJO_DCHECK(!queue_.empty()); in Pop()
43 delete queue_.front(); in Pop()
[all …]
|
| /external/chromium_org/content/renderer/gpu/ |
| D | frame_swap_message_queue_unittest.cc | 17 queue_(new FrameSwapMessageQueue()) {} in FrameSwapMessageQueueTest()
21 queue_->QueueMessageForFrame( in QueueNextSwapMessage()
26 queue_->QueueMessageForFrame( in QueueNextSwapMessage()
32 queue_->QueueMessageForFrame(MESSAGE_DELIVERY_POLICY_WITH_VISUAL_STATE, in QueueVisualStateMessage()
41 queue_->QueueMessageForFrame(MESSAGE_DELIVERY_POLICY_WITH_VISUAL_STATE, in QueueVisualStateMessage()
50 queue_->DidSwap(source_frame_number); in DrainMessages()
52 queue_->AcquireSendMessageScope(); in DrainMessages()
53 queue_->DrainMessages(messages); in DrainMessages()
76 scoped_refptr<FrameSwapMessageQueue> queue_; member in content::FrameSwapMessageQueueTest
88 ASSERT_TRUE(queue_->Empty()); in TEST_F()
[all …]
|
| D | frame_swap_message_queue.cc | 50 for (VisualStateQueueMap::iterator i = queue_.begin(); i != queue_.end(); in ~VisualStateQueue()
56 virtual bool Empty() const OVERRIDE { return queue_.empty(); } in Empty()
62 *is_first = (queue_.count(source_frame_number) == 0); in QueueMessage()
64 queue_[source_frame_number].push_back(msg.release()); in QueueMessage()
69 VisualStateQueueMap::iterator end = queue_.upper_bound(source_frame_number); in DrainMessages()
70 for (VisualStateQueueMap::iterator i = queue_.begin(); i != end; i++) { in DrainMessages()
75 queue_.erase(queue_.begin(), end); in DrainMessages()
80 VisualStateQueueMap queue_; member in content::__anon5eab4d0e0111::VisualStateQueue
89 virtual bool Empty() const OVERRIDE { return queue_.empty(); } in Empty()
96 queue_.push_back(msg.release()); in QueueMessage()
[all …]
|
| /external/chromium_org/remoting/protocol/ |
| D | buffered_socket_writer.cc | 54 queue_.push_back(new PendingPacket(data, done_task)); in Write()
140 STLDeleteElements(&queue_); in HandleError()
151 return queue_.size(); in GetBufferChunks()
163 STLDeleteElements(&queue_); in ~BufferedSocketWriterBase()
167 base::Closure result = queue_.front()->done_task; in PopQueue()
168 delete queue_.front(); in PopQueue()
169 queue_.pop_front(); in PopQueue()
179 if (queue_.empty()) { in GetNextPacket()
183 current_buf_ = new net::DrainableIOBuffer(queue_.front()->data.get(), in GetNextPacket()
184 queue_.front()->data->size()); in GetNextPacket()
[all …]
|
| /external/chromium_org/net/spdy/ |
| D | spdy_read_queue.cc | 20 DCHECK_EQ(queue_.empty(), total_size_ == 0); in IsEmpty()
21 return queue_.empty(); in IsEmpty()
31 queue_.push_back(buffer.release()); in Enqueue()
37 while (!queue_.empty() && bytes_copied < len) { in Dequeue()
38 SpdyBuffer* buffer = queue_.front(); in Dequeue()
44 delete queue_.front(); in Dequeue()
45 queue_.pop_front(); in Dequeue()
55 STLDeleteElements(&queue_); in Clear()
56 queue_.clear(); in Clear()
|
| D | spdy_write_queue.cc | 39 if (!queue_[i].empty()) in IsEmpty()
54 queue_[priority].push_back( in Enqueue()
63 if (!queue_[i].empty()) { in Dequeue()
64 PendingWrite pending_write = queue_[i].front(); in Dequeue()
65 queue_[i].pop_front(); in Dequeue()
92 for (std::deque<PendingWrite>::const_iterator it = queue_[i].begin(); in RemovePendingWritesForStream()
93 it != queue_[i].end(); ++it) { in RemovePendingWritesForStream()
104 std::deque<PendingWrite>* queue = &queue_[priority]; in RemovePendingWritesForStream()
128 std::deque<PendingWrite>* queue = &queue_[i]; in RemovePendingWritesForStreamsAfter()
152 for (std::deque<PendingWrite>::iterator it = queue_[i].begin(); in Clear()
[all …]
|
| /external/chromium_org/mojo/system/ |
| D | message_in_transit_queue.h | 26 bool IsEmpty() const { return queue_.empty(); } in IsEmpty()
29 queue_.push_back(message.release()); in AddMessage()
33 MessageInTransit* rv = queue_.front(); in GetMessage()
34 queue_.pop_front(); in GetMessage()
38 MessageInTransit* PeekMessage() { return queue_.front(); } in PeekMessage()
41 delete queue_.front(); in DiscardMessage()
42 queue_.pop_front(); in DiscardMessage()
53 std::deque<MessageInTransit*> queue_;
|
| /external/chromium_org/chrome/browser/resources/chromeos/chromevox/closure/ |
| D | closure_preinit.js | 27 window.queue_ = [];
44 if (goog.global.queue_.length == 0)
47 var src = goog.global.queue_[0];
59 goog.global.queue_ = goog.global.queue_.slice(1);
79 goog.global.queue_ = goog.global.queue_.slice(1);
86 goog.global.queue_.push(src);
87 if (goog.global.queue_.length == 1) {
|
| /external/chromium_org/cc/resources/ |
| D | resource_update_controller.cc | 44 queue_(queue.Pass()), in ResourceUpdateController()
83 queue_->ClearUploadsToEvictedResources(); in DiscardUploadsToEvictedResources()
98 while (queue_->FullUploadSize()) in Finalize()
99 UpdateTexture(queue_->TakeFirstFullUpload()); in Finalize()
101 while (queue_->PartialUploadSize()) in Finalize()
102 UpdateTexture(queue_->TakeFirstPartialUpload()); in Finalize()
130 if (!queue_->FullUploadSize()) in UpdateMoreTexturesIfEnoughTimeRemaining()
153 queue_->FullUploadSize(), UpdateMoreTexturesSize()); in UpdateMoreTexturesNow()
158 while (queue_->FullUploadSize() && uploads--) in UpdateMoreTexturesNow()
159 UpdateTexture(queue_->TakeFirstFullUpload()); in UpdateMoreTexturesNow()
|
| /external/chromium_org/base/threading/ |
| D | thread_collision_warner_unittest.cc | 152 : queue_(queue) {} in TEST()
155 queue_.push(0); in TEST()
156 queue_.pop(); in TEST()
160 NonThreadSafeQueue& queue_; in TEST() member in TEST::QueueUser
210 : queue_(queue) {} in TEST()
213 queue_.push(0); in TEST()
214 queue_.pop(); in TEST()
218 NonThreadSafeQueue& queue_; in TEST() member in TEST::QueueUser
270 : queue_(queue), in TEST()
276 queue_.push(0); in TEST()
[all …]
|
| /external/openfst/src/include/fst/ |
| D | queue.h | 448 : QueueBase<S>(SCC_QUEUE), queue_(queue), scc_(scc), front_(0), in SccQueue()
453 (((*queue_)[front_] && (*queue_)[front_]->Empty()) in Head()
454 || (((*queue_)[front_] == 0) && in Head()
458 if ((*queue_)[front_]) in Head()
459 return (*queue_)[front_]->Head(); in Head()
468 if ((*queue_)[scc_[s]]) { in Enqueue()
469 (*queue_)[scc_[s]]->Enqueue(s); in Enqueue()
478 if ((*queue_)[front_]) in Dequeue()
479 (*queue_)[front_]->Dequeue(); in Dequeue()
485 if ((*queue_)[scc_[s]]) in Update()
[all …]
|
| /external/chromium_org/sandbox/mac/ |
| D | dispatch_source_mach.cc | 19 dispatch_release(queue_);
25 : queue_(queue),
27 port, 0, queue_)),
56 if (queue_) { in Cancel()
57 dispatch_release(queue_); in Cancel()
58 queue_ = NULL; in Cancel()
|
| /external/srec/tools/thirdparty/OpenFst/fst/lib/ |
| D | queue.h | 411 : QueueBase<S>(SCC_QUEUE), queue_(queue), scc_(scc), front_(0), in SccQueue()
416 (((*queue_)[front_] && (*queue_)[front_]->Empty()) in Head()
417 || (((*queue_)[front_] == 0) && in Head()
423 if ((*queue_)[front_]) in Head()
424 return (*queue_)[front_]->Head(); in Head()
433 if ((*queue_)[scc_[s]]) { in Enqueue()
434 (*queue_)[scc_[s]]->Enqueue(s); in Enqueue()
445 if ((*queue_)[front_]) in Dequeue()
446 (*queue_)[front_]->Dequeue(); in Dequeue()
452 if ((*queue_)[scc_[s]]) in Update()
[all …]
|
| /external/chromium_org/media/midi/ |
| D | midi_message_queue.cc | 38 queue_.insert(queue_.end(), data.begin(), data.end()); in Add()
42 queue_.insert(queue_.end(), data, data + length); in Add()
49 if (queue_.empty()) in Get()
52 const uint8 next = queue_.front(); in Get()
53 queue_.pop_front(); in Get()
|
| /external/chromium_org/third_party/webrtc/modules/desktop_capture/ |
| D | screen_capturer_x11.cc | 122 ScreenCaptureFrameQueue queue_; member in webrtc::__anon8d2474e70111::ScreenCapturerLinux
265 queue_.MoveToNextFrame(); in Capture()
282 if (!queue_.current_frame()) { in Capture()
285 queue_.ReplaceCurrentFrame(frame.release()); in Capture()
289 DesktopFrame* frame = queue_.current_frame(); in Capture()
385 DesktopFrame* frame = queue_.current_frame()->Share(); in CaptureScreen()
396 if (use_damage_ && queue_.previous_frame()) in CaptureScreen()
402 if (use_damage_ && queue_.previous_frame()) { in CaptureScreen()
435 if (queue_.previous_frame()) { in CaptureScreen()
439 DCHECK(queue_.previous_frame()->data()); in CaptureScreen()
[all …]
|
| /external/chromium_org/cc/layers/ |
| D | tiled_layer_unittest.cc | 99 queue_(make_scoped_ptr(new ResourceUpdateQueue)), in TiledLayerTest()
162 DCHECK(queue_); in UpdateTextures()
166 queue_.Pass(), in UpdateTextures()
169 queue_ = make_scoped_ptr(new ResourceUpdateQueue); in UpdateTextures()
182 layer->Update(queue_.get(), occluded); in LayerUpdate()
227 layer1->Update(queue_.get(), occlusion_); in UpdateAndPush()
229 layer2->Update(queue_.get(), occlusion_); in UpdateAndPush()
254 scoped_ptr<ResourceUpdateQueue> queue_; member in cc::__anond5d03a570111::TiledLayerTest
725 layer->Update(queue_.get(), NULL); in TEST_F()
913 layer->Update(queue_.get(), NULL); in TEST_F()
[all …]
|
| /external/chromium_org/net/websockets/ |
| D | websocket_throttle.cc | 33 DCHECK(queue_.empty()); in ~WebSocketThrottle()
43 if (queue_.size() >= kMaxWebSocketJobsThrottled) in PutInQueue()
46 queue_.push_back(job); in PutInQueue()
75 std::find(queue_.begin(), queue_.end(), job); in RemoveFromQueue()
76 if (queue_iter == queue_.end()) in RemoveFromQueue()
78 queue_.erase(queue_iter); in RemoveFromQueue()
|
| /external/chromium_org/media/base/ |
| D | decoder_buffer_queue.cc | 24 queue_.push_back(buffer); in Push()
55 scoped_refptr<DecoderBuffer> buffer = queue_.front(); in Pop()
56 queue_.pop_front(); in Pop()
72 queue_.clear(); in Clear()
79 return queue_.empty(); in IsEmpty()
|
| /external/chromium_org/third_party/webrtc/modules/desktop_capture/win/ |
| D | screen_capturer_win_gdi.cc | 77 queue_.MoveToNextFrame(); in Capture()
96 const DesktopFrame* current_frame = queue_.current_frame(); in Capture()
97 const DesktopFrame* last_frame = queue_.previous_frame(); in Capture()
125 DesktopFrame* frame = queue_.current_frame()->Share(); in Capture()
232 queue_.Reset(); in PrepareCaptureResources()
248 if (!queue_.current_frame() || in CaptureImage()
249 !queue_.current_frame()->size().equals(screen_rect.size())) { in CaptureImage()
260 queue_.ReplaceCurrentFrame(buffer.release()); in CaptureImage()
266 queue_.current_frame()->GetUnderlyingFrame()); in CaptureImage()
|