/external/chromium_org/media/filters/ |
H A D | source_buffer_stream_unittest.cc | 385 BufferQueue queue; local 416 queue.push_back(buffer); 418 if (!queue.empty()) 419 EXPECT_EQ(expect_success, stream_->Append(queue));
|
/external/chromium_org/media/midi/ |
H A D | midi_message_queue_unittest.cc | 31 void Add(MidiMessageQueue* queue, const T(&array)[N]) { argument 32 queue->Add(array, N); 58 MidiMessageQueue queue(false); 60 queue.Get(&message); 65 MidiMessageQueue queue(false); 66 Add(&queue, kGMOn); 67 Add(&queue, kBrokenData1); 68 Add(&queue, kNoteOnWithRunningStatus); 69 Add(&queue, kBrokenData2); 70 Add(&queue, kChannelPressureWithRunningStatu [all...] |
/external/chromium_org/mojo/public/cpp/bindings/tests/ |
H A D | router_unittest.cc | 37 explicit MessageAccumulator(internal::MessageQueue* queue) : queue_(queue) { argument
|
/external/chromium_org/net/socket/ |
H A D | websocket_endpoint_lock_manager.cc | 34 lock_info_in_map.queue.reset(new LockInfo::WaiterQueue); 38 lock_info_in_map.queue->Append(waiter); 92 DCHECK(!rhs.queue); 106 LockInfo::WaiterQueue* queue = lock_info_it->second.queue.get(); local 107 DCHECK(queue); 108 if (queue->empty()) { 116 Waiter* next_job = queue->head()->value();
|
H A D | websocket_endpoint_lock_manager.h | 72 // copied after |queue| has been assigned to. 81 scoped_ptr<WaiterQueue> queue; member in struct:net::WebSocketEndpointLockManager::LockInfo 104 // endpoint is locked. If LockInfo.queue is non-empty, then one or more
|
/external/chromium_org/net/spdy/ |
H A D | spdy_priority_tree.h | 11 #include <queue> 448 List queue; local 454 queue.push_back(*it); 456 while (!queue.empty()) { 457 NodeId current_node_id = queue.front(); 471 queue.push_back(*it); 486 // Remove this node from the queue. 487 queue.pop_front();
|
H A D | spdy_read_queue_unittest.cc | 20 const char kData[] = "SPDY read queue test data.\0Some more data."; 23 // Enqueues |data| onto |queue| in chunks of at most |max_buffer_size| 27 SpdyReadQueue* queue) { 30 size_t old_total_size = queue->GetTotalSize(); 33 queue->Enqueue( 36 EXPECT_FALSE(queue->IsEmpty()); 37 EXPECT_EQ(old_total_size + i, queue->GetTotalSize()); 41 // Dequeues all bytes in |queue| in chunks of at most 43 std::string DrainToString(size_t max_buffer_size, SpdyReadQueue* queue) { argument 47 size_t padding = std::max(static_cast<size_t>(4096), queue 25 EnqueueString(const std::string& data, size_t max_buffer_size, SpdyReadQueue* queue) argument [all...] |
H A D | spdy_session.cc | 907 // |request| should not be in a queue not matching its priority. 911 PendingStreamRequestQueue* queue = &pending_create_stream_queues_[i]; local 912 DCHECK(std::find_if(queue->begin(), 913 queue->end(), 914 RequestEquals(request)) == queue->end()); 918 PendingStreamRequestQueue* queue = local 920 // Remove |request| from |queue| while preserving the order of the 923 std::find_if(queue->begin(), queue->end(), RequestEquals(request)); 926 if (it != queue 3251 std::deque<SpdyStreamId>* queue = &stream_send_unstall_queue_[i]; local [all...] |
H A D | spdy_write_queue.cc | 87 // |stream| should not have pending writes in a queue not matching 99 // Defer deletion until queue iteration is complete, as 104 std::deque<PendingWrite>* queue = &queue_[priority]; local 105 std::deque<PendingWrite>::iterator out_it = queue->begin(); 106 for (std::deque<PendingWrite>::const_iterator it = queue->begin(); 107 it != queue->end(); ++it) { 115 queue->erase(out_it, queue->end()); 128 std::deque<PendingWrite>* queue = &queue_[i]; local 129 std::deque<PendingWrite>::iterator out_it = queue [all...] |
H A D | spdy_write_queue_unittest.cc | 56 RequeingBufferProducer(SpdyWriteQueue* queue) { argument 59 base::Bind(RequeingBufferProducer::ConsumeCallback, queue)); 66 static void ConsumeCallback(SpdyWriteQueue* queue, argument 73 queue->Enqueue( 265 // Enqueue a bunch of writes and then call Clear(). The write queue 285 SpdyWriteQueue queue; local 286 queue.Enqueue( 289 scoped_ptr<SpdyBufferProducer>(new RequeingBufferProducer(&queue)), 296 EXPECT_TRUE(queue.Dequeue(&frame_type, &producer, &stream)); 297 EXPECT_TRUE(queue 312 SpdyWriteQueue queue; local 334 SpdyWriteQueue queue; local 356 SpdyWriteQueue queue; local [all...] |
/external/chromium_org/sandbox/mac/ |
H A D | dispatch_source_mach.cc | 17 // Since the queue was created above in the delegated constructor, and it was 22 DispatchSourceMach::DispatchSourceMach(dispatch_queue_t queue, argument 25 : queue_(queue), 29 dispatch_retain(queue);
|
H A D | dispatch_source_mach_unittest.cc | 89 dispatch_queue_t queue = local 93 dispatch_async(queue, ^{ 107 dispatch_async(queue, ^{ 116 dispatch_release(queue);
|
/external/chromium_org/third_party/WebKit/PerformanceTests/Dromaeo/resources/dromaeo/web/ |
H A D | webrunner.js | 210 var queue = []; variable 352 // Remove the next test from the queue and execute it 354 if ( interval && queue.length ) { 357 status: { current: totalTestItems - queue.length, 361 queue.shift()(); 362 } else if ( queue.length == 0 ) { 412 queue = queue.concat( queues[ names[n] ] ); 415 totalTestItems = queue.length;
|
/external/chromium_org/third_party/WebKit/PerformanceTests/SunSpider/tests/v8-v4/ |
H A D | v8-richards.js | 46 var queue = new Packet(null, ID_WORKER, KIND_WORK); 47 queue = new Packet(queue, ID_WORKER, KIND_WORK); 48 scheduler.addWorkerTask(ID_WORKER, 1000, queue); 50 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE); 51 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE); 52 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE); 53 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue); [all...] |
/external/chromium_org/third_party/WebKit/PerformanceTests/SunSpider/tests/v8-v5/ |
H A D | v8-richards.js | 46 var queue = new Packet(null, ID_WORKER, KIND_WORK); 47 queue = new Packet(queue, ID_WORKER, KIND_WORK); 48 scheduler.addWorkerTask(ID_WORKER, 1000, queue); 50 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE); 51 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE); 52 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE); 53 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue); [all...] |
/external/chromium_org/third_party/WebKit/PerformanceTests/SunSpider/tests/v8-v6/ |
H A D | v8-richards.js | 46 var queue = new Packet(null, ID_WORKER, KIND_WORK); 47 queue = new Packet(queue, ID_WORKER, KIND_WORK); 48 scheduler.addWorkerTask(ID_WORKER, 1000, queue); 50 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE); 51 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE); 52 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE); 53 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue); [all...] |
/external/chromium_org/third_party/WebKit/Source/core/dom/custom/ |
H A D | CustomElementMicrotaskDispatcher.cpp | 33 void CustomElementMicrotaskDispatcher::enqueue(CustomElementCallbackQueue* queue) argument 36 queue->setOwner(kMicrotaskQueueId); 37 m_elements.append(queue);
|
/external/chromium_org/third_party/WebKit/Source/core/html/forms/ |
H A D | FormController.cpp | 234 const Deque<FormControlState>& queue = it->value; local 235 for (Deque<FormControlState>::const_iterator queIterator = queue.begin(); queIterator != queue.end(); ++queIterator) { 279 const Deque<FormControlState>& queue = it->value; local 280 for (Deque<FormControlState>::const_iterator queIterator = queue.begin(); queIterator != queue.end(); ++queIterator) {
|
/external/chromium_org/third_party/WebKit/Source/core/inspector/ |
H A D | DOMPatchSupport.cpp | 489 Deque<Digest*> queue; local 490 queue.append(digest); 491 while (!queue.isEmpty()) { 492 Digest* first = queue.takeFirst(); 495 queue.append(first->m_children[i].get());
|
/external/chromium_org/third_party/WebKit/Source/devtools/scripts/closure/ |
H A D | compiler.jar | META-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/javascript/ com/google/javascript/jscomp/ ... |
/external/chromium_org/third_party/WebKit/Source/wtf/ |
H A D | DoubleBufferedDequeTest.cpp | 16 DoubleBufferedDeque<int> queue; local 18 EXPECT_TRUE(queue.isEmpty()); 19 queue.append(1); 20 EXPECT_FALSE(queue.isEmpty()); 25 DoubleBufferedDeque<int> queue; local 26 queue.append(1); 28 queue.swapBuffers(); 29 EXPECT_TRUE(queue.isEmpty()); 34 DoubleBufferedDeque<int> queue; local 35 queue [all...] |
/external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/tool/servers/data/rebaselineserver/ |
H A D | main.js | 41 STATE_TO_DISPLAY_STATE[STATE_IN_QUEUE] = 'In queue'; 48 var queue; variable 63 queue = new RebaselineQueue(); 80 queue.addCurrentTest(); 83 queue.removeCurrentTest(); 86 queue.rebaseline(); 394 queue.updateState();
|
/external/chromium_org/third_party/WebKit/Tools/qunit/qunit/ |
H A D | qunit.js | 221 queue: function() { 293 test.queue(); 436 // The queue of tests to run 437 queue: [], 503 queue: [], 676 // Initialize the config, saving the execution queue 853 config.queue.push( callback ); 863 while ( config.queue.length && !config.blocking ) { 865 config.queue.shift()(); 871 if (!config.blocking && !config.queue [all...] |
/external/chromium_org/third_party/android_platform/webview/ |
H A D | frameworks.jar | META-INF/ META-INF/MANIFEST.MF android/ android/location/ android/location/Address$1.class ... |
/external/chromium_org/third_party/boringssl/src/ssl/ |
H A D | d1_pkt.c | 207 dtls1_buffer_record(SSL *s, record_pqueue *queue, unsigned char *priority) argument 212 /* Limit the size of the queue to prevent DOS attacks */ 213 if (pqueue_size(queue->q) >= 100) 248 if (pqueue_insert(queue->q, item) == NULL) 261 dtls1_retrieve_buffered_record(SSL *s, record_pqueue *queue) argument 265 item = pqueue_pop(queue->q);
|