| /external/stlport/test/unit/ |
| queue_header_test.cpp | 8 #include <queue>
|
| /ndk/tests/device/test-gnustl-full/unit/ |
| queue_header_test.cpp | 8 #include <queue>
|
| /ndk/tests/device/test-stlport/unit/ |
| queue_header_test.cpp | 8 #include <queue>
|
| /external/dropbear/ |
| queue.c | 27 #include "queue.h"
29 void initqueue(struct Queue* queue) {
31 queue->head = NULL;
32 queue->tail = NULL;
33 queue->count = 0;
36 int isempty(struct Queue* queue) {
38 return (queue->head == NULL);
41 void* dequeue(struct Queue* queue)
[all...] |
| queue.h | 35 struct Queue {
43 void initqueue(struct Queue* queue);
44 int isempty(struct Queue* queue);
45 void* dequeue(struct Queue* queue);
46 void *examine(struct Queue* queue);
47 void enqueue(struct Queue* queue, void* item)
[all...] |
| /device/samsung/crespo/sec_mm/sec_omx/sec_osal/ |
| SEC_OSAL_Queue.c | 42 SEC_QUEUE *queue = (SEC_QUEUE *)queueHandle; local
46 if (!queue)
49 ret = SEC_OSAL_MutexCreate(&queue->qMutex);
53 queue->first = (SEC_QElem *)SEC_OSAL_Malloc(sizeof(SEC_QElem));
54 if (queue->first == NULL)
57 SEC_OSAL_Memset(queue->first, 0, sizeof(SEC_QElem));
58 currentqelem = queue->last = queue->first;
59 queue->numElem = 0;
64 while (queue->first != NULL)
86 SEC_QUEUE *queue = (SEC_QUEUE *)queueHandle; local
110 SEC_QUEUE *queue = (SEC_QUEUE *)queueHandle; local
131 SEC_QUEUE *queue = (SEC_QUEUE *)queueHandle; local
153 SEC_QUEUE *queue = (SEC_QUEUE *)queueHandle; local
165 SEC_QUEUE *queue = (SEC_QUEUE *)queueHandle; local
[all...] |
| /external/bluetooth/glib/glib/ |
| gqueue.h | 52 void g_queue_free (GQueue *queue);
53 void g_queue_init (GQueue *queue);
54 void g_queue_clear (GQueue *queue);
55 gboolean g_queue_is_empty (GQueue *queue);
56 guint g_queue_get_length (GQueue *queue);
57 void g_queue_reverse (GQueue *queue);
58 GQueue * g_queue_copy (GQueue *queue);
59 void g_queue_foreach (GQueue *queue,
62 GList * g_queue_find (GQueue *queue,
64 GList * g_queue_find_custom (GQueue *queue,
[all...] |
| gasyncqueue.h | 47 /* Lock and unlock a GAsyncQueue. All functions lock the queue for
49 * thus you lock the queue, call the *_unlocked functions and unlock it again.
51 void g_async_queue_lock (GAsyncQueue *queue);
52 void g_async_queue_unlock (GAsyncQueue *queue);
55 GAsyncQueue* g_async_queue_ref (GAsyncQueue *queue);
56 void g_async_queue_unref (GAsyncQueue *queue);
60 void g_async_queue_ref_unlocked (GAsyncQueue *queue);
61 void g_async_queue_unref_and_unlock (GAsyncQueue *queue);
64 /* Push data into the async queue. Must not be NULL. */
65 void g_async_queue_push (GAsyncQueue *queue,
[all...] |
| /external/guava/src/com/google/common/base/ |
| FinalizablePhantomReference.java | 40 * @param queue that should finalize the referent
43 FinalizableReferenceQueue queue) {
44 super(referent, queue.queue);
45 queue.cleanUp();
|
| FinalizableSoftReference.java | 36 * @param queue that should finalize the referent
39 FinalizableReferenceQueue queue) {
40 super(referent, queue.queue);
41 queue.cleanUp();
|
| FinalizableWeakReference.java | 36 * @param queue that should finalize the referent
39 FinalizableReferenceQueue queue) {
40 super(referent, queue.queue);
41 queue.cleanUp();
|
| /external/chromium/base/ |
| condition_variable_unittest.cc | 190 WorkQueue queue(kThreadCount); // Start the threads.
197 AutoLock auto_lock(*queue.lock());
198 while (!queue.EveryIdWasAllocated())
199 queue.all_threads_have_ids()->Wait();
209 AutoLock auto_lock(*queue.lock());
210 EXPECT_EQ(0, queue.GetNumThreadsTakingAssignments());
211 EXPECT_EQ(0, queue.GetNumThreadsCompletingTasks());
212 EXPECT_EQ(0, queue.task_count());
213 EXPECT_EQ(0, queue.GetMaxCompletionsByWorkerThread());
214 EXPECT_EQ(0, queue.GetMinCompletionsByWorkerThread())
[all...] |
| /libcore/luni/src/main/java/java/lang/ref/ |
| Reference.java | 53 * If non-null, the queue on which this reference will be enqueued
55 * VM requirement: this field <em>must</em> be called "queue"
59 volatile ReferenceQueue queue; field in class:Reference
107 * if "(queue != null && queueNext == null)".
111 if (queue != null && queueNext == null) {
112 queue.enqueue(this);
113 queue = null;
121 * a queue.
|
| /libcore/luni/src/test/java/tests/api/java/util/ |
| AbstractQueueTest.java | 37 private MockAbstractQueue<Object> queue; field in class:AbstractQueueTest
125 queue.add(null);
145 queue.add(o);
149 queue.add(o);
169 queue.add(o);
172 queue.add(I);
173 assertTrue(queue.contains(I));
174 Iterator iter = queue.iterator();
192 queue.addAll(null);
211 queue.addAll(list)
332 MockAbstractQueue queue = new MockAbstractQueue(); local
[all...] |
| /external/webkit/WebKitTools/Scripts/webkitpy/commands/ |
| queues_unittest.py | 39 name = "test-queue"
43 name = "test-review-queue"
51 self._assert_log_progress_output([1,2,3], "3 patches in test-queue [1, 2, 3]\n")
52 self._assert_log_progress_output(["1","2","3"], "3 patches in test-queue [1, 2, 3]\n")
53 self._assert_log_progress_output([1], "1 patch in test-queue [1]\n")
56 queue = TestQueue()
58 queue.bind_to_tool(tool)
60 queue.run_webkit_patch(run_args)
71 queue = TestReviewQueue()
73 queue.bind_to_tool(tool
[all...] |
| queuestest.py | 38 def __init__(self, name, queue):
52 def assert_queue_outputs(self, queue, args=None, work_item=None, expected_stdout=None, expected_stderr=None, options=Mock(), tool=MockBugzillaTool()):
63 queue.execute(options, args, tool, engine=MockQueueEngine)
66 queue.queue_log_path,
70 queue.work_item_log_path,
75 queue.begin_work_queue,
79 queue.should_continue_work_queue,
82 queue.next_work_item,
86 queue.should_proceed_with_work_item,
91 queue.process_work_item
[all...] |
| /external/chromium/net/ftp/ |
| ftp_directory_listing_parser_ls.h | 8 #include <queue>
33 std::queue<FtpDirectoryListingEntry> entries_;
|
| ftp_directory_listing_parser_mlsd.h | 8 #include <queue>
28 std::queue<FtpDirectoryListingEntry> entries_;
|
| ftp_directory_listing_parser_netware.h | 8 #include <queue>
30 std::queue<FtpDirectoryListingEntry> entries_;
|
| ftp_directory_listing_parser_windows.h | 8 #include <queue>
26 std::queue<FtpDirectoryListingEntry> entries_;
|
| ftp_directory_listing_parser_vms.h | 8 #include <queue>
55 std::queue<FtpDirectoryListingEntry> entries_;
|
| /frameworks/base/native/android/ |
| sensor.cpp | 65 sp<SensorEventQueue> queue = local
67 if (queue != 0) {
68 ALooper_addFd(looper, queue->getFd(), ident, ALOOPER_EVENT_INPUT, callback, data);
69 queue->looper = looper;
70 queue->incStrong(manager);
72 return static_cast<ASensorEventQueue*>(queue.get());
78 sp<SensorEventQueue> queue = static_cast<SensorEventQueue*>(inQueue); local
79 ALooper_removeFd(queue->looper, queue->getFd());
80 queue->decStrong(manager)
[all...] |
| /external/webkit/WebKitTools/DumpRenderTree/ |
| WorkQueue.h | 38 void queue(WorkQueueItem*);
|
| /frameworks/base/media/libstagefright/rtsp/ |
| AAVCAssembler.cpp | 48 List<sp<ABuffer> > *queue = source->queue(); local
50 if (queue->empty()) {
55 List<sp<ABuffer> >::iterator it = queue->begin();
56 while (it != queue->end()) {
61 it = queue->erase(it);
64 if (queue->empty()) {
69 sp<ABuffer> buffer = *queue->begin();
87 queue->erase(queue->begin())
[all...] |
| /external/webkit/WebKit/mac/Panels/ |
| WebPanelAuthenticationHandler.m | 70 NSMutableArray *queue = [windowToChallengeQueue objectForKey:window];
71 if (queue == nil) {
72 queue = [[NSMutableArray alloc] init];
73 [windowToChallengeQueue _webkit_setObject:queue forUncopiedKey:window];
74 [queue release];
76 [queue addObject:challenge];
81 NSMutableArray *queue = [windowToChallengeQueue objectForKey:window];
82 if (queue == nil) {
86 NSURLAuthenticationChallenge *challenge = [[queue objectAtIndex:0] retain];
87 [queue removeObjectAtIndex:0]
[all...] |
