Searched defs:queue (Results 151 - 175 of 247) sorted by last modified time

12345678910

/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/v4l2capture/
H A Dv4l2capture.c378 static PyObject *Video_device_read_internal(Video_device *self, int queue) argument
404 if(queue && my_ioctl(self->fd, VIDIOC_QBUF, &buffer))
462 "The buffer is removed from the queue. Fails if no buffer "
466 "Same as 'read', but adds the buffer back to the queue so the video "
/external/chromium_org/ui/aura/gestures/
H A Dgesture_recognizer_unittest.cc30 #include <queue>
365 void set_queue_events(bool queue) { queue_events_ = queue; } argument
375 std::queue<ui::TouchEvent*> queue_;
1708 scoped_ptr<aura::Window> queue(CreateTestWindowWithDelegate(
1711 queued_delegate->set_window(queue.get());
/external/chromium_org/ui/events/ozone/evdev/
H A Dtouch_event_converter_evdev_unittest.cc44 void ConfigureReadMock(struct input_event* queue,
103 void MockTouchEventConverterEvdev::ConfigureReadMock(struct input_event* queue, argument
107 queue + queue_index,
/external/chromium_org/third_party/closure_compiler/compiler/
H A Dcompiler.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/debugging/ com/google/debugging/sourcemap/ ...
/external/chromium_org/third_party/libevent/
H A Devent.c42 #include <sys/queue.h>
188 /* allocate a single active event queue */
912 event_queue_remove(struct event_base *base, struct event *ev, int queue) argument
914 if (!(ev->ev_flags & queue))
915 event_errx(1, "%s: %p(fd %d) not on queue %x", __func__,
916 ev, ev->ev_fd, queue);
921 ev->ev_flags &= ~queue;
922 switch (queue) {
935 event_errx(1, "%s: unknown queue %x", __func__, queue);
940 event_queue_insert(struct event_base *base, struct event *ev, int queue) argument
[all...]
/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/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/checkstyle/
H A Dcheckstyle-5.7-all.jarMETA-INF/MANIFEST.MF META-INF/ checkstyle_packages.xml checkstylecompilation.properties checkstyletask.properties com/ ...
/external/chromium_org/extensions/browser/
H A Devent_router.cc639 LazyBackgroundTaskQueue* queue = ExtensionSystem::Get(
641 if (queue->ShouldEnqueueTask(context, extension)) {
655 queue->AddPendingTask(context, extension->id(),
741 LazyBackgroundTaskQueue* queue = ExtensionSystem::Get( local
743 queue->AddPendingTask(browser_context_, extension->id(),
/external/chromium_org/extensions/browser/guest_view/app_view/
H A Dapp_view_guest.cc180 LazyBackgroundTaskQueue* queue = local
182 if (queue->ShouldEnqueueTask(browser_context(), guest_extension)) {
183 queue->AddPendingTask(browser_context(),
/external/chromium_org/media/base/
H A Ddecoder_buffer_queue_unittest.cc36 DecoderBufferQueue queue; local
37 EXPECT_TRUE(queue.IsEmpty());
39 queue.Push(CreateBuffer(0));
40 EXPECT_FALSE(queue.IsEmpty());
44 DecoderBufferQueue queue; local
45 queue.Push(CreateBuffer(0));
46 queue.Push(CreateBuffer(1));
47 EXPECT_FALSE(queue.IsEmpty());
48 EXPECT_EQ(1, queue.Duration().InSeconds());
50 queue
56 DecoderBufferQueue queue; local
85 DecoderBufferQueue queue; local
121 DecoderBufferQueue queue; local
146 DecoderBufferQueue queue; local
[all...]
H A Dstream_parser_unittest.cc39 // |queue|. |decode_timestamps| determines the number of appended buffers and
46 BufferQueue* queue) {
48 DCHECK(queue);
57 queue->push_back(buffer);
43 GenerateBuffers(const int* decode_timestamps, StreamParserBuffer::Type type, TrackId track_id, BufferQueue* queue) argument
/external/chromium_org/media/filters/
H A Dchunk_demuxer.cc27 static TimeDelta EndTimestamp(const StreamParser::BufferQueue& queue) { argument
28 return queue.back()->timestamp() + queue.back()->duration();
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));

Completed in 7936 milliseconds

12345678910