| /external/chromium_org/net/url_request/ |
| url_request_throttler_entry.h | 8 #include <queue>
151 std::queue<base::TimeTicks> send_log_;
|
| /external/chromium_org/ppapi/proxy/ |
| file_chooser_resource.h | 8 #include <queue>
74 // queue, removing them when ownership has transferred to the plugin.
75 std::queue<PP_Resource> file_queue_;
|
| /external/chromium_org/remoting/host/ |
| oauth_token_getter.h | 8 #include <queue>
92 std::queue<OAuthTokenGetter::TokenCallback> pending_callbacks_;
|
| /external/chromium_org/remoting/host/setup/ |
| oauth_client.h | 8 #include <queue>
69 std::queue<Request> pending_requests_;
|
| /external/chromium_org/remoting/jingle_glue/ |
| fake_signal_strategy.h | 9 #include <queue>
58 // Queue of messages that have yet to be delivered to observers.
59 std::queue<buzz::XmlElement*> pending_messages_;
|
| /external/chromium_org/remoting/protocol/ |
| v2_authenticator.h | 9 #include <queue>
73 std::queue<std::string> pending_messages_;
|
| /external/deqp/framework/platform/android/ |
| tcuAndroidNativeActivity.cpp | 84 static void onInputQueueCreatedCallback (ANativeActivity* activity, AInputQueue* queue)
86 static_cast<tcu::Android::NativeActivity*>(activity->instance)->onInputQueueCreated(queue);
89 static void onInputQueueDestroyedCallback (ANativeActivity* activity, AInputQueue* queue)
91 static_cast<tcu::Android::NativeActivity*>(activity->instance)->onInputQueueDestroyed(queue);
193 void NativeActivity::onInputQueueCreated (AInputQueue* queue)
195 DE_UNREF(queue);
198 void NativeActivity::onInputQueueDestroyed (AInputQueue* queue)
200 DE_UNREF(queue);
|
| /external/lldb/test/api/multithreaded/ |
| common.h | 10 #include <queue>
28 std::queue<T> m_data;
|
| /external/mp4parser/isoparser/src/main/java/com/googlecode/mp4parser/authoring/tracks/ |
| AACTrackImpl.java | 109 LinkedList<Integer> queue = new LinkedList<Integer>(); local
113 queue.add(size);
114 while (queue.size() > packetsPerSecond) {
115 queue.pop();
117 if (queue.size() == (int) packetsPerSecond) {
119 for (int j = 0 ; j < queue.size(); j++) {
120 currSize += queue.get(j);
122 double currBitrate = 8.0 * currSize / queue.size() * packetsPerSecond;
|
| /frameworks/base/media/java/android/media/session/ |
| ISessionControllerCallback.aidl | 35 void onQueueChanged(in ParceledListSlice queue);
|
| /frameworks/native/services/surfaceflinger/ |
| MessageQueue.h | 72 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { }
|
| /device/moto/shamu/camera/QCamera/stack/mm-camera-interface/src/ |
| mm_camera_channel.c | 102 mm_channel_queue_t *queue);
104 mm_channel_queue_t *queue);
142 /* channel super queue functions */
143 int32_t mm_channel_superbuf_queue_init(mm_channel_queue_t * queue);
145 mm_channel_queue_t * queue);
147 mm_channel_queue_t * queue,
149 mm_channel_queue_node_t* mm_channel_superbuf_dequeue(mm_channel_queue_t * queue);
[all...] |
| /development/tools/axl/ |
| chewie.py | 16 class Queue:
18 self.queue = []
21 self.queue.append([url, time])
24 for x in range(len(self.queue)):
25 rec = self.queue[x]
27 del self.queue[x]
30 ## pull out request lag -- queue to start to done
56 queued = Queue()
|
| /external/chromium_org/content/common/gpu/media/ |
| v4l2_video_decode_accelerator.h | 12 #include <queue>
172 // decoder_input_queue_, then queue a DecodeBufferTask() to actually decode
205 // Enqueue a buffer on the corresponding queue.
220 // called any time a relevant queue could potentially be emptied: see
361 // Input queue for decoder_thread_: BitstreamBuffers in.
362 std::queue<linked_ptr<BitstreamBufferRef> > decoder_input_queue_;
379 std::queue<int> input_ready_queue_;
396 std::queue<int> free_output_buffers_;
405 std::queue<PictureRecord> pending_picture_ready_;
|
| v4l2_image_processor.h | 8 #include <queue>
145 std::queue<linked_ptr<JobRecord> > input_queue_;
146 std::queue<linked_ptr<JobRecord> > running_jobs_;
148 // Input queue state.
157 // Output queue state.
|
| /external/chromium_org/native_client_sdk/src/tools/tests/ |
| httpd_test.py | 7 import Queue
44 def _SubprocessThread(process, queue):
46 queue.put((process.returncode, stdout, stderr))
55 queue = Queue.Queue()
57 args=(self.process, queue))
62 returncode, stdout, stderr = queue.get(False)
|
| /external/qemu/distrib/mini-glib/include/ |
| glib.h | 170 void g_queue_free(GQueue* queue);
172 void g_queue_push_tail(GQueue* queue, void* data);
174 void* g_queue_peek_head(GQueue* queue);
176 void* g_queue_pop_head(GQueue* queue);
178 gboolean g_queue_is_empty(GQueue* queue);
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| PriorityBlockingQueue.java | 18 * An unbounded {@linkplain BlockingQueue blocking queue} that uses
20 * blocking retrieval operations. While this queue is logically
23 * {@code null} elements. A priority queue relying on {@linkplain
104 * Priority queue represented as a balanced binary heap: the two
105 * children of queue[n] are queue[2*n+1] and queue[2*(n+1)]. The
106 * priority queue is ordered by comparator, or by the elements'
109 * lowest value is in queue[0], assuming the queue is nonempty
111 private transient Object[] queue; field in class:PriorityBlockingQueue
[all...] |
| /frameworks/av/media/libstagefright/rtsp/ |
| AMPEG4ElementaryAssembler.cpp | 208 List<sp<ABuffer> > *queue = source->queue(); local
210 if (queue->empty()) {
215 List<sp<ABuffer> >::iterator it = queue->begin();
216 while (it != queue->end()) {
221 it = queue->erase(it);
224 if (queue->empty()) {
229 sp<ABuffer> buffer = *queue->begin();
368 queue->erase(queue->begin())
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ref/ |
| ReferenceTest.java | 147 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); local
149 r = newWeakReference(queue);
151 Reference ref = queue.remove();
156 r = newWeakReference(queue);
159 // wait for the reference queue thread to enqueue the newly-finalized object
163 ref = queue.poll();
253 private WeakReference<Object> newWeakReference(ReferenceQueue<Object> queue) {
255 WeakReference<Object> ref = new WeakReference<Object>(o, queue);
|
| /external/chromium_org/content/browser/renderer_host/ |
| render_widget_helper.cc | 151 BackingStoreMsgProxyQueue &queue = it->second; local
152 DCHECK(!queue.empty());
153 proxy = queue.front();
159 queue.pop_front();
160 if (queue.empty())
224 BackingStoreMsgProxyQueue &queue = it->second; local
225 DCHECK(queue.front() == proxy);
227 queue.pop_front();
228 if (queue.empty())
|
| /external/chromium_org/third_party/mesa/src/src/gallium/drivers/svga/ |
| svga_state_rss.c | 48 svga_queue_rs( &queue, SVGA3D_RS_##token, value ); \
58 svga_queue_rs( &queue, SVGA3D_RS_##token, value ); \
83 struct rs_queue queue; local
86 queue.rs_count = 0;
268 if (queue.rs_count) {
273 queue.rs_count ) != PIPE_OK)
277 queue.rs,
278 queue.rs_count * sizeof queue.rs[0]);
|
| /external/mesa3d/src/gallium/drivers/svga/ |
| svga_state_rss.c | 48 svga_queue_rs( &queue, SVGA3D_RS_##token, value ); \
58 svga_queue_rs( &queue, SVGA3D_RS_##token, value ); \
83 struct rs_queue queue; local
86 queue.rs_count = 0;
268 if (queue.rs_count) {
273 queue.rs_count ) != PIPE_OK)
277 queue.rs,
278 queue.rs_count * sizeof queue.rs[0]);
|
| /frameworks/base/tests/CoreTests/android/core/ |
| HeapTest.java | 230 ReferenceQueue<Object> queue) {
233 refs[i] = new PhantomReference<Object>(objects[i], queue);
238 ReferenceQueue<T> queue) {
242 * the queue are marked as enqueued. Once we
243 * pull them off the queue, they will no longer
258 /* Make sure that all of the references on the queue
262 while ((ref = (PhantomReference<T>) queue.poll()) != null) {
273 "unexpected ref on queue");
316 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); local
321 makeRefs(objects, refs, queue);
[all...] |
| /external/chromium_org/cc/layers/ |
| tiled_layer.h | 37 virtual bool Update(ResourceUpdateQueue* queue,
99 ResourceUpdateQueue* queue,
120 ResourceUpdateQueue* queue,
|
