HomeSort by relevance Sort by last modified time
    Searched refs:queue_ (Results 1 - 25 of 105) sorted by null

1 2 3 4 5

  /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) {

Completed in 904 milliseconds

1 2 3 4 5