Searched refs:query_num (Results 1 – 3 of 3) sorted by relevance
| /external/autotest/client/common_lib/feedback/ |
| D | tester_feedback_client.py | 40 def _make_query_call(self, query_num, query_method, **kwargs): argument
49 return self._rpc_proxy.query_call(self._client_id, query_num,
107 def __init__(self, client, query_num): argument
110 self.query_num = query_num
115 ret, desc = self.client._make_query_call(self.query_num,
142 def __init__(self, client, query_num): argument
143 super(OutputQuery, self).__init__(client, query_num)
149 def __init__(self, client, query_num): argument
150 super(InputQuery, self).__init__(client, query_num)
|
| /external/autotest/site_utils/tester_feedback/ |
| D | feedback_delegate.py | 89 def new_query(self, client_id, query_id, query_num): argument
101 if query_num in client:
103 query_num)
105 client[query_num] = self._get_delegate_cls(query_id)(
110 def query_call(self, client_id, query_num, query_method, kwargs_dict): argument
125 query = self._get_client(client_id)[query_num]
128 (query_num, client_id))
|
| D | request_multiplexer.py | 56 if req_tuple.query_num == self._atomic_seq:
121 self._atomic_seq = (req_tuple.query_num if req_tuple.atomic
153 def process_request(self, request, query_num, atomic): argument
167 query_num, atomic))
171 def end_atomic_seq(self, query_num): argument
179 self._request_queue.put(ReqTuple(None, None, query_num, False))
|