| /external/autotest/scheduler/ |
| 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 = []
|
| 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
[all...] |
| rdb_integration_tests.py | 73 def verify_priority(request_queue, result):
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/autotest/client/cros/cellular/mbim_compliance/ |
| mbim_channel_endpoint.py | 54 request_queue,
65 @param request_queue: A process safe queue where we expect commands
77 self._request_queue = request_queue
|
| /external/ltp/testcases/kernel/device-drivers/tbio/tbio_kernel/ |
| ltp_tbio.c | 74 struct request_queue *q;
77 static int send_request(struct request_queue *q, struct bio *bio,
125 struct request_queue *q = bdev_get_queue(bdev);
292 struct request_queue *q = bdev_get_queue(bdev);
462 static void tbio_request(struct request_queue *q)
|
| /external/ltp/testcases/kernel/device-drivers/nls/ |
| nlsTest.c | 140 static void test_request(struct request_queue *q)
148 struct request_queue *queue;
|
| /external/autotest/site_utils/rpm_control_system/ |
| rpm_controller.py | 55 @var request_queue: queue used to store requested outlet state changes.
56 @var queue_lock: lock used to control access to request_queue.
102 self.request_queue = Queue.Queue()
125 Called if the request request_queue is empty.
132 if not self.request_queue.empty():
142 Callers should first request_queue up atleast one request and if this
154 while not self.request_queue.empty():
157 request = self.request_queue.get()
271 # Place in request_queue
272 self.request_queue.put(request
[all...] |
| /external/python/cpython2/Lib/idlelib/ |
| rpc.py | 120 request_queue = Queue.Queue(0) variable
193 request_queue.put((seq, (method, args, kwargs)))
397 request_queue by self.localcall(). Responses to queued requests are
401 from the request_queue is responsible for returning the correct
|
| run.py | 111 seq, request = rpc.request_queue.get(block=True, timeout=0.05)
|
| /external/python/cpython3/Lib/idlelib/ |
| rpc.py | 121 request_queue = queue.Queue(0) variable
194 request_queue.put((seq, (method, args, kwargs)))
405 request_queue by self.localcall(). Responses to queued requests are
409 from the request_queue is responsible for returning the correct
|
| run.py | 137 seq, request = rpc.request_queue.get(block=True, timeout=0.05)
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/idlelib/ |
| rpc.py | 120 request_queue = Queue.Queue(0) variable
193 request_queue.put((seq, (method, args, kwargs)))
400 request_queue by self.localcall(). Responses to queued requests are
404 from the request_queue is responsible for returning the correct
|
| run.py | 96 seq, request = rpc.request_queue.get(block=True, timeout=0.05)
|
| /prebuilts/gdb/linux-x86/lib/python2.7/idlelib/ |
| rpc.py | 120 request_queue = Queue.Queue(0) variable
193 request_queue.put((seq, (method, args, kwargs)))
400 request_queue by self.localcall(). Responses to queued requests are
404 from the request_queue is responsible for returning the correct
|
| run.py | 96 seq, request = rpc.request_queue.get(block=True, timeout=0.05)
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/idlelib/ |
| rpc.py | 120 request_queue = Queue.Queue(0) variable
193 request_queue.put((seq, (method, args, kwargs)))
400 request_queue by self.localcall(). Responses to queued requests are
404 from the request_queue is responsible for returning the correct
|
| run.py | 96 seq, request = rpc.request_queue.get(block=True, timeout=0.05)
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/idlelib/ |
| rpc.py | 120 request_queue = Queue.Queue(0) variable
193 request_queue.put((seq, (method, args, kwargs)))
400 request_queue by self.localcall(). Responses to queued requests are
404 from the request_queue is responsible for returning the correct
|
| run.py | 96 seq, request = rpc.request_queue.get(block=True, timeout=0.05)
|
