Home
last modified time | relevance | path

Searched refs:responses (Results 1 – 25 of 330) sorted by relevance

12345678910>>...14

/external/tensorflow/tensorflow/core/profiler/rpc/client/
Dremote_profiler_session_manager_test.cc85 std::vector<Response> responses = sessions->WaitForCompletion(); in TEST() local
87 ASSERT_EQ(responses.size(), 1); in TEST()
88 EXPECT_TRUE(responses.back().status.ok()); in TEST()
89 EXPECT_TRUE(responses.back().profile_response->empty_trace()); in TEST()
90 EXPECT_EQ(responses.back().profile_response->tool_data_size(), 0); in TEST()
118 std::vector<Response> responses = sessions->WaitForCompletion(); in TEST() local
121 ASSERT_EQ(responses.size(), 1); in TEST()
122 EXPECT_TRUE(errors::IsDeadlineExceeded(responses.back().status)); in TEST()
123 EXPECT_TRUE(responses.back().profile_response->empty_trace()); in TEST()
124 EXPECT_EQ(responses.back().profile_response->tool_data_size(), 0); in TEST()
[all …]
/external/bouncycastle/bcprov/src/main/java/org/bouncycastle/asn1/ocsp/
DResponseData.java36 private ASN1Sequence responses; field in ResponseData
43 ASN1Sequence responses, in ResponseData() argument
49 this.responses = responses; in ResponseData()
63 ASN1Sequence responses, in ResponseData() argument
66 …this(V1, responderID, ASN1GeneralizedTime.getInstance(producedAt), responses, Extensions.getInstan… in ResponseData()
72 ASN1Sequence responses, in ResponseData() argument
75 this(V1, responderID, producedAt, responses, responseExtensions); in ResponseData()
106 this.responses = (ASN1Sequence)seq.getObjectAt(index++); in ResponseData()
154 return responses; in getResponses()
184 v.add(responses); in toASN1Primitive()
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/
D_python_plugin_test.py35 import tests.protoc_plugin.protos.responses.test_responses_pb2 as response_pb2
109 responses = []
116 responses.append(response)
117 for response in responses:
307 responses = service.stub.StreamingOutputCall(request)
311 expected_responses, responses):
319 responses = service.stub.StreamingOutputCall(
322 list(responses)
330 responses = service.stub.StreamingOutputCall(request)
331 next(responses)
[all …]
Dbeta_python_plugin_test.py177 responses = []
184 responses.append(response)
185 for response in responses:
432 responses = stub.StreamingOutputCall(request,
437 expected_responses, responses):
447 responses = stub.StreamingOutputCall(
450 list(responses)
458 responses = stub.StreamingOutputCall(request,
460 next(responses)
461 responses.cancel()
[all …]
/external/bouncycastle/repackaged_platform/bcprov/src/main/java/com/android/internal/org/bouncycastle/asn1/ocsp/
DResponseData.java38 private ASN1Sequence responses; field in ResponseData
45 ASN1Sequence responses, in ResponseData() argument
51 this.responses = responses; in ResponseData()
65 ASN1Sequence responses, in ResponseData() argument
68 …this(V1, responderID, ASN1GeneralizedTime.getInstance(producedAt), responses, Extensions.getInstan… in ResponseData()
74 ASN1Sequence responses, in ResponseData() argument
77 this(V1, responderID, producedAt, responses, responseExtensions); in ResponseData()
108 this.responses = (ASN1Sequence)seq.getObjectAt(index++); in ResponseData()
156 return responses; in getResponses()
186 v.add(responses); in toASN1Primitive()
/external/pigweed/pw_metric/
Dmetric_service_nanopb_test.cc39 EXPECT_EQ(0u, context.responses().size()); in TEST()
58 EXPECT_EQ(1u, context.responses().size()); in TEST()
59 EXPECT_EQ(5, context.responses()[0].metrics_count); in TEST()
83 EXPECT_EQ(1u, context.responses().size()); in TEST()
84 EXPECT_EQ(6, context.responses()[0].metrics_count); in TEST()
118 EXPECT_EQ(2u, context.responses().size()); in TEST()
119 EXPECT_EQ(10, context.responses()[0].metrics_count); in TEST()
120 EXPECT_EQ(2, context.responses()[1].metrics_count); in TEST()
124 for (const auto& response : context.responses()) { in TEST()
177 EXPECT_EQ(1u, context.responses().size()); in TEST()
[all …]
/external/pigweed/pw_rpc/nanopb/
Dcodegen_test.cc77 EXPECT_TRUE(context.responses().empty()); in TEST()
82 ASSERT_EQ(4u, context.responses().size()); in TEST()
85 for (size_t i = 0; i < context.responses().size(); ++i) { in TEST()
86 EXPECT_EQ(context.responses()[i].number, i); in TEST()
96 ASSERT_EQ(3u, context.responses().max_size()); in TEST()
100 ASSERT_EQ(3u, context.responses().size()); in TEST()
103 EXPECT_EQ(context.responses()[0].number, 0u); in TEST()
104 EXPECT_EQ(context.responses()[1].number, 1u); in TEST()
105 EXPECT_EQ(context.responses()[2].number, 4u); in TEST()
111 ASSERT_EQ(3u, context.responses().max_size()); in TEST()
[all …]
/external/llvm-project/lldb/third_party/Python/module/pexpect-4.6/pexpect/
Drun.py103 responses = [y for x,y in events]
106 responses = list(events.values())
110 responses = None
122 if isinstance(responses[index], child.allowed_string_types):
123 child.send(responses[index])
124 elif (isinstance(responses[index], types.FunctionType) or
125 isinstance(responses[index], types.MethodType)):
126 callback_result = responses[index](locals())
135 .format(index=index, value=responses[index]))
/external/grpc-grpc/src/python/grpcio_tests/tests/reflection/
D_reflection_servicer_test.py69 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
83 self.assertSequenceEqual(expected_responses, responses)
93 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
107 self.assertSequenceEqual(expected_responses, responses)
122 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
136 self.assertSequenceEqual(expected_responses, responses)
146 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
161 self.assertSequenceEqual(expected_responses, responses)
165 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
172 self.assertSequenceEqual(expected_responses, responses)
/external/skqp/experimental/canvaskit/perf/
Danimation.bench.js63 Promise.all(promises).then((responses) => {
66 jsonStr = responses[0];
94 Promise.all(promises).then((responses) => {
97 jsonStr = responses[0];
120 Promise.all(promises).then((responses) => {
123 jsonStr = responses[0];
155 Promise.all(promises).then((responses) => {
158 jsonStr = responses[0];
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/
DRecordingOkAuthenticator.java26 public final List<Response> responses = new ArrayList<>(); field in RecordingOkAuthenticator
35 if (responses.size() != 1) throw new IllegalStateException(); in onlyResponse()
36 return responses.get(0); in onlyResponse()
45 responses.add(response); in authenticate()
53 responses.add(response); in authenticateProxy()
/external/pigweed/pw_rpc/nanopb/public/pw_rpc/
Dnanopb_test_method_context.h94 Vector<Response>& responses, in MessageOutput() argument
98 responses_(responses), in MessageOutput()
138 responses, in InvocationContext()
153 Vector<Response, kMaxResponse> responses; member
178 ctx_.responses.emplace_back(); in call()
179 ctx_.responses.back() = {}; in call()
181 ctx_.call, request, ctx_.responses.back()); in call()
186 PW_ASSERT(ctx_.responses.size() > 0u); in response()
187 return ctx_.responses.back(); in response()
231 const Vector<Response>& responses() const { return ctx_.responses; } in responses() function
/external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/
DShadowTypedArrayTest.java128 .addAttribute(R.attr.responses, "@array/greetings") in getTextArray_shouldReturnValues()
130 new int[]{R.attr.responses}); in getTextArray_shouldReturnValues()
137 .addAttribute(R.attr.responses, "@array/greetings") in hasValue_withValue()
139 new int[]{R.attr.responses}); in hasValue_withValue()
146 new int[]{R.attr.responses}); in hasValue_withoutValue()
153 .addAttribute(R.attr.responses, AttributeResource.NULL_VALUE) in hasValue_withNullValue()
155 new int[]{R.attr.responses}); in hasValue_withNullValue()
162 .addAttribute(R.attr.responses, "@array/greetings") in shouldEnumeratePresentValues()
165 new int[]{R.attr.scrollBars, R.attr.responses, R.attr.isSugary}); in shouldEnumeratePresentValues()
/external/grpc-grpc/src/ruby/spec/generic/
Dclient_interceptors_spec.rb93 responses = stub.a_server_streaming_rpc(request)
94 responses.each do |r|
110 responses = stub.a_server_streaming_rpc(request)
111 responses.each do |r|
128 responses = stub.a_bidi_rpc(requests)
129 responses.each do |r|
145 responses = stub.a_bidi_rpc(requests)
146 responses.each do |r|
Dserver_interceptors_spec.rb111 responses = stub.a_server_streaming_rpc(request)
112 responses.each do |r|
129 responses = op.execute
130 responses.each do |r|
151 responses = stub.a_bidi_rpc(requests)
152 responses.each do |r|
169 responses = op.execute
170 responses.each do |r|
/external/crosvm/devices/src/virtio/video/
Dasync_cmd_desc_map.rs40 let mut responses = vec![]; in create_cancellation_responses() localVariable
50 responses.push(AsyncCmdResponse::from_response( in create_cancellation_responses()
62 responses.push(AsyncCmdResponse::from_error( in create_cancellation_responses()
75 responses.push(AsyncCmdResponse::from_error( in create_cancellation_responses()
85 responses in create_cancellation_responses()
Dworker.rs40 responses: &mut VecDeque<WritableResp>, in write_responses()
42 if responses.is_empty() { in write_responses()
45 while let Some((desc, response)) = responses.pop_front() { in write_responses()
87 let mut responses: VecDeque<WritableResp> = Default::default(); in write_event_responses() localVariable
104 responses.push_back((desc, cmd_response)) in write_event_responses()
127 if let Err(e) = self.write_responses(cmd_queue, &mut responses) { in write_event_responses()
154 let mut responses: VecDeque<WritableResp> = Default::default(); in handle_command_desc() localVariable
196 responses.push_back((destroy_desc, destroy_response)); in handle_command_desc()
207 responses.push_back((desc, r)); in handle_command_desc()
226 Ok(responses) in handle_command_desc()
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
DRecordingCallback.java30 private final List<RecordedResponse> responses = new ArrayList<>(); field in RecordingCallback
33 responses.add(new RecordedResponse(request, null, null, null, e)); in onFailure()
39 responses.add(new RecordedResponse(response.request(), response, null, body, null)); in onResponse()
50 for (Iterator<RecordedResponse> i = responses.iterator(); i.hasNext(); ) { in await()
67 for (RecordedResponse recordedResponse : responses) { in assertNoResponse()
/external/dagger2/javatests/dagger/grpc/functional/server/
DBaristaTest.java52 private final List<CoffeeResponse> responses = new ArrayList<>(); field in BaristaTest.CoffeeResponseObserver
54 List<CoffeeResponse> responses() { in responses() method in BaristaTest.CoffeeResponseObserver
56 return responses; in responses()
61 responses.add(value); in onNext()
108 assertThat(responseObserver.responses()) in testUnaryGetCoffee()
120 assertThat(responseObserver.responses()) in testClientStreamingGetCoffee()
127 assertThat(responseObserver.responses()) in testServerStreamingGetCoffee()
140 assertThat(responseObserver.responses()) in testBidiStreamingGetCoffee()
/external/pigweed/pw_rpc/raw/public/pw_rpc/
Draw_test_method_context.h97 MessageOutput(Vector<ByteSpan>& responses, in MessageOutput() argument
101 responses_(responses), in MessageOutput()
143 : output(responses, buffers, packet_buffer), in InvocationContext()
158 Vector<ByteSpan, kMaxResponse> responses; member
183 ctx_.responses.emplace_back(); in call()
184 auto& response = ctx_.responses.back(); in call()
193 PW_ASSERT(ctx_.responses.size() > 0u); in response()
194 return ctx_.responses.back(); in response()
235 const Vector<ByteSpan>& responses() const { return ctx_.responses; } in responses() function
/external/boringssl/src/util/fipstools/acvp/acvptool/testmodulewrapper/
Dtestmodulewrapper.go122 func reply(responses ...[]byte) error {
123 if len(responses) > maxArgs {
124 return fmt.Errorf("%d responses is too many", len(responses))
128 binary.LittleEndian.PutUint32(lengths[:4], uint32(len(responses)))
129 for i, response := range responses {
133 lengthsLength := (1 + len(responses)) * 4
138 for _, response := range responses {
/external/grpc-grpc/src/csharp/Grpc.Examples.Tests/
DMathClientServerTests.cs97 var responses = await call.ResponseStream.ToListAsync(); in Fib()
99 responses.Select((n) => n.Num_)); in Fib()
110 List<long> responses = new List<long>(); in FibWithCancel()
116 if (responses.Count == 0) in FibWithCancel()
120 responses.Add(call.ResponseStream.Current.Num_); in FibWithCancel()
126 Assert.IsTrue(responses.Count > 0); in FibWithCancel()
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/protos/service/
Dtest_service.proto18 import "tests/protoc_plugin/protos/responses/test_responses.proto";
27 // One request followed by a sequence of responses (streamed download).
38 // As one request could lead to multiple responses, this interface
43 // A sequence of requests followed by a sequence of responses.
45 // stream of responses are returned to the client when the server starts with
/external/grpc-grpc/src/ruby/spec/
Dclient_auth_spec.rb118 responses = @stub.a_server_streaming_rpc(EchoMsg.new)
119 responses.each { |r| GRPC.logger.info(r) }
123 responses = @stub.a_bidi_rpc([EchoMsg.new, EchoMsg.new])
124 responses.each { |r| GRPC.logger.info(r) }
/external/grpc-grpc/src/objective-c/tests/RemoteTestClient/
Dtest.proto16 // of unary/streaming requests/responses.
35 // One request followed by a sequence of responses (streamed download).
46 // As one request could lead to multiple responses, this interface
51 // A sequence of requests followed by a sequence of responses.
53 // stream of responses are returned to the client when the server starts with

12345678910>>...14