/external/chromium/net/websockets/ |
websocket_throttle.cc | 53 DCHECK(queue_.empty()); 63 queue_.push_back(job); 91 for (ConnectingQueue::iterator iter = queue_.begin(); 92 iter != queue_.end(); 95 queue_.erase(iter); 134 for (ConnectingQueue::iterator iter = queue_.begin(); 135 iter != queue_.end();
|
/external/chromium/base/ |
task_queue_unittest.cc | 42 : queue_(queue), 47 queue_->Push(task_to_queue_); 51 TaskQueue* queue_; member in class:__anon1479::TaskQueuerTask
|
task_queue.h | 41 std::deque<Task*> queue_; member in class:TaskQueue
|
/external/chromium_org/net/websockets/ |
websocket_throttle.h | 36 // Puts |job| in |queue_| and queues for the destination addresses 44 // Removes |job| from |queue_| and queues for the destination addresses 68 ConnectingQueue queue_; member in class:net::WebSocketThrottle
|
/external/chromium_org/cc/layers/ |
tiled_layer_unittest.cc | 52 queue_(make_scoped_ptr(new ResourceUpdateQueue)), 107 DCHECK(queue_); 111 queue_.Pass(), 114 queue_ = make_scoped_ptr(new ResourceUpdateQueue); 127 layer->Update(queue_.get(), occluded); 172 layer1->Update(queue_.get(), occlusion_); 174 layer2->Update(queue_.get(), occlusion_); 198 scoped_ptr<ResourceUpdateQueue> queue_; member in class:cc::__anon3863::TiledLayerTest 662 layer->Update(queue_.get(), NULL); [all...] |
/external/chromium_org/mojo/public/bindings/lib/ |
message_queue.h | 38 std::queue<Message*> queue_; member in class:mojo::MessageQueue
|
/external/chromium_org/media/base/ |
decoder_buffer_queue.h | 56 Queue queue_; member in class:media::DecoderBufferQueue 58 // A subset of |queue_| that contains buffers that are in strictly
|
/external/chromium_org/content/browser/indexed_db/ |
indexed_db_transaction.h | 114 bool empty() const { return queue_.empty(); } 115 void push(Operation task) { queue_.push(task); } 120 std::queue<Operation> queue_; member in class:content::IndexedDBTransaction::TaskQueue
|
indexed_db_transaction.cc | 27 while (!queue_.empty()) 28 queue_.pop(); 32 DCHECK(!queue_.empty()); 33 Operation task(queue_.front()); 34 queue_.pop();
|
/external/chromium_org/chrome/browser/extensions/activity_log/ |
activity_database_unittest.cc | 61 std::vector<scoped_refptr<Action> > queue_; member in class:extensions::ActivityDatabaseTestPolicy 84 for (i = 0; i < queue_.size(); i++) { 85 const Action& action = *queue_[i]; 98 queue_.clear(); 104 queue_.push_back(action); 105 db->AdviseFlush(queue_.size());
|
/external/chromium/chrome/browser/debugger/ |
devtools_remote_listen_socket_unittest.cc | 162 queue_.push_back(action); 167 queue_.push_back(action); 179 if (queue_.empty()) { 183 last_action_ = queue_.front(); 184 queue_.pop_front(); 200 if (queue_.empty()) { 204 last_action_ = queue_.front(); 205 queue_.pop_front();
|
/external/chromium/net/base/ |
listen_socket_unittest.h | 109 base::Lock lock_; // protects |queue_| and wraps |cv_| 111 std::deque<ListenSocketTestAction> queue_; member in class:ListenSocketTester
|
listen_socket_unittest.cc | 81 queue_.push_back(action); 87 while (queue_.empty()) 89 last_action_ = queue_.front(); 90 queue_.pop_front();
|
/external/chromium_org/cc/resources/ |
resource_update_controller_unittest.cc | 57 queue_(make_scoped_ptr(new ResourceUpdateQueue)), 140 queue_->AppendFullUpload(upload); 156 queue_->AppendPartialUpload(upload); 173 queue_.Pass(), 186 scoped_ptr<ResourceUpdateQueue> queue_; member in class:cc::__anon3910::ResourceUpdateControllerTest 397 queue_.Pass(), 444 queue_.Pass(), 484 queue_.Pass(),
|
resource_update_controller.h | 73 scoped_ptr<ResourceUpdateQueue> queue_; member in class:cc::ResourceUpdateController
|
/external/chromium_org/media/mp4/ |
offset_byte_queue.h | 53 // Synchronize |buf_| and |size_| with |queue_|. 56 ByteQueue queue_; member in class:media::OffsetByteQueue
|
/external/chromium_org/chrome/browser/printing/ |
printing_message_filter.cc | 96 queue_(g_browser_process->print_job_manager()->queue()) { 97 DCHECK(queue_); 314 printer_query = queue_->PopPrinterQuery(0); 316 printer_query = queue_->CreatePrinterQuery(); 351 queue_->QueuePrinterQuery(printer_query.get()); 362 queue_->PopPrinterQuery(params.cookie); 364 printer_query = queue_->CreatePrinterQuery(); 411 queue_->QueuePrinterQuery(printer_query.get()); 438 printer_query = queue_->PopPrinterQuery(document_cookie); 440 printer_query = queue_->CreatePrinterQuery() [all...] |
/external/chromium_org/content/browser/loader/ |
resource_scheduler.cc | 35 Iterator(NetQueue* queue) : queue_(queue) { 37 current_pointer_ = queue_->FirstMax(); 41 current_pointer_ = queue_->GetNextTowardsLastMin(current_pointer_); 60 NetQueue* queue_; member in class:content::ResourceScheduler::RequestQueue::Iterator 64 RequestQueue() : queue_(net::NUM_PRIORITIES) {} 71 NetQueue::Pointer pointer = queue_.Insert(request, priority); 81 queue_.Erase(it->second); 87 return queue_.FirstMax().value(); 91 return Iterator(&queue_); 100 bool IsEmpty() const { return queue_.size() == 0; 105 NetQueue queue_; member in class:content::ResourceScheduler::RequestQueue [all...] |
/external/chromium_org/mojo/public/tests/ |
bindings_connector_unittest.cc | 24 queue_.Push(message); 29 return queue_.IsEmpty(); 33 queue_.Pop(message); 37 MessageQueue queue_; member in class:mojo::test::MessageAccumulator
|
/external/chromium_org/net/spdy/ |
spdy_read_queue.h | 43 std::deque<SpdyBuffer*> queue_; member in class:net::SpdyReadQueue
|
/external/chromium_org/remoting/host/ |
screen_capturer_fake.h | 53 webrtc::ScreenCaptureFrameQueue queue_; member in class:remoting::ScreenCapturerFake
|
/external/chromium_org/chrome/browser/chromeos/drive/ |
search_metadata.cc | 72 bool empty() const { return queue_.empty(); } 74 size_t size() const { return queue_.size(); } 76 const T* top() const { return queue_.top(); } 78 void push(T* x) { queue_.push(x); } 84 T* saved_top = queue_.top(); 85 queue_.pop(); 90 std::priority_queue<T*, std::vector<T*>, Compare> queue_; member in class:drive::internal::__anon4212::ScopedPriorityQueue
|
/external/chromium_org/chrome/browser/extensions/ |
extension_host.cc | 70 queue_.push_back(host); 76 Queue::iterator it = std::find(queue_.begin(), queue_.end(), host); 77 if (it != queue_.end()) 78 queue_.erase(it); 101 if (queue_.empty()) 104 queue_.front()->CreateRenderViewNow(); 105 queue_.pop_front(); 107 if (!queue_.empty()) 112 Queue queue_; member in class:extensions::ExtensionHost::ProcessCreationQueue [all...] |
/external/chromium_org/third_party/leveldatabase/src/util/ |
env_posix.cc | 521 BGQueue queue_; member in class:leveldb::__anon11716::PosixEnv 545 if (queue_.empty()) { 550 queue_.push_back(BGItem()); 551 queue_.back().function = function; 552 queue_.back().arg = arg; 561 while (queue_.empty()) { 565 void (*function)(void*) = queue_.front().function; 566 void* arg = queue_.front().arg; 567 queue_.pop_front();
|
/external/chromium_org/content/browser/renderer_host/input/ |
touch_event_queue_unittest.cc | 37 queue_.reset(new TouchEventQueue(this)); 41 queue_.reset(); 67 queue_->OnGestureScrollEvent( 76 queue_->SetAckTimeoutEnabled(true, timeout_delay_ms); 80 queue_->QueueEvent(TouchEventWithLatencyInfo(event, ui::LatencyInfo())); 86 queue_->OnGestureScrollEvent( 91 queue_->ProcessTouchAck(ack_result, ui::LatencyInfo()); 145 return queue_->IsPendingAckTouchStart(); 149 queue_->FlushQueue(); 153 queue_->no_touch_to_renderer_ = !enabled 198 scoped_ptr<TouchEventQueue> queue_; member in class:content::TouchEventQueueTest [all...] |