| /external/autotest/server/cros/ |
| queue_barrier.py | 5 from multiprocessing import Queue, queues namespace
52 except queues.Empty:
72 except queues.Empty:
|
| /external/autotest/client/site_tests/security_SysVIPC/ |
| security_SysVIPC.py | 101 # Also check Message Queues. Since we currently expect
103 queues = utils.system_output('ipcs -q | grep ^0', ignore_status=True)
104 if queues:
106 logging.error('Unexpected message queues found:')
107 logging.error(queues)
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ListenerCallQueue.java | 22 import com.google.common.collect.Queues;
51 /** Helper method to add this callback to all the queues. */
52 void enqueueOn(Iterable<ListenerCallQueue<L>> queues) {
53 for (ListenerCallQueue<L> queue : queues) {
62 @GuardedBy("this") private final Queue<Callback<L>> waitQueue = Queues.newArrayDeque();
|
| /external/squashfs-tools/squashfs-tools/ |
| Android.mk | 26 caches-queues-lists.c \
|
| Makefile | 115 caches-queues-lists.o
232 info.h caches-queues-lists.h read_fs.h restore.h process_fragments.h
257 caches-queues-lists.h
259 restore.o: restore.c caches-queues-lists.h squashfs_fs.h mksquashfs.h error.h \
264 caches-queues-lists.o: caches-queues-lists.c error.h caches-queues-lists.h
|
| /external/vulkan-validation-layers/demos/smoke/ |
| Helpers.h | 91 inline VkResult get(VkPhysicalDevice phy, std::vector<VkQueueFamilyProperties> &queues)
96 queues.resize(count);
97 vk::GetPhysicalDeviceQueueFamilyProperties(phy, &count, queues.data());
|
| Shell.cpp | 236 std::vector<VkQueueFamilyProperties> queues; local
237 vk::get(phy, queues);
240 for (uint32_t i = 0; i < queues.size(); i++) {
241 const VkQueueFamilyProperties &q = queues[i];
243 // requires only GRAPHICS for game queues
|
| /external/vulkan-validation-layers/libs/vkjson/ |
| vkjson_instance.cc | 61 device.queues.resize(queue_family_count);
63 physical_device, &queue_family_count, device.queues.data());
|
| vkjson.h | 57 std::vector<VkQueueFamilyProperties> queues; member in struct:VkJsonDevice
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/multiprocessing/ |
| __init__.py | 217 from multiprocessing.queues import Queue
224 from multiprocessing.queues import JoinableQueue
|
| /prebuilts/gdb/linux-x86/lib/python2.7/multiprocessing/ |
| __init__.py | 217 from multiprocessing.queues import Queue
224 from multiprocessing.queues import JoinableQueue
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
| __init__.py | 217 from multiprocessing.queues import Queue
224 from multiprocessing.queues import JoinableQueue
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
| __init__.py | 217 from multiprocessing.queues import Queue
224 from multiprocessing.queues import JoinableQueue
|
| /external/autotest/client/tests/kvm/tests/ |
| virtio_console.py | 316 def __init__(self, port, event, queues, blocklen=1024):
320 @param queues: Queues for the control data (FIFOs)
325 self.queues = queues
342 for queue in self.queues:
354 for queue in self.queues:
[all...] |
| /hardware/libhardware/modules/sensors/ |
| multihal.cpp | 48 // This mutex is shared by all queues
201 std::vector<SensorEventQueue*> queues; member in struct:sensors_poll_context_t
217 this->queues.push_back(queue);
339 queueCount = (int)this->queues.size();
342 SensorEventQueue* queue = this->queues.at(this->nextReadIndex);
360 // The queues have been scanned and none contain data, so wait.
|
| /bionic/libc/kernel/uapi/sound/ |
| asequencer.h | 236 int queues; member in struct:snd_seq_system_info
|
| /external/chromium-trace/catapult/third_party/typ/typ/ |
| pool.py | 104 multiprocessing.queues.is_exiting = lambda: True
|
| /external/kernel-headers/original/uapi/sound/ |
| asequencer.h | 171 #define SNDRV_SEQ_ADDRESS_BROADCAST 255 /* send event to all queues/clients/ports/channels */
312 int queues; /* maximum queues count */ member in struct:snd_seq_system_info
317 int cur_queues; /* current queues */
378 #define SNDRV_SEQ_REMOVE_INPUT (1<<0) /* Flush input queues */
379 #define SNDRV_SEQ_REMOVE_OUTPUT (1<<1) /* Flush output queues */
480 unsigned locked:1; /* timing queue locked for other queues */
|
| /external/vulkan-validation-layers/layers/ |
| swapchain.h | 281 unordered_map<VkQueue, SwpQueue *> queues; member in struct:_SwpDevice
|
| /hardware/qcom/msm8996/kernel-headers/sound/ |
| asequencer.h | 235 int queues; member in struct:snd_seq_system_info
|
| /hardware/qcom/msm8996/original-kernel-headers/sound/ |
| asequencer.h | 170 #define SNDRV_SEQ_ADDRESS_BROADCAST 255 /* send event to all queues/clients/ports/channels */
311 int queues; /* maximum queues count */ member in struct:snd_seq_system_info
316 int cur_queues; /* current queues */
377 #define SNDRV_SEQ_REMOVE_INPUT (1<<0) /* Flush input queues */
378 #define SNDRV_SEQ_REMOVE_OUTPUT (1<<1) /* Flush output queues */
479 unsigned locked:1; /* timing queue locked for other queues */
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.11-4.8/sysroot/usr/include/sound/ |
| asequencer.h | 170 #define SNDRV_SEQ_ADDRESS_BROADCAST 255 /* send event to all queues/clients/ports/channels */
311 int queues; /* maximum queues count */ member in struct:snd_seq_system_info
316 int cur_queues; /* current queues */
377 #define SNDRV_SEQ_REMOVE_INPUT (1<<0) /* Flush input queues */
378 #define SNDRV_SEQ_REMOVE_OUTPUT (1<<1) /* Flush output queues */
479 unsigned locked:1; /* timing queue locked for other queues */
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.15-4.8/sysroot/usr/include/sound/ |
| asequencer.h | 170 #define SNDRV_SEQ_ADDRESS_BROADCAST 255 /* send event to all queues/clients/ports/channels */
311 int queues; /* maximum queues count */ member in struct:snd_seq_system_info
316 int cur_queues; /* current queues */
377 #define SNDRV_SEQ_REMOVE_INPUT (1<<0) /* Flush input queues */
378 #define SNDRV_SEQ_REMOVE_OUTPUT (1<<1) /* Flush output queues */
479 unsigned locked:1; /* timing queue locked for other queues */
|
| /device/lge/bullhead/ |
| init.bullhead.power.sh | 111 write /sys/class/net/rmnet_ipa0/queues/rx-0/rps_cpus 8
|
| /external/chromium-trace/catapult/third_party/gsutil/gslib/ |
| command.py | 130 # We will keep this list of all thread- or process-safe queues ever created by
132 # we encounter a Python bug in which empty queues block forever on join (which
136 queues = [] variable
141 queues.append(queue)
147 queues.append(queue)
214 # List of all existing task queues - used by all pools to find the queue
[all...] |
