/external/chromium_org/media/formats/common/ |
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/mojo/system/ |
message_in_transit_queue.h | 33 return queue_.empty(); 37 queue_.push_back(message.release()); 41 MessageInTransit* rv = queue_.front(); 42 queue_.pop_front(); 47 return queue_.front(); 51 delete queue_.front(); 52 queue_.pop_front(); 60 std::deque<MessageInTransit*> queue_; member in class:mojo::system::MessageInTransitQueue
|
message_in_transit_queue.cc | 18 queue_.swap(other->queue_); 29 STLDeleteElements(&queue_);
|
/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::__anon13079::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/cpp/bindings/lib/ |
message_queue.cc | 19 while (!queue_.empty()) 24 return queue_.empty(); 28 assert(!queue_.empty()); 29 return queue_.front(); 33 queue_.push(new Message()); 34 queue_.back()->Swap(message); 38 assert(!queue_.empty()); 39 queue_.front()->Swap(message); 44 assert(!queue_.empty()); 45 delete queue_.front() [all...] |
message_queue.h | 39 std::queue<Message*> queue_; member in class:mojo::internal::MessageQueue
|
/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/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/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/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 | 39 if (!queue_[i].empty()) 54 queue_[priority].push_back( 63 if (!queue_[i].empty()) { 64 PendingWrite pending_write = queue_[i].front(); 65 queue_[i].pop_front(); 92 for (std::deque<PendingWrite>::const_iterator it = queue_[i].begin(); 93 it != queue_[i].end(); ++it) { 104 std::deque<PendingWrite>* queue = &queue_[priority]; 128 std::deque<PendingWrite>* queue = &queue_[i]; 152 for (std::deque<PendingWrite>::iterator it = queue_[i].begin() [all...] |
spdy_read_queue.h | 43 std::deque<SpdyBuffer*> queue_; member in class:net::SpdyReadQueue
|
/external/chromium_org/v8/src/libplatform/ |
worker-thread.cc | 14 : Thread("V8 WorkerThread"), queue_(queue) { 25 while (Task* task = queue_->GetNext()) {
|
worker-thread.h | 30 TaskQueue* queue_; member in class:v8::internal::WorkerThread
|
/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/cc/resources/ |
resource_update_controller.cc | 44 queue_(queue.Pass()), 83 queue_->ClearUploadsToEvictedResources(); 98 while (queue_->FullUploadSize()) 99 UpdateTexture(queue_->TakeFirstFullUpload()); 101 while (queue_->PartialUploadSize()) 102 UpdateTexture(queue_->TakeFirstPartialUpload()); 130 if (!queue_->FullUploadSize()) 153 queue_->FullUploadSize(), UpdateMoreTexturesSize()); 158 while (queue_->FullUploadSize() && uploads--) 159 UpdateTexture(queue_->TakeFirstFullUpload()) [all...] |
/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/media/base/ |
decoder_buffer_queue.cc | 24 queue_.push_back(buffer); 55 scoped_refptr<DecoderBuffer> buffer = queue_.front(); 56 queue_.pop_front(); 72 queue_.clear(); 79 return queue_.empty();
|
/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_org/third_party/webrtc/modules/audio_device/android/ |
single_rw_fifo.h | 38 scoped_ptr<int8_t*[]> queue_; member in class:webrtc::SingleRwFifo
|
/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()); 96 webrtc::DesktopFrame* frame = queue_.current_frame(); 134 queue_.Reset();
|
/external/chromium_org/chrome/browser/resources/chromeos/chromevox/closure/ |
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) {
|