Searched defs:queue (Results 26 - 50 of 247) sorted by relevance

12345678910

/external/chromium_org/sandbox/mac/
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/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/mesa/src/src/gallium/drivers/llvmpipe/
H A Dlp_scene_queue.c30 * Scene queue. We'll use two queues. One contains "full" scenes which
49 * A queue of scenes
58 /** Allocate a new scene queue */
62 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); local
63 if (queue == NULL)
66 queue->ring = util_ringbuffer_create( MAX_SCENE_QUEUE *
68 if (queue->ring == NULL)
71 return queue;
74 FREE(queue);
79 /** Delete a scene queue */
81 lp_scene_queue_destroy(struct lp_scene_queue *queue) argument
90 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) argument
110 lp_scene_enqueue(struct lp_scene_queue *queue, struct lp_scene *scene) argument
[all...]
/external/chromium_org/third_party/skia/experimental/Intersection/
H A DEdgeWalker_Test.h35 static State4* queue; member in struct:State4
/external/mesa3d/src/gallium/drivers/llvmpipe/
H A Dlp_scene_queue.c30 * Scene queue. We'll use two queues. One contains "full" scenes which
49 * A queue of scenes
58 /** Allocate a new scene queue */
62 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); local
63 if (queue == NULL)
66 queue->ring = util_ringbuffer_create( MAX_SCENE_QUEUE *
68 if (queue->ring == NULL)
71 return queue;
74 FREE(queue);
79 /** Delete a scene queue */
81 lp_scene_queue_destroy(struct lp_scene_queue *queue) argument
90 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) argument
110 lp_scene_enqueue(struct lp_scene_queue *queue, struct lp_scene *scene) argument
[all...]
/external/skia/experimental/Intersection/
H A DEdgeWalker_Test.h35 static State4* queue; member in struct:State4
/external/smack/src/org/jivesoftware/smackx/workgroup/agent/
H A DQueueUsersListener.java30 * The status of the queue was updated.
32 * @param queue the workgroup queue.
33 * @param status the status of queue.
35 public void statusUpdated(WorkgroupQueue queue, WorkgroupQueue.Status status); argument
38 * The average wait time of the queue was updated.
40 * @param queue the workgroup queue.
41 * @param averageWaitTime the average wait time of the queue.
43 public void averageWaitTimeUpdated(WorkgroupQueue queue, in argument
51 oldestEntryUpdated(WorkgroupQueue queue, Date oldestEntry) argument
59 usersUpdated(WorkgroupQueue queue, Set<QueueUser> users) argument
[all...]
/external/bluetooth/bluedroid/osi/src/
H A Dfixed_queue.c69 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb) { argument
70 if (!queue)
74 for (const list_node_t *node = list_begin(queue->list); node != list_end(queue->list); node = list_next(node))
77 list_free(queue->list);
78 semaphore_free(queue->enqueue_sem);
79 semaphore_free(queue->dequeue_sem);
80 pthread_mutex_destroy(&queue->lock);
81 free(queue);
84 void fixed_queue_enqueue(fixed_queue_t *queue, voi argument
97 fixed_queue_dequeue(fixed_queue_t *queue) argument
112 fixed_queue_try_enqueue(fixed_queue_t *queue, void *data) argument
127 fixed_queue_try_dequeue(fixed_queue_t *queue) argument
143 fixed_queue_get_dequeue_fd(const fixed_queue_t *queue) argument
148 fixed_queue_get_enqueue_fd(const fixed_queue_t *queue) argument
[all...]
H A Dthread.c114 // of queue space, we should abort this operation, otherwise we'll
117 // Queue item is freed either when the queue itself is destroyed
118 // or when the item is removed from the queue for dispatch.
180 ALOGD("%s growing event queue on shutdown.", __func__);
188 fixed_queue_t *queue = (fixed_queue_t *)context; local
189 work_item_t *item = fixed_queue_dequeue(queue);
/external/chromium_org/cc/layers/
H A Ddelegated_renderer_layer.cc85 bool DelegatedRendererLayer::Update(ResourceUpdateQueue* queue, argument
87 bool updated = Layer::Update(queue, occlusion);
H A Dio_surface_layer.cc44 bool IOSurfaceLayer::Update(ResourceUpdateQueue* queue, argument
46 bool updated = Layer::Update(queue, occlusion);
H A Dimage_layer.cc48 bool ImageLayer::Update(ResourceUpdateQueue* queue, argument
56 return TiledLayer::Update(queue, occlusion);
/external/guava/guava/src/com/google/common/util/concurrent/
H A DUninterruptibles.java207 * Invokes {@code queue.}{@link BlockingQueue#take() take()} uninterruptibly.
209 public static <E> E takeUninterruptibly(BlockingQueue<E> queue) { argument
214 return queue.take();
227 * Invokes {@code queue.}{@link BlockingQueue#put(Object) put(element)}
230 public static <E> void putUninterruptibly(BlockingQueue<E> queue, E element) { argument
235 queue.put(element);
/external/okhttp/samples/crawler/src/main/java/com/squareup/okhttp/sample/
H A DCrawler.java47 private final LinkedBlockingQueue<URL> queue = new LinkedBlockingQueue<URL>(); field in class:Crawler
70 for (URL url; (url = queue.take()) != null; ) {
107 if (link != null) queue.add(link);
138 crawler.queue.add(new URL(args[1]));
/external/chromium_org/base/threading/
H A Dthread_collision_warner_unittest.cc151 explicit QueueUser(NonThreadSafeQueue& queue) argument
152 : queue_(queue) {}
165 NonThreadSafeQueue queue(local_reporter);
167 QueueUser queue_user_a(queue);
168 QueueUser queue_user_b(queue);
209 explicit QueueUser(NonThreadSafeQueue& queue) argument
210 : queue_(queue) {}
223 NonThreadSafeQueue queue(local_reporter);
225 QueueUser queue_user_a(queue);
226 QueueUser queue_user_b(queue);
269 QueueUser(NonThreadSafeQueue& queue, base::Lock& lock) argument
343 QueueUser(NonThreadSafeQueue& queue, base::Lock& lock) argument
[all...]
/external/chromium_org/cc/resources/
H A Dbitmap_skpicture_content_layer_updater.cc22 ResourceUpdateQueue* queue,
36 queue->AppendPartialUpload(upload);
38 queue->AppendFullUpload(upload);
21 Update( ResourceUpdateQueue* queue, const gfx::Rect& source_rect, const gfx::Vector2d& dest_offset, bool partial_update) argument
H A Dimage_layer_updater.cc17 void ImageLayerUpdater::Resource::Update(ResourceUpdateQueue* queue, argument
22 queue, texture(), source_rect, dest_offset, partial_update);
36 void ImageLayerUpdater::UpdateTexture(ResourceUpdateQueue* queue, argument
54 queue->AppendPartialUpload(upload);
56 queue->AppendFullUpload(upload);
H A Dresource_update_controller.cc41 scoped_ptr<ResourceUpdateQueue> queue,
44 queue_(queue.Pass()),
64 // attempt. This ensures that we empty the update queue in a finite
38 ResourceUpdateController( ResourceUpdateControllerClient* client, base::SingleThreadTaskRunner* task_runner, scoped_ptr<ResourceUpdateQueue> queue, ResourceProvider* resource_provider) argument
H A Dresource_update_controller.h34 scoped_ptr<ResourceUpdateQueue> queue,
37 client, task_runner, queue.Pass(), resource_provider));
57 scoped_ptr<ResourceUpdateQueue> queue,
31 Create( ResourceUpdateControllerClient* client, base::SingleThreadTaskRunner* task_runner, scoped_ptr<ResourceUpdateQueue> queue, ResourceProvider* resource_provider) argument
/external/chromium_org/cc/test/
H A Dfake_content_layer.cc38 bool FakeContentLayer::Update(ResourceUpdateQueue* queue, argument
40 bool updated = ContentLayer::Update(queue, occlusion);
/external/chromium_org/chrome/browser/printing/
H A Dprint_job_manager.cc78 scoped_refptr<PrintQueriesQueue> PrintJobManager::queue() { function in class:printing::PrintJobManager
/external/chromium_org/chrome/browser/ui/
H A Dbrowser_tabrestore_browsertest.cc85 content::DOMMessageQueue queue; local
90 AwaitTabsReady(&queue, 2);
133 content::DOMMessageQueue queue; local
136 AwaitTabsReady(&queue, 2);
/external/chromium_org/components/keyed_service/core/
H A Ddependency_graph.cc66 std::deque<DependencyNode*> queue; local
67 std::copy(all_nodes_.begin(), all_nodes_.end(), std::back_inserter(queue));
69 std::deque<DependencyNode*>::iterator queue_end = queue.end();
71 queue_end = std::remove(queue.begin(), queue_end, it->second);
73 queue.erase(queue_end, queue.end());
78 while (!queue.empty()) {
79 DependencyNode* node = queue.front();
80 queue.pop_front();
101 queue
[all...]
/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/net/spdy/
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...]

Completed in 5129 milliseconds

12345678910