| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | gcs_file_system_test.cc | 55 std::vector<HttpRequest*> requests( in TEST() local
70 new FakeHttpRequestFactory(&requests)), in TEST()
102 std::vector<HttpRequest*> requests({new FakeHttpRequest( in TEST() local
113 new FakeHttpRequestFactory(&requests)), in TEST()
127 std::vector<HttpRequest*> requests( in TEST() local
155 new FakeHttpRequestFactory(&requests)), in TEST()
185 std::vector<HttpRequest*> requests({new FakeHttpRequest( in TEST() local
196 new FakeHttpRequestFactory(&requests)), in TEST()
213 std::vector<HttpRequest*> requests( in TEST() local
228 new FakeHttpRequestFactory(&requests)), in TEST()
[all …]
|
| D | google_auth_provider_test.cc | 91 std::vector<HttpRequest*> requests; in TEST_F() local
96 std::make_shared<FakeHttpRequestFactory>(&requests); in TEST_F()
128 std::vector<HttpRequest*> requests; in TEST_F() local
132 std::make_shared<FakeHttpRequestFactory>(&requests); in TEST_F()
151 std::vector<HttpRequest*> requests( in TEST_F() local
181 std::make_shared<FakeHttpRequestFactory>(&requests); in TEST_F()
223 std::vector<HttpRequest*> requests({new FakeHttpRequest( in TEST_F() local
231 std::make_shared<FakeHttpRequestFactory>(&requests); in TEST_F()
|
| D | compute_engine_zone_provider_test.cc | 30 std::vector<HttpRequest*> requests({new FakeHttpRequest( in TEST_F() local
35 auto httpRequestFactory = std::make_shared<FakeHttpRequestFactory>(&requests); in TEST_F()
51 std::vector<HttpRequest*> requests({new FakeHttpRequest( in TEST_F() local
56 auto httpRequestFactory = std::make_shared<FakeHttpRequestFactory>(&requests); in TEST_F()
|
| D | compute_engine_metadata_client_test.cc | 25 std::vector<HttpRequest*> requests({new FakeHttpRequest( in TEST() local
32 std::make_shared<FakeHttpRequestFactory>(&requests); in TEST()
46 std::vector<HttpRequest*> requests( in TEST() local
59 std::make_shared<FakeHttpRequestFactory>(&requests); in TEST()
|
| /external/grpc-grpc/src/ruby/spec/support/ |
| D | services.rb | 64 def a_bidi_rpc(requests, call) argument
66 requests.each do |r|
103 def bidi_streamer(requests:, call:, method:) argument
104 requests.each do |r|
108 " #{requests} for call #{call}")
124 def client_streamer(requests:, call:, method:, metadata: {}) argument
126 " with requests #{requests} for call #{call}" \
128 requests.each do |r|
143 def bidi_streamer(requests:, call:, method:, metadata: {}) argument
145 "with requests #{requests} for call #{call}" \
[all …]
|
| /external/glide/library/src/main/java/com/bumptech/glide/manager/ |
| D | RequestTracker.java | 19 …private final Set<Request> requests = Collections.newSetFromMap(new WeakHashMap<Request, Boolean>(… field in RequestTracker
26 requests.add(request); in runRequest()
34 requests.add(request); in addRequest()
41 requests.remove(request); in removeRequest()
56 for (Request request : requests) { in pauseRequests()
68 for (Request request : requests) { in resumeRequests()
79 for (Request request : requests) { in clearRequests()
88 for (Request request : requests) { in restartRequests()
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _rpc_test.py | 260 requests = tuple(
263 iter(requests), None)
264 request_iterator = iter(requests)
275 requests = tuple(
278 iter(requests), None)
279 request_iterator = iter(requests)
292 requests = tuple(
295 iter(requests), None)
296 request_iterator = iter(requests)
309 requests = tuple(
[all …]
|
| /external/grpc-grpc/src/ruby/spec/generic/ |
| D | client_interceptors_spec.rb | 63 requests = [EchoMsg.new, EchoMsg.new]
64 expect(stub.a_client_streaming_rpc(requests)).to be_a(EchoMsg)
74 requests = [EchoMsg.new, EchoMsg.new]
76 .with(requests, metadata: { 'foo' => 'bar_from_client_streamer' })
78 expect(stub.a_client_streaming_rpc(requests)).to be_a(EchoMsg)
127 requests = [EchoMsg.new, EchoMsg.new]
128 responses = stub.a_bidi_rpc(requests)
141 requests = [EchoMsg.new, EchoMsg.new]
143 .with(requests, metadata: { 'foo' => 'bar_from_bidi_streamer' })
145 responses = stub.a_bidi_rpc(requests)
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/reflection/ |
| D | _reflection_servicer_test.py | 63 requests = (
69 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
86 requests = (
93 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
110 requests = (
122 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
139 requests = (
146 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
164 requests = (reflection_pb2.ServerReflectionRequest(list_services='',),)
165 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
|
| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| D | client_stub.rb | 225 def client_streamer(method, requests, marshal, unmarshal, argument
238 requests: requests,
249 c.client_streamer(requests)
255 c.client_streamer(requests, metadata: metadata)
438 def bidi_streamer(method, requests, marshal, unmarshal, argument
452 requests: requests,
463 c.bidi_streamer(requests, &blk)
469 c.bidi_streamer(requests, metadata: metadata, &blk)
|
| D | interceptors.rb | 58 def client_streamer(requests: nil, call: nil, method: nil, metadata: nil)
60 " for requests #{requests} with call #{call} and metadata: #{metadata}"
86 def bidi_streamer(requests: nil, call: nil, method: nil, metadata: nil)
88 " for requests #{requests} with call #{call} and metadata: #{metadata}"
143 def bidi_streamer(requests: nil, call: nil, method: nil)
145 " for requests #{requests} with call #{call}"
|
| D | bidi_call.rb | 70 def run_on_client(requests, argument
75 write_loop(requests, set_output_stream_done: set_output_stream_done)
92 def run_on_server(gen_each_reply, requests) argument
97 replies = gen_each_reply.call(requests)
99 replies = gen_each_reply.call(requests, @req_view)
142 def write_loop(requests, is_client: true, set_output_stream_done: nil) argument
145 requests.each do |req|
|
| D | active_call.rb | 393 def client_streamer(requests, metadata: {}) argument
397 requests.each { |r| @call.run_batch(SEND_MESSAGE => @marshal.call(r)) }
494 def bidi_streamer(requests, metadata: {}, &blk) argument
516 bd.run_on_client(requests,
544 requests = bidi_call.read_next_loop(proc { set_input_stream_done }, false)
549 requests: requests
551 bidi_call.run_on_server(mth, requests)
|
| /external/python/cpython3/Doc/tutorial/ |
| D | venv.rst | 125 (tutorial-env) $ pip install requests==2.6.0
126 Collecting requests==2.6.0
127 Using cached requests-2.6.0-py2.py3-none-any.whl
128 Installing collected packages: requests
129 Successfully installed requests-2.6.0
138 (tutorial-env) $ pip install --upgrade requests
139 Collecting requests
140 Installing collected packages: requests
141 Found existing installation: requests 2.6.0
142 Uninstalling requests-2.6.0:
[all …]
|
| /external/skia/tools/skiaserve/tester/ |
| D | tester.py | 10 import requests
55 return Check(requests.get(self.url + '/info'))
62 return Check(requests.post(self.url + '/new', files=files))
66 return WriteJson(Check(requests.get(self.url + '/cmd')), path)
72 return WritePng(Check(requests.get(url)), path)
75 return Check(requests.post(self.url + '/enableGPU/1'))
78 return Check(requests.post(self.url + '/enableGPU/0'))
86 return WriteJson(Check(requests.get(self.url + '/batches')), path)
|
| /external/skqp/tools/skiaserve/tester/ |
| D | tester.py | 10 import requests
55 return Check(requests.get(self.url + '/info'))
62 return Check(requests.post(self.url + '/new', files=files))
66 return WriteJson(Check(requests.get(self.url + '/cmd')), path)
72 return WritePng(Check(requests.get(url)), path)
75 return Check(requests.post(self.url + '/enableGPU/1'))
78 return Check(requests.post(self.url + '/enableGPU/0'))
86 return WriteJson(Check(requests.get(self.url + '/batches')), path)
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowDownloadManager.java | 52 result.requests.add(request); in query()
56 result.requests.addAll(requestMap.values()); in query()
146 public List<DownloadManager.Request> requests = new ArrayList<>(); field in ShadowDownloadManager.ResultCursor
153 return requests.size(); in getCount()
165 return !requests.isEmpty(); in moveToFirst()
172 return positionIndex < requests.size(); in moveToNext()
228 ShadowRequest request = Shadow.extract(requests.get(positionIndex)); in getString()
255 ShadowRequest request = Shadow.extract(requests.get(positionIndex)); in getInt()
|
| /external/autotest/client/cros/enterprise/ |
| D | enterprise_au_context.py | 117 requests = self.get_update_requests()
118 if not requests:
122 for i in xrange(len(requests) - 1, -1, -1):
123 search = re.search(MATCH_STR, requests[i])
126 return requests[i]
|
| /external/cros/system_api/dbus/seneschal/ |
| D | seneschal_service.proto | 34 // Defines the vsock address on which a server should listen for requests.
37 // The port number on which the server should listen for requests.
44 // Defines the unix address on which a server should listen for requests.
46 // The path on the system where the server should listen for requests.
50 // Defines the network address on which a server should listen for requests.
53 // The port on which the server should listen for requests.
58 // should listen for requests.
63 // The address on which the server should listen for requests.
77 // The handle with which to refer to this server in future requests. Only
92 // Information sent back by seneschal when it receives a StopServer requests.
|
| /external/autotest/server/cros/cfm/utils/ |
| D | bond_http_api.py | 9 import requests
35 resp = requests.get(
59 resp = requests.post(
89 resp = requests.post(
137 resp = requests.post(
|
| /external/python/cpython2/Doc/library/ |
| D | docxmlrpcserver.rst | 19 requests. Servers can either be free standing, using :class:`~DocXMLRPCServer.DocXMLRPCServer`,
32 Create a new instance to handle XML-RPC requests in a CGI environment.
38 POST requests, documentation GET requests, and modifies logging so that the
50 self-documenting, stand alone XML-RPC servers. HTTP POST requests are handled as
51 XML-RPC method calls. HTTP GET requests are handled by generating pydoc-style
79 creating self-documenting, XML-RPC CGI scripts. HTTP POST requests are handled
80 as XML-RPC method calls. HTTP GET requests are handled by generating pydoc-style
|
| /external/libpcap/ |
| D | rpcap-protocol.c | 148 static const char *requests[] = variable
163 #define NUM_REQ_TYPES (sizeof requests / sizeof requests[0])
193 return requests[type]; in rpcap_msg_type_string()
|
| /external/autotest/client/cros/cellular/mbim_compliance/ |
| D | mbim_channel_unittest.py | 295 def _expect_transaction(self, requests, responses=None): argument
305 last_request = requests[len(requests) - 1]
306 earlier_requests = requests[:len(requests) - 1]
316 def _verify_transaction_successful(self, requests, responses): argument
325 self._channel.bidirectional_transaction(*requests))
329 def _verify_transaction_failed(self, requests): argument
339 *requests)
|
| /external/bcc/tests/python/ |
| D | test_trace3.c | 7 BPF_HASH(requests, struct Request, struct Time, 1024);
33 requests.update(&rq, &tm); in probe_blk_start_request()
39 struct Time *tm = requests.lookup(&rq); in probe_blk_update_request()
42 requests.delete(&rq); in probe_blk_update_request()
|
| /external/guava/guava-tests/benchmark/com/google/common/cache/ |
| D | LoadingCacheSingleThreadBenchmark.java | 48 static AtomicLong requests = new AtomicLong(0); field in LoadingCacheSingleThreadBenchmark
72 requests.set(0); in setUp()
81 requests.addAndGet(reps); in time()
98 double req = requests.get(); in tearDown()
|