Searched defs:queue (Results 76 - 100 of 247) sorted by path

12345678910

/external/chromium_org/media/filters/
H A Dsource_buffer_stream_unittest.cc385 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 Dmidi_message_queue_unittest.cc31 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 Drouter_unittest.cc37 explicit MessageAccumulator(internal::MessageQueue* queue) : queue_(queue) { argument
/external/chromium_org/net/socket/
H A Dwebsocket_endpoint_lock_manager.cc34 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 Dwebsocket_endpoint_lock_manager.h72 // 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 Dspdy_priority_tree.h11 #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 Dspdy_read_queue_unittest.cc20 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 Dspdy_session.cc907 // |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 Dspdy_write_queue.cc87 // |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 Dspdy_write_queue_unittest.cc56 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 Ddispatch_source_mach.cc17 // 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 Ddispatch_source_mach_unittest.cc89 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 Dwebrunner.js210 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 Dv8-richards.js46 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 Dv8-richards.js46 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 Dv8-richards.js46 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 DCustomElementMicrotaskDispatcher.cpp33 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 DFormController.cpp234 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 DDOMPatchSupport.cpp489 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 Dcompiler.jarMETA-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 DDoubleBufferedDequeTest.cpp16 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 Dmain.js41 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 Dqunit.js221 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 Dframeworks.jarMETA-INF/ META-INF/MANIFEST.MF android/ android/location/ android/location/Address$1.class ...
/external/chromium_org/third_party/boringssl/src/ssl/
H A Dd1_pkt.c207 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);

Completed in 1673 milliseconds

12345678910