/external/chromium_org/sandbox/mac/ |
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/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/mesa/src/src/gallium/drivers/llvmpipe/ |
H A D | lp_scene_queue.c | 30 * 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 D | EdgeWalker_Test.h | 35 static State4* queue; member in struct:State4
|
/external/mesa3d/src/gallium/drivers/llvmpipe/ |
H A D | lp_scene_queue.c | 30 * 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 D | EdgeWalker_Test.h | 35 static State4* queue; member in struct:State4
|
/external/smack/src/org/jivesoftware/smackx/workgroup/agent/ |
H A D | QueueUsersListener.java | 30 * 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 D | fixed_queue.c | 69 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 D | thread.c | 114 // 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 D | delegated_renderer_layer.cc | 85 bool DelegatedRendererLayer::Update(ResourceUpdateQueue* queue, argument 87 bool updated = Layer::Update(queue, occlusion);
|
H A D | io_surface_layer.cc | 44 bool IOSurfaceLayer::Update(ResourceUpdateQueue* queue, argument 46 bool updated = Layer::Update(queue, occlusion);
|
H A D | image_layer.cc | 48 bool ImageLayer::Update(ResourceUpdateQueue* queue, argument 56 return TiledLayer::Update(queue, occlusion);
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | Uninterruptibles.java | 207 * 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 D | Crawler.java | 47 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 D | thread_collision_warner_unittest.cc | 151 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 D | bitmap_skpicture_content_layer_updater.cc | 22 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 D | image_layer_updater.cc | 17 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 D | resource_update_controller.cc | 41 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 D | resource_update_controller.h | 34 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 D | fake_content_layer.cc | 38 bool FakeContentLayer::Update(ResourceUpdateQueue* queue, argument 40 bool updated = ContentLayer::Update(queue, occlusion);
|
/external/chromium_org/chrome/browser/printing/ |
H A D | print_job_manager.cc | 78 scoped_refptr<PrintQueriesQueue> PrintJobManager::queue() { function in class:printing::PrintJobManager
|
/external/chromium_org/chrome/browser/ui/ |
H A D | browser_tabrestore_browsertest.cc | 85 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 D | dependency_graph.cc | 66 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 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/net/spdy/ |
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...] |