| /external/libnl/lib/netfilter/ |
| D | queue_obj.c | 33 struct nfnl_queue *queue = (struct nfnl_queue *) a; in nfnl_queue_dump() local
83 void nfnl_queue_get(struct nfnl_queue *queue) in nfnl_queue_get()
88 void nfnl_queue_put(struct nfnl_queue *queue) in nfnl_queue_put()
100 void nfnl_queue_set_group(struct nfnl_queue *queue, uint16_t group) in nfnl_queue_set_group()
106 int nfnl_queue_test_group(const struct nfnl_queue *queue) in nfnl_queue_test_group()
111 uint16_t nfnl_queue_get_group(const struct nfnl_queue *queue) in nfnl_queue_get_group()
116 void nfnl_queue_set_maxlen(struct nfnl_queue *queue, uint32_t maxlen) in nfnl_queue_set_maxlen()
122 int nfnl_queue_test_maxlen(const struct nfnl_queue *queue) in nfnl_queue_test_maxlen()
127 uint32_t nfnl_queue_get_maxlen(const struct nfnl_queue *queue) in nfnl_queue_get_maxlen()
132 void nfnl_queue_set_copy_mode(struct nfnl_queue *queue, enum nfnl_queue_copy_mode mode) in nfnl_queue_set_copy_mode()
[all …]
|
| D | queue.c | 111 static int nfnl_queue_build_request(const struct nfnl_queue *queue, in nfnl_queue_build_request()
160 int nfnl_queue_build_create_request(const struct nfnl_queue *queue, in nfnl_queue_build_create_request()
182 int nfnl_queue_create(struct nl_sock *nlh, const struct nfnl_queue *queue) in nfnl_queue_create()
193 int nfnl_queue_build_change_request(const struct nfnl_queue *queue, in nfnl_queue_build_change_request()
199 int nfnl_queue_change(struct nl_sock *nlh, const struct nfnl_queue *queue) in nfnl_queue_change()
210 int nfnl_queue_build_delete_request(const struct nfnl_queue *queue, in nfnl_queue_build_delete_request()
220 int nfnl_queue_delete(struct nl_sock *nlh, const struct nfnl_queue *queue) in nfnl_queue_delete()
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | EvictingQueueTest.java | 44 EvictingQueue<String> queue = EvictingQueue.create(0); in testCreateWithZeroSize() local
70 EvictingQueue<String> queue = EvictingQueue.create(0); in testRemainingCapacity_maxSize0() local
75 EvictingQueue<String> queue = EvictingQueue.create(1); in testRemainingCapacity_maxSize1() local
82 EvictingQueue<String> queue = EvictingQueue.create(3); in testRemainingCapacity_maxSize3() local
93 EvictingQueue<String> queue = EvictingQueue.create(1); in testEvictingAfterOne() local
115 EvictingQueue<String> queue = EvictingQueue.create(3); in testEvictingAfterThree() local
139 EvictingQueue<String> queue = EvictingQueue.create(3); in testAddAll() local
164 EvictingQueue<String> queue = EvictingQueue.create(5); in testNullPointerExceptions() local
|
| D | MinMaxPriorityQueueTest.java | 53 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_simple() local
61 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_comparator() local
70 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_expectedSize() local
79 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_expectedSize_comparator() local
89 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_maximumSize() local
98 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_comparator_maximumSize() local
108 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_expectedSize_maximumSize() local
121 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_withContents() local
130 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_comparator_withContents() local
140 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_expectedSize_withContents() local
[all …]
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/sqs/ |
| D | connection.py | 98 def delete_queue(self, queue, force_deletion=False): argument
114 def purge_queue(self, queue): argument
126 def get_queue_attributes(self, queue, attribute='All'): argument
160 def set_queue_attribute(self, queue, attribute, value): argument
164 def receive_message(self, queue, number_messages=1, argument
222 def delete_message(self, queue, message): argument
238 def delete_message_batch(self, queue, messages): argument
258 def delete_message_from_handle(self, queue, receipt_handle): argument
274 def send_message(self, queue, message_content, delay_seconds=None, argument
333 def send_message_batch(self, queue, messages): argument
[all …]
|
| /external/webrtc/webrtc/common_audio/ |
| D | swap_queue_unittest.cc | 46 SwapQueue<std::vector<int>> queue(2, i); in TEST() local
59 SwapQueue<int> queue(2); in TEST() local
81 SwapQueue<int> queue(2); in TEST() local
90 SwapQueue<int> queue(2); in TEST() local
114 queue(2, template_element); in TEST() local
126 SwapQueue<std::vector<int>, LengthVerifierFunctor> queue(2, template_element, in TEST() local
140 SwapQueue<int, decltype(minus_2_verifier)> queue(2, minus_2_verifier); in TEST() local
154 queue(2, template_element); in TEST() local
164 queue(2, template_element); in TEST() local
180 SwapQueue<std::vector<int16_t>> queue(kQueueSize, in TEST() local
[all …]
|
| /external/squashfs-tools/squashfs-tools/ |
| D | caches-queues-lists.c | 41 struct queue *queue = malloc(sizeof(struct queue)); in queue_init() local
64 void queue_put(struct queue *queue, void *data) in queue_put()
81 void *queue_get(struct queue *queue) in queue_get()
100 int queue_empty(struct queue *queue) in queue_empty()
115 void queue_flush(struct queue *queue) in queue_flush()
126 void dump_queue(struct queue *queue) in dump_queue()
156 struct seq_queue *queue = malloc(sizeof(struct seq_queue)); in seq_queue_init() local
169 void seq_queue_put(struct seq_queue *queue, struct file_buffer *entry) in seq_queue_put()
188 struct file_buffer *seq_queue_get(struct seq_queue *queue) in seq_queue_get()
233 void seq_queue_flush(struct seq_queue *queue) in seq_queue_flush()
[all …]
|
| D | caches-queues-lists.h | 131 struct queue { struct
143 * struct describing seq_queues used to pass data between the read argument
|
| /external/v8/test/unittests/ |
| D | locked-queue-unittest.cc | 18 LockedQueue<Record> queue; in TEST() local
24 LockedQueue<Record> queue; in TEST() local
37 LockedQueue<Record> queue; in TEST() local
54 LockedQueue<Record> queue; in TEST() local
63 LockedQueue<Record> queue; in TEST() local
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/impl/ |
| D | select_reactor.hpp | 25 void select_reactor::add_timer_queue(timer_queue<Time_Traits>& queue) in add_timer_queue()
32 void select_reactor::remove_timer_queue(timer_queue<Time_Traits>& queue) in remove_timer_queue()
38 void select_reactor::schedule_timer(timer_queue<Time_Traits>& queue, in schedule_timer()
57 std::size_t select_reactor::cancel_timer(timer_queue<Time_Traits>& queue, in cancel_timer()
|
| /external/mesa3d/src/gallium/drivers/llvmpipe/ |
| D | lp_scene_queue.c | 62 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); in lp_scene_queue_create() local
81 lp_scene_queue_destroy(struct lp_scene_queue *queue) in lp_scene_queue_destroy()
90 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) in lp_scene_dequeue()
110 lp_scene_enqueue(struct lp_scene_queue *queue, struct lp_scene *scene) in lp_scene_enqueue()
|
| /external/v8/benchmarks/ |
| D | richards.js | 126 Scheduler.prototype.addIdleTask = function (id, priority, queue, count) { argument
136 Scheduler.prototype.addWorkerTask = function (id, priority, queue) { argument
146 Scheduler.prototype.addHandlerTask = function (id, priority, queue) { argument
156 Scheduler.prototype.addDeviceTask = function (id, priority, queue) { argument
167 Scheduler.prototype.addRunningTask = function (id, priority, queue, task) { argument
179 Scheduler.prototype.addTask = function (id, priority, queue, task) { argument
241 Scheduler.prototype.queue = function (packet) { method in Scheduler
260 function TaskControlBlock(link, id, priority, queue, task) { argument
527 Packet.prototype.addTo = function (queue) { argument
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ListenerCallQueueTest.java | 43 ListenerCallQueue<Object> queue = in testAddAndExecute() local
58 ListenerCallQueue<Object> queue = in testAddAndExecute_withExceptions() local
78 ListenerCallQueue<Object> queue = in testAddAndExecute_multithreaded() local
100 ListenerCallQueue<Object> queue = in testAddAndExecute_multithreaded_withThrowingRunnable() local
|
| /external/libchrome/base/threading/ |
| D | thread_collision_warner_unittest.cc | 150 explicit QueueUser(NonThreadSafeQueue* queue) : queue_(queue) {} in TEST()
163 NonThreadSafeQueue queue(local_reporter); in TEST() local
207 explicit QueueUser(NonThreadSafeQueue* queue) : queue_(queue) {} in TEST()
220 NonThreadSafeQueue queue(local_reporter); in TEST() local
266 QueueUser(NonThreadSafeQueue* queue, base::Lock* lock) in TEST()
286 NonThreadSafeQueue queue(local_reporter); in TEST() local
339 QueueUser(NonThreadSafeQueue* queue, base::Lock* lock) in TEST()
363 NonThreadSafeQueue queue(local_reporter); in TEST() local
|
| /external/javassist/src/main/javassist/bytecode/analysis/ |
| D | Analyzer.java | 133 IntQueue queue = new IntQueue(); in analyze() local
168 IntQueue queue, Executor executor) throws BadBytecode { in analyzeNextEntry()
276 private void merge(IntQueue queue, Frame frame, int target) { in merge()
292 private void mergeExceptionHandlers(IntQueue queue, MethodInfo method, int pos, Frame frame) { in mergeExceptionHandlers()
306 …private void mergeJsr(IntQueue queue, Frame frame, Subroutine sub, int pos, int next) throws BadBy… in mergeJsr()
347 …private void mergeLookupSwitch(IntQueue queue, int pos, CodeIterator iter, Frame frame) throws Bad… in mergeLookupSwitch()
361 …private void mergeRet(IntQueue queue, CodeIterator iter, int pos, Frame frame, Subroutine subrouti… in mergeRet()
400 …private void mergeTableSwitch(IntQueue queue, int pos, CodeIterator iter, Frame frame) throws BadB… in mergeTableSwitch()
|
| /external/guava/guava/src/com/google/common/collect/ |
| D | Queues.java | 98 ConcurrentLinkedQueue<E> queue = new ConcurrentLinkedQueue<E>(); in newConcurrentLinkedQueue() local
170 LinkedBlockingQueue<E> queue = new LinkedBlockingQueue<E>(); in newLinkedBlockingQueue() local
202 PriorityBlockingQueue<E> queue = new PriorityBlockingQueue<E>(); in newPriorityBlockingQueue() local
232 PriorityQueue<E> queue = new PriorityQueue<E>(); in newPriorityQueue() local
363 public static <E> Queue<E> synchronizedQueue(Queue<E> queue) { in synchronizedQueue()
|
| /external/v8/test/unittests/libplatform/ |
| D | task-queue-unittest.cc | 26 explicit TaskQueueThread(TaskQueue* queue) in TaskQueueThread()
39 TaskQueue queue; in TEST() local
49 TaskQueue queue; in TEST() local
|
| /external/doclava/src/com/google/doclava/ |
| D | MethodInfo.java | 47 private static void addInterfaces(ArrayList<ClassInfo> ifaces, ArrayList<ClassInfo> queue) { in addInterfaces()
52 addInterfaces(i.interfaces(), queue); in addInterfaces() local
67 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); in findOverriddenMethod() local
68 addInterfaces(containingClass().interfaces(), queue); in findOverriddenMethod() local
80 private static void addRealInterfaces(ArrayList<ClassInfo> ifaces, ArrayList<ClassInfo> queue) { in addRealInterfaces()
88 addInterfaces(i.realInterfaces(), queue); in addRealInterfaces() local
101 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); in findRealOverriddenMethod() local
106 addInterfaces(containingClass().realInterfaces(), queue); in findRealOverriddenMethod() local
134 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); in findSuperclassImplementation() local
139 addInterfaces(containingClass().realInterfaces(), queue); in findSuperclassImplementation() local
[all …]
|
| /external/guava/guava/src/com/google/common/base/internal/ |
| D | Finalizer.java | 70 ReferenceQueue<Object> queue, in startFinalizer()
104 private final ReferenceQueue<Object> queue; field in Finalizer
112 ReferenceQueue<Object> queue, in Finalizer()
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| D | test_support.py | 175 def execute_all_tasks(taskqueue, queue="default", handlers_map=None): argument
214 def execute_until_empty(taskqueue, queue="default", handlers_map=None): argument
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | MonitorBenchmark.java | 37 private BlockingQueue<String> queue; field in MonitorBenchmark
57 BlockingQueue<String> queue = this.queue; in addsAndRemoves() local
|
| /external/autotest/contrib/ |
| D | watch_expensive_rpcs.py | 67 def pull_all_data(pid, queue): argument
88 queue = multiprocessing.Queue() variable
|
| /external/deqp/framework/platform/android/ |
| D | tcuAndroidNativeActivity.cpp | 84 static void onInputQueueCreatedCallback (ANativeActivity* activity, AInputQueue* queue) in onInputQueueCreatedCallback()
89 static void onInputQueueDestroyedCallback (ANativeActivity* activity, AInputQueue* queue) in onInputQueueDestroyedCallback()
193 void NativeActivity::onInputQueueCreated (AInputQueue* queue) in onInputQueueCreated()
198 void NativeActivity::onInputQueueDestroyed (AInputQueue* queue) in onInputQueueDestroyed()
|
| /external/autotest/scheduler/ |
| D | thread_lib_unittest.py | 82 def waiting_func(queue): argument
88 def exception_func(queue): argument
|
| /external/jetty/src/java/org/eclipse/jetty/server/ |
| D | AsyncNCSARequestLog.java | 47 public AsyncNCSARequestLog(BlockingQueue<String> queue) in AsyncNCSARequestLog()
57 public AsyncNCSARequestLog(String filename,BlockingQueue<String> queue) in AsyncNCSARequestLog()
|