| /external/tensorflow/tensorflow/core/lib/gtl/ |
| priority_queue_util.h | 20 #include <queue>
|
| /hardware/intel/common/wrs_omxil_core/base/inc/ |
| portbase.h | 28 #include <queue.h>
157 struct queue bufferq;
161 struct queue retainedbufferq;
164 struct queue markq;
|
| /hardware/interfaces/automotive/vehicle/2.0/default/common/include/vhal_v2_0/ |
| ConcurrentQueue.h | 20 #include <queue>
63 /* Deactivates the queue, thus no one can push items to it, also
84 std::queue<T> mQueue;
105 void run(ConcurrentQueue<T>* queue,
108 mQueue = queue;
|
| /hardware/interfaces/broadcastradio/common/utils/include/broadcastradio-utils/ |
| WorkerThread.h | 20 #include <queue>
|
| /packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/ |
| RecordingSampleBuffer.java | 203 private boolean maybeReadSample(SampleQueue queue, int index) {
204 if (queue.getLastQueuedPositionUs() != null
205 && queue.getLastQueuedPositionUs() > mCurrentPlaybackPositionUs + BUFFER_NEEDED_US
206 && queue.isDurationGreaterThan(MIN_SEEK_DURATION_US)) {
208 // If the duration of the samples in the queue is not limited,
216 queue.queueSample(sample);
274 SampleQueue queue = mReadSampleQueues.get(i); local
275 maybeReadSample(queue, i);
276 if (queue.getLastQueuedPositionUs() == null
277 || positionUs > queue.getLastQueuedPositionUs())
[all...] |
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/containers/container.adaptors/priority.queue/priqueue.cons/ |
| assign_copy.pass.cpp | 10 // <queue>
14 #include <queue>
|
| assign_move.pass.cpp | 12 // <queue>
16 #include <queue>
|
| ctor_copy.pass.cpp | 10 // <queue>
14 #include <queue>
|
| ctor_move.pass.cpp | 12 // <queue>
16 #include <queue>
|
| /tools/test/connectivity/acts/tests/google/bt/test_tools/ |
| EnergyTest.py | 20 from queue import Empty
|
| /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/deqp/external/vulkancts/modules/vulkan/draw/ |
| vktDrawImageObjectUtil.hpp | 73 tcu::ConstPixelBufferAccess readSurface (vk::VkQueue queue,
83 tcu::ConstPixelBufferAccess readSurface1D (vk::VkQueue queue,
92 tcu::ConstPixelBufferAccess readVolume (vk::VkQueue queue,
111 void read (vk::VkQueue queue,
124 void readUsingBuffer (vk::VkQueue queue,
146 vk::VkQueue queue,
155 vk::VkQueue queue,
164 vk::VkQueue queue,
181 void upload (vk::VkQueue queue,
194 void uploadUsingBuffer (vk::VkQueue queue,
[all...] |
| /external/linux-kselftest/tools/testing/selftests/mqueue/ |
| mq_open_tests.c | 18 * open a posix message queue and then reports whether or not they
40 " path Path name of the message queue to create\n"
56 mqd_t queue = -1; variable
87 if (queue != -1)
88 if (mq_close(queue))
155 printf("Current rlimit value for POSIX message queue bytes is "
166 printf("Temporarily lowering default queue parameters "
178 printf("Temporarily lowering maximum queue parameters "
182 "queue parameters to the maximum queue "
[all...] |
| /external/llvm/utils/lit/lit/ |
| run.py | 6 import Queue as queue
8 import queue
50 # Create a shared queue to provide the test indices.
51 self.queue = queue_impl()
55 self.queue.put(i)
57 self.queue.put(None)
68 return self.queue.get()
118 self.queue = multiprocessing.Queue()
[all...] |
| /device/google/cuttlefish_common/common/vsoc/shm/ |
| socket_forward_layout.h | 36 // If both are closed then the queue goes back to INACTIVE
42 struct Queue {
46 CircularPacketQueue<16, kMaxPacketSize> queue; member in struct:vsoc::layout::socket_forward::Queue
51 return queue.Recover();
54 ASSERT_SHM_COMPATIBLE(Queue);
57 static constexpr size_t layout_size = 2 * Queue::layout_size + 8;
60 Queue host_to_guest;
62 Queue guest_to_host;
|
| /external/autotest/site_utils/ |
| job_overhead.py | 56 metadata_reporter.queue(metadata)
81 metadata_reporter.queue(metadata)
|
| /external/deqp/external/vulkancts/modules/vulkan/sparse_resources/ |
| vktSparseResourcesBase.cpp | 64 typedef std::map<vk::VkQueueFlags, std::vector<Queue> > QueuesMap;
108 TCU_THROW(ResourceError, "Device reports an empty set of queue family properties");
116 TCU_THROW(ResourceError, "Device reports an empty set of queue family properties");
133 TCU_THROW(NotSupportedError, "No match found for queue requirements");
141 Queue queue; local
142 queue.queueFamilyIndex = queueFamilyIndex;
143 queue.queueIndex = queueNdx;
145 m_queues[queueRequirement.queueFlags].push_back(queue);
197 Queue& queue = queuesIter->second[queueNdx] local
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| vktSynchronizationBasicFenceTests.cpp | 47 const VkQueue queue = context.getUniversalQueue(); local
83 VK_CHECK(vk.queueSubmit(queue, 1u, &submitInfo, *fence));
105 const VkQueue queue = context.getUniversalQueue(); local
141 VK_CHECK(vk.queueSubmit(queue, 1u, &submitInfo, fence[FISRT_FENCE]));
149 VK_CHECK(vk.queueSubmit(queue, 1u, &submitInfo, fence[FISRT_FENCE]));
154 VK_CHECK(vk.queueSubmit(queue, 1u, &submitInfo, fence[SECOND_FENCE]));
166 const VkQueue queue = context.getUniversalQueue(); local
175 VK_CHECK(vk.queueSubmit(queue, 0u, DE_NULL, *fence));
190 addFunctionCase(basicFenceTests.get(), "empty_submit", "Signal a fence after an empty queue submission", emptySubmitCase);
|
| /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/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_notify/ |
| 1-1.c | 13 * message queue. The notification will be sent to the process when
14 * the message queue transitions from empty to non-empty.
46 void mqclean(mqd_t queue, const char *qname)
48 mq_close(queue);
|
| 2-1.c | 11 * Only one process may be registerd for notification by a message queue.
13 * notification, subsequent attempts to register for that message queue
36 void mqclean(mqd_t queue, const char *qname)
38 mq_close(queue);
|
| 3-1.c | 12 * for notification by the specified message queue, the existing registration
46 void mqclean(mqd_t queue, const char *qname)
48 mq_close(queue);
|
| 4-1.c | 12 * will be removed, then, the message queue will be available for
43 void mqclean(mqd_t queue, const char *qname)
45 mq_close(queue);
|
| 9-1.c | 12 * notification by the message queue.
35 void mqclean(mqd_t queue, const char *qname)
37 mq_close(queue);
|
| /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;
|
