Searched refs:request_queue (Results 1 – 9 of 9) sorted by relevance
| /external/autotest/scheduler/ |
| D | rdb_requests.py | 39 self.request_queue = []
44 self.request_queue.append(self.request(**kwargs).get_request())
56 if not self.request_queue:
60 result = self.api_call(self.request_queue)
61 requests = self.request_queue
62 self.request_queue = []
|
| D | rdb_unittest.py | 47 request = self.get_hosts_manager.request_queue[0]
68 request_1 = self.get_hosts_manager.request_queue[0]
69 request_2 = self.get_hosts_manager.request_queue[1]
108 self.handler.batch_get_hosts(self.get_hosts_manager.request_queue)
120 self.handler.update_hosts(self.update_manager.request_queue)
132 self.handler.update_hosts(self.update_manager.request_queue)
144 self.handler.update_hosts(self.update_manager.request_queue)
156 self.handler.update_hosts(self.update_manager.request_queue)
178 exception_types, self.update_manager.request_queue):
183 for request in self.update_manager.request_queue:
|
| D | rdb_integration_tests.py | 73 def verify_priority(request_queue, result): argument
74 requests = AssignmentValidator.sort_requests(request_queue)
109 result = request_manager.api_call(request_manager.request_queue)
113 request_manager.request_queue, result)
422 result = request_manager.api_call(request_manager.request_queue)
475 if any([request for request in request_manager.request_queue
486 disorderly_queue = sorted(request_manager.request_queue,
488 request_manager.request_queue = disorderly_queue
489 result = request_manager.api_call(request_manager.request_queue)
|
| /external/ltp/testcases/kernel/device-drivers/tbio/tbio_kernel/ |
| D | ltp_tbio.c | 74 struct request_queue *q;
77 static int send_request(struct request_queue *q, struct bio *bio, in send_request()
125 struct request_queue *q = bdev_get_queue(bdev); in tbio_io()
292 struct request_queue *q = bdev_get_queue(bdev); in test_bio_split()
462 static void tbio_request(struct request_queue *q) in tbio_request()
|
| /external/autotest/client/cros/cellular/mbim_compliance/ |
| D | mbim_channel_endpoint.py | 54 request_queue, argument
77 self._request_queue = request_queue
|
| /external/ltp/testcases/kernel/device-drivers/nls/ |
| D | nlsTest.c | 140 static void test_request(struct request_queue *q) in test_request()
148 struct request_queue *queue; in test_init_module()
|
| /external/autotest/site_utils/rpm_control_system/ |
| D | rpm_controller.py | 102 self.request_queue = Queue.Queue()
132 if not self.request_queue.empty():
154 while not self.request_queue.empty():
157 request = self.request_queue.get()
274 self.request_queue.put(request)
|
| /external/python/cpython2/Lib/idlelib/ |
| D | rpc.py | 120 request_queue = Queue.Queue(0) variable
193 request_queue.put((seq, (method, args, kwargs)))
|
| D | run.py | 111 seq, request = rpc.request_queue.get(block=True, timeout=0.05)
|