| /test/vts/drivers/resource/include/fmq_driver/ |
| D | VtsFmqDriver.h | 41 // struct to store queue information.
43 // type of data in the queue.
45 // flavor of the queue (sync or unsync).
47 // pointer to the actual queue object.
51 // A fast message queue class that manages all fast message queues created
53 // into the queue.
71 // Constructor to initialize a Fast Message Queue (FMQ) manager.
80 // Creates a brand new FMQ, i.e. the "first message queue object".
82 // @param data_type type of data in the queue. This information is stored
84 // @param queue_size number of elements in the queue.
[all …]
|
| /test/vts/testcases/host/fmq_hidl_test/ |
| D | VtsHalTestsMsgqV1_0HostTest.py | 107 "Hal should configure a synchronized queue without error.")
109 # Initialize an unsynchronized queue on the server.
114 "Hal should configure an unsynchronized queue without error.")
115 # An unsynchronized queue is registered successfully on the target driver.
125 """This test operates on the synchronized queue.
154 """This test operates on the synchronized queue.
172 """This test operates on the synchronized queue.
189 """This test operates on the synchronized queue.
191 Read should fail when queue is empty.
196 "Client should fail to read because queue is empty.")
[all …]
|
| /test/vts/testcases/codelab/fmq_test/ |
| D | VtsCodelabFmqTest.py | 35 _queue1_writer: ResourceFmqMirror, writer of queue 1.
36 _queue1_reader: ResourceFmqMirror, reader of queue 1.
37 _queue2_writer: ResourceFmqMirror, writer of queue 2.
38 _queue2_reader: ResourceFmqMirror, reader of queue 2.
39 _queue3_writer: ResourceFmqMirror, writer of queue 3.
40 _queue3_reader1: ResourceFmqMirror, reader 1 of queue 3.
41 _queue3_reader2: ResourceFmqMirror, reader 2 of queue 3.
42 _queue4_writer: ResourceFmqMirror, writer of queue 4.
43 _queue4_reader: ResourceFmqMirror, reader of queue 4.
51 Queue 1: synchronized queue (without blocking) between
[all …]
|
| /test/vti/dashboard/src/main/java/com/android/vts/util/ |
| D | TaskQueueHelper.java | 16 import com.google.appengine.api.taskqueue.Queue;
23 /** TaskQueueHelper, a helper class for interacting with App Engine Task Queue API. */
29 * Add the list of tasks to the provided queue.
31 * @param queue The task queue in which to insert the tasks.
34 public static void addToQueue(Queue queue, List<TaskOptions> tasks) { in addToQueue() argument
39 queue.addAsync(puts); in addToQueue()
42 logger.log(Level.SEVERE, "Too many tasks batched in the task queue API."); in addToQueue()
47 queue.addAsync(puts); in addToQueue()
|
| /test/vti/dashboard/src/main/webapp/WEB-INF/ |
| D | queue.xml | 17 <queue-entries>
18 <queue>
22 </queue>
23 <queue>
28 </queue>
29 <queue>
34 </queue>
35 </queue-entries>
|
| /test/vts/utils/python/mirror/ |
| D | resource_mirror.py | 33 _queue_id: int, used to identify the queue object on the target side.
34 _data_type: type of data in the queue.
35 _sync: bool, whether the queue is synchronized.
47 data_type: string, type of data in the queue
49 sync: bool, whether queue is synchronized (only has one reader).
51 queue_id: int, identifies the queue on the target side.
60 """Initiate a fast message queue object on the target side.
66 queue object out of reference.
68 new queue object.
71 queue_id: int, identifies the message queue object on the target side.
[all …]
|
| D | mirror_tracker.py | 119 """Initializes a fast message queue object.
121 This method will initialize a fast message queue object on the target side,
126 This argument identifies an existing queue mirror object.
128 new message queue object based on an existing message queue.
129 If it is None, that means creating a brand new message queue.
130 new_queue_name: string, name of the new queue, used as key in the tracker.
132 data_type: string, type of data in the queue.
133 sync: bool, whether the queue is synchronized (only has one reader).
134 queue_size: int, size of the queue.
137 creating a new message queue object based on an existing message queue.
[all …]
|
| /test/vts/proto/ |
| D | VtsResourceControllerMessage.proto | 23 // Possible operations on Fast Message Queue.
53 // Get address of queue descriptor.
55 // drivers to pass queue descriptor address to identify
104 // string to represent type of data in the queue
107 // queue flavor
110 // queue id
113 // queue size
127 // store address of queue descriptor
135 // including scalar values and data read back from the queue.
137 // data read from the queue
[all …]
|
| /test/vts/drivers/resource/include/resource_manager/ |
| D | VtsResourceManager.h | 48 // Resources include fast message queue, hidl_memory, hidl_handle.
54 // // Generate some FMQ request (e.g. creating a queue.).
137 // Processes command for operations on Fast Message Queue.
148 // This message stores queue data_type, sync option, and existing
152 // @param queue_msg stores queue information, data_type, sync option,
153 // and queue descriptor address.
155 // @return queue_id assigned to the new queue object.
158 // Gets queue descriptor address specified in VariableSpecificationMessage.
159 // The message contains type of data in the queue, queue flavor,
160 // and queue id. The method calls fmq_driver to locate the address of the
[all …]
|
| /test/vts/drivers/resource/fmq_driver/ |
| D | VtsFmqDriverTest.cpp | 121 // check if the writer has a valid queue in TEST_F()
125 // check queue size on writer side in TEST_F()
131 // check queue element size on writer side in TEST_F()
143 // check if the reader has a valid queue in TEST_F()
147 // check queue size on reader side in TEST_F()
153 // check queue element size on reader side in TEST_F()
195 // Tests reading from an empty queue.
200 // attempt to read from an empty queue in TEST_F()
205 // Tests writing to a full queue.
214 // This write succeeds, filling up the queue in TEST_F()
[all …]
|
| /test/vti/test_serving/gae/ |
| D | queue.yaml | 1 queue:
2 - name: queue-schedule
11 - name: queue-indexing
|
| /test/framework/harnesses/host_controller/tradefed/ |
| D | remote_client_test.py | 18 import queue
34 _response_queue: A queue.Queue object containing the response strings.
44 self._response_queue = queue.Queue()
72 """Add a response string to the queue.
|
| /test/vti/dashboard/src/main/java/com/android/vts/job/ |
| D | VtsSuiteTestJobServlet.java | 28 import com.google.appengine.api.taskqueue.Queue;
75 public static final String QUEUE = "suiteTestQueue"; field in VtsSuiteTestJobServlet
124 logger.log(Level.INFO, "Yesterday is added to the process queue and processed!"); in doGet()
132 Queue queue = QueueFactory.getQueue(QUEUE); in doGet() local
186 TaskQueueHelper.addToQueue(queue, tasks); in doGet()
|
| D | VtsProfilingStatsJobServlet.java | 37 import com.google.appengine.api.taskqueue.Queue;
68 public static final String QUEUE = "profilingStatsQueue"; field in VtsProfilingStatsJobServlet
90 Queue queue = QueueFactory.getQueue(QUEUE); in addTasks() local
99 TaskQueueHelper.addToQueue(queue, tasks); in addTasks()
|
| D | VtsInactivityJobServlet.java | 36 import com.google.appengine.api.taskqueue.Queue;
126 Queue queue = QueueFactory.getDefaultQueue(); in doGet() local
136 TaskQueueHelper.addToQueue(queue, tasks); in doGet()
|
| D | VtsCoverageAlertJobServlet.java | 33 import com.google.appengine.api.taskqueue.Queue;
82 * @param messages The email Message queue.
278 Queue queue = QueueFactory.getDefaultQueue(); in addTask() local
280 queue.add( in addTask()
|
| D | VtsPerformanceJobServlet.java | 32 import com.google.appengine.api.taskqueue.Queue;
206 Queue queue = QueueFactory.getDefaultQueue(); in doGet() local
219 TaskQueueHelper.addToQueue(queue, tasks); in doGet()
|
| D | VtsAlertJobServlet.java | 44 import com.google.appengine.api.taskqueue.Queue;
225 * @param messages The email Message queue.
489 Queue queue = QueueFactory.getDefaultQueue(); in addTask() local
491 queue.add( in addTask()
|
| /test/vts/drivers/hal/common/include/component_loader/ |
| D | HalDriverLoader.h | 20 #include <queue>
61 // found functions to the fuzzing job queue.
112 // fuzzing job queue. Used by Process method.
113 queue<pair<FunctionSpecificationMessage*, DriverBase*>> job_queue_;
|
| /test/vti/dashboard/src/main/java/com/android/vts/entity/ |
| D | TestPlanRunEntity.java | 24 import com.google.appengine.api.taskqueue.Queue;
219 logger.log(Level.WARNING, "testRuns is null so adding task to the queue is skipped!"); in addCoverageApiTask()
221 Queue queue = QueueFactory.getQueue(QUEUE_NAME); in addCoverageApiTask() local
222 queue.add( in addCoverageApiTask()
|
| /test/vts-testcase/kernel/ltp/ |
| D | KernelLtpTest.py | 21 import queue
350 # Create a queue for thread workers to pull tasks
351 q = queue.Queue()
436 "sequential job queue.".format(id, test_case))
|
| /test/vti/test_serving/configs/infra/prod/vtslab-config-prod/ |
| D | services.cfg | 27 # Commit Queue
29 # id: "commit-queue"
|
| /test/vti/test_serving/configs/infra/test/vtslab-config-test/ |
| D | services.cfg | 27 # Commit Queue
29 # id: "commit-queue"
|
| /test/vti/test_serving/gae/webapp/src/tasks/ |
| D | indexing.py | 64 queue_name="queue-indexing",
75 """Task queue handler class to re-index ndb model."""
|
| /test/vti/test_serving/gae/webapp/src/scheduler/ |
| D | periodic.py | 49 queue_name="queue-schedule",
|