| /external/fio/ |
| ioengine.h | 122 * io_ops->queue() return values
138 int (*queue)(struct thread_data *, struct io_u *); member in struct:ioengine_ops
157 FIO_SYNCIO = 1 << 0, /* io engine has synchronous ->queue */
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| ForwardingQueueTest.java | 31 import java.util.Queue;
43 private final Queue<T> backingQueue;
45 StandardImplForwardingQueue(Queue<T> backingQueue) {
49 @Override protected Queue<T> delegate() {
106 private Queue<String> forward;
107 private Queue<String> queue; field in class:ForwardingQueueTest
116 @Override protected Queue<String> create(String[] elements) {
137 queue = createProxyInstance(Queue.class)
[all...] |
| /external/javassist/src/main/javassist/bytecode/analysis/ |
| Analyzer.java | 133 IntQueue queue = new IntQueue(); local
141 queue.add(iter.next());
142 while (!queue.isEmpty()) {
143 analyzeNextEntry(method, iter, queue, executor);
168 IntQueue queue, Executor executor) throws BadBytecode {
169 int pos = queue.take();
185 mergeTableSwitch(queue, pos, iter, frame);
187 mergeLookupSwitch(queue, pos, iter, frame);
189 mergeRet(queue, iter, pos, frame, subroutine);
195 mergeJsr(queue, frames[pos], subroutines[target], pos, lookAhead(iter, pos))
[all...] |
| /external/mockito/cglib-and-asm/src/org/mockito/asm/tree/analysis/ |
| Analyzer.java | 72 private int[] queue;
field in class:Analyzer
111 queue = new int[n];
173 int insn = queue[--top];
475 queue[top++] = insn;
504 queue[top++] = insn;
|
| /frameworks/av/media/libstagefright/rtsp/ |
| AMPEG4AudioAssembler.cpp | 487 List<sp<ABuffer> > *queue = source->queue(); local
489 if (queue->empty()) {
494 List<sp<ABuffer> >::iterator it = queue->begin();
495 while (it != queue->end()) {
500 it = queue->erase(it);
503 if (queue->empty()) {
508 sp<ABuffer> buffer = *queue->begin();
531 queue->erase(queue->begin())
[all...] |
| /frameworks/base/core/java/android/os/ |
| Handler.java | 28 * queue. When you create a new Handler, it is bound to the thread /
29 * message queue of the thread that is creating it -- from that point on,
30 * it will deliver messages and runnables to that message queue and execute
31 * them as they come out of the message queue.
42 * you to enqueue Runnable objects to be called by the message queue when
49 * allow the item to be processed as soon as the message queue is ready
56 * running a message queue that takes care of managing the top-level
62 * in the Handler's message queue and processed when appropriate.
314 * Causes the Runnable r to be added to the message queue.
321 * message queue. Returns false on failure, usually because th
593 MessageQueue queue = mQueue; local
616 MessageQueue queue = mQueue; local
[all...] |
| /frameworks/support/v4/api21/android/support/v4/media/session/ |
| MediaControllerCompatApi21.java | 68 List<MediaSession.QueueItem> queue = ((MediaController) controllerObj).getQueue(); local
69 if (queue == null) {
72 List<Object> queueObjs = new ArrayList<Object>(queue);
|
| /hardware/libhardware/tests/camera2/ |
| camera2_utils.cpp | 105 ALOGV("%s: Streaming %d frames to queue", __FUNCTION__,
201 MetadataQueue *queue = getInstance(q); local
202 return queue->getBufferCount();
207 MetadataQueue *queue = getInstance(q); local
208 return queue->dequeue(buffer, true);
235 MetadataQueue *queue = getInstance(q); local
236 return queue->enqueue(filled_buffer);
|
| /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);
|
| /cts/suite/cts/deviceTests/browserbench/assets/octane/ |
| richards.js | 51 var queue = new Packet(null, ID_WORKER, KIND_WORK);
52 queue = new Packet(queue, ID_WORKER, KIND_WORK);
53 scheduler.addWorkerTask(ID_WORKER, 1000, queue);
55 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE);
56 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
57 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
58 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue);
[all...] |
| /development/cmds/monkey/src/com/android/commands/monkey/ |
| MonkeySourceNetwork.java | 42 import java.util.Queue;
100 * @param queue the command queue.
103 MonkeyCommandReturn translateCommand(List<String> command, CommandQueue queue);
113 CommandQueue queue) {
117 queue.enqueueEvent(new MonkeyFlipEvent(true));
120 queue.enqueueEvent(new MonkeyFlipEvent(false));
137 CommandQueue queue) {
165 queue.enqueueEvent(new MonkeyTouchEvent(action)
181 CommandQueue queue) {
[all...] |
| /external/bluetooth/bluedroid/stack/rfcomm/ |
| port_int.h | 56 BUFFER_Q queue; /* Queue of buffers waiting to be sent */ member in struct:__anon6313
59 UINT32 queue_size; /* Number of data bytes in the queue */
94 BUFFER_Q cmd_q; /* Queue for command messages on this mux */
203 UINT16 rx_buf_critical; /* port receive queue critical watermark level */
|
| /external/chromium_org/cc/layers/ |
| scrollbar_layer_unittest.cc | 743 ResourceUpdateQueue queue; local
749 scrollbar_layer->Update(&queue, &occlusion_tracker);
822 ResourceUpdateQueue queue; local
973 ResourceUpdateQueue queue; local
1050 ResourceUpdateQueue queue; local
[all...] |
| /external/chromium_org/chrome/browser/media/ |
| media_capture_devices_dispatcher.cc | 790 RequestsQueue& queue = pending_requests_[web_contents]; local
791 queue.push_back(PendingAccessRequest(request, callback));
794 if (queue.size() == 1)
1047 RequestsQueue& queue = rqs_it->second; local
[all...] |
| /external/chromium_org/extensions/browser/ |
| event_router.cc | 639 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/media/filters/ |
| source_buffer_stream_unittest.cc | 385 BufferQueue queue; local
416 queue.push_back(buffer);
418 if (!queue.empty())
419 EXPECT_EQ(expect_success, stream_->Append(queue));
[all...] |
| /external/chromium_org/third_party/WebKit/PerformanceTests/SunSpider/tests/v8-v4/ |
| v8-richards.js | 46 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/ |
| v8-richards.js | 46 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/ |
| v8-richards.js | 46 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/html/forms/ |
| FormController.cpp | 234 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/libjingle/source/talk/p2p/base/ |
| pseudotcp.cc | 481 int written = queue(buffer, uint32(len), false);
499 uint32 PseudoTcp::queue(const char* data, uint32 len, bool bCtrl) { function in class:cricket::PseudoTcp
836 // If we make room in the send queue, notify the user
[all...] |
| /external/chromium_org/v8/benchmarks/ |
| richards.js | 51 var queue = new Packet(null, ID_WORKER, KIND_WORK);
52 queue = new Packet(queue, ID_WORKER, KIND_WORK);
53 scheduler.addWorkerTask(ID_WORKER, 1000, queue);
55 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE);
56 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
57 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
58 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue);
[all...] |
| /external/clang/include/clang/AST/ |
| DataRecursiveASTVisitor.h | 117 /// Stmts are traversed internally using a data queue to avoid a stack overflow
290 StmtQueue.queue(S->getSubExpr()); \
310 StmtQueue.queue(S->getLHS()); \
311 StmtQueue.queue(S->getRHS()); \
442 NewQueueRAII(StmtsTy &queue, RecursiveASTVisitor &RAV) : RAV(RAV) {
443 RAV.Queues.push_back(&queue);
461 void queue(Stmt *S) { CurrQueue.push_back(S); } function in class:clang::RecursiveASTVisitor::StmtQueueAction
473 StmtsTy Queue, StmtsToEnqueue;
474 Queue.push_back(S);
477 while (!Queue.empty())
[all...] |
| /external/openssl/crypto/rand/ |
| rand_win.c | 392 GETQUEUESTATUS queue; local
396 queue = (GETQUEUESTATUS) GetProcAddress(user, "GetQueueStatus");
424 if (queue)
426 /* message queue status */
428 w = queue(QS_ALLEVENTS);
|
| /external/qemu/hw/input/ |
| ps2.c | 81 PS2Queue queue; member in struct:__anon13362
126 PS2Queue *q = &s->queue;
162 q = &s->queue;
349 (s->common.queue.count < (PS2_QUEUE_SIZE - 16))) {
496 q = &s->queue;
506 qemu_put_be32 (f, s->queue.rptr);
507 qemu_put_be32 (f, s->queue.wptr);
508 qemu_put_be32 (f, s->queue.count);
509 qemu_put_buffer (f, s->queue.data, sizeof (s->queue.data))
[all...] |
