| /external/scapy/test/contrib/automotive/obd/ |
| D | scanner.uts | 25 responses = [
26 …EcuResponse(responses=OBD(service=65)/OBD_S01_PR(data_records=[OBD_S01_PR_Record(pid=0)/OBD_PID00(…
27 …EcuResponse(responses=OBD(service=65)/OBD_S01_PR(data_records=[OBD_S01_PR_Record(pid=1)/OBD_PID01(…
28 …EcuResponse(responses=OBD(service=65)/OBD_S01_PR(data_records=[OBD_S01_PR_Record(pid=11)/OBD_PID0B…
29 …EcuResponse(responses=OBD(service=65)/OBD_S01_PR(data_records=[OBD_S01_PR_Record(pid=12)/OBD_PID0C…
30 …EcuResponse(responses=OBD(service=65)/OBD_S01_PR(data_records=[OBD_S01_PR_Record(pid=13)/OBD_PID0D…
31 …EcuResponse(responses=OBD(service=65)/OBD_S01_PR(data_records=[OBD_S01_PR_Record(pid=14)/OBD_PID0E…
32 …EcuResponse(responses=OBD(service=65)/OBD_S01_PR(data_records=[OBD_S01_PR_Record(pid=15)/OBD_PID0F…
33 …EcuResponse(responses=OBD(service=65)/OBD_S01_PR(data_records=[OBD_S01_PR_Record(pid=17)/OBD_PID11…
34 …EcuResponse(responses=OBD(service=65)/OBD_S01_PR(data_records=[OBD_S01_PR_Record(pid=19)/OBD_PID13…
[all …]
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
| D | HealthStatusManagerTest.java | 73 assertThat(obs.responses).hasSize(2); in enterTerminalState_check()
74 HealthCheckResponse resp = (HealthCheckResponse) obs.responses.poll(); in enterTerminalState_check()
80 assertThat(obs.responses).hasSize(2); in enterTerminalState_check()
81 resp = (HealthCheckResponse) obs.responses.poll(); in enterTerminalState_check()
87 assertThat(obs.responses).hasSize(2); in enterTerminalState_check()
88 resp = (HealthCheckResponse) obs.responses.poll(); in enterTerminalState_check()
97 assertThat(obs.responses).hasSize(1); in enterTerminalState_watch()
98 HealthCheckResponse resp = (HealthCheckResponse) obs.responses.poll(); in enterTerminalState_watch()
100 obs.responses.clear(); in enterTerminalState_watch()
103 assertThat(obs.responses).hasSize(1); in enterTerminalState_watch()
[all …]
|
| /external/pigweed/pw_rpc/ts/ |
| D | call_test.ts | 56 it('getResponse returns all responses.', async () => {
61 // Queue three responses
66 let responses = call.getResponses(2); variable
67 expect((await responses.next()).value).toEqual(message1);
68 expect((await responses.next()).value).toEqual(message2);
69 expect((await responses.next()).done).toEqual(true);
71 responses = call.getResponses(1);
72 expect((await responses.next()).value).toEqual(message3);
73 expect((await responses.next()).done).toEqual(true);
78 const responses = call.getResponses(2); constant
[all …]
|
| D | call.ts | 51 class Responses { class
52 private responses: Message[] = []; property in Responses
65 this.responses[this.totalResponses % this.maxResponses] = response;
75 return this.responses[lastIndex];
80 return this.responses.slice(0, this.totalResponses);
84 return this.responses
86 .concat(this.responses.slice(0, splitIndex));
92 // Responses ordered by arrival time. Undefined signifies stream completion.
94 protected responses: Responses; property in Call
118 this.responses = new Responses(maxResponses);
[all …]
|
| /external/python/python-api-core/tests/unit/ |
| D | test_rest_streaming.py | 59 responses: List[proto.Message],
64 self._responses = responses
88 responses = [EchoResponse(content="hello world"), EchoResponse(content="yes")]
91 responses = [
97 responses=responses, random_split=random_split, response_cls=response_type
100 assert list(itr) == responses
115 responses = [
123 responses = [
134 responses=responses, random_split=random_split, response_cls=response_type
137 assert list(itr) == responses
[all …]
|
| D | test_extended_operation.py | 63 def make_extended_operation(responses=None): argument
64 client_operations_responses = responses or [
71 refresh.responses = client_operations_responses
84 assert ex_op._extended_operation == refresh.responses[0]
94 responses = [
109 ex_op, refresh, _ = make_extended_operation(responses)
127 responses = [
136 ex_op, _, cancel = make_extended_operation(responses)
153 responses = [
162 ex_op, refresh, _ = make_extended_operation(responses)
[all …]
|
| /external/python/python-api-core/tests/asyncio/ |
| D | test_rest_streaming_async.py | 85 responses: List[proto.Message],
89 self._responses = responses
126 responses = [EchoResponse(content="hello world"), EchoResponse(content="yes")]
129 responses = [
135 responses=responses, random_split=random_split, response_cls=response_type
140 assert response == responses[idx]
157 responses = [
165 responses = [
176 responses=responses, random_split=random_split, response_cls=response_type
181 assert response == responses[idx]
[all …]
|
| /external/aws-sdk-java-v2/test/service-test-utils/src/main/java/software/amazon/awssdk/testutils/service/http/ |
| D | MockSyncHttpClient.java | 39 private final List<Pair<HttpExecuteResponse, Duration>> responses = new LinkedList<>(); field in MockSyncHttpClient
50 responses.get(responseIndex.getAndIncrement() % responses.size()); in prepareRequest()
61 throw new IllegalStateException("No responses remain."); in prepareRequest()
81 this.responses.clear();
87 this.responses.clear();
88 this.responses.add(Pair.of(nextResponse, DEFAULT_DURATION));
94 this.responses.add(Pair.of(nextResponse, delay));
99 public void stubResponses(Pair<HttpExecuteResponse, Duration>... responses) {
100 this.responses.clear();
101 this.responses.addAll(Arrays.asList(responses));
[all …]
|
| /external/pigweed/pw_metric/ |
| D | metric_service_pwpb_test.cc | 90 EXPECT_EQ(0u, ctx.responses().size()); in TEST()
107 EXPECT_EQ(1u, ctx.responses().size()); in TEST()
110 EXPECT_EQ(3u, GetMetricsSum(ctx.responses()[0])); in TEST()
131 EXPECT_EQ(2u, ctx.responses().size()); in TEST()
132 EXPECT_EQ(3u, CountEncodedMetrics(ctx.responses()[0])); in TEST()
133 EXPECT_EQ(2u, CountEncodedMetrics(ctx.responses()[1])); in TEST()
138 GetMetricsSum(ctx.responses()[0]) + GetMetricsSum(ctx.responses()[1])); in TEST()
163 EXPECT_EQ(2u, ctx.responses().size()); in TEST()
164 EXPECT_EQ(3u, CountEncodedMetrics(ctx.responses()[0])); in TEST()
165 EXPECT_EQ(2u, CountEncodedMetrics(ctx.responses()[1])); in TEST()
[all …]
|
| /external/bouncycastle/bcprov/src/main/java/org/bouncycastle/asn1/ocsp/ |
| D | ResponseData.java | 22 * responses SEQUENCE OF SingleResponse,
36 private ASN1Sequence responses; field in ResponseData
43 ASN1Sequence responses, in ResponseData() argument
49 this.responses = responses; in ResponseData()
57 * @param responses
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()
[all …]
|
| /external/google-cloud-java/java-containeranalysis/google-cloud-containeranalysis/src/test/java/com/google/cloud/devtools/containeranalysis/v1beta1/ |
| D | MockGrafeasV1Beta1Impl.java | 55 private Queue<Object> responses; field in MockGrafeasV1Beta1Impl
59 responses = new LinkedList<>(); in MockGrafeasV1Beta1Impl()
67 responses.add(response); in addResponse()
70 public void setResponses(List<AbstractMessage> responses) { in setResponses() argument
71 this.responses = new LinkedList<Object>(responses); in setResponses()
75 responses.add(exception); in addException()
80 responses = new LinkedList<>(); in reset()
86 Object response = responses.remove(); in getOccurrence()
101 Object response = responses.remove(); in listOccurrences()
116 Object response = responses.remove(); in deleteOccurrence()
[all …]
|
| D | MockContainerAnalysisV1Beta1Impl.java | 41 private Queue<Object> responses; field in MockContainerAnalysisV1Beta1Impl
45 responses = new LinkedList<>(); in MockContainerAnalysisV1Beta1Impl()
53 responses.add(response); in addResponse()
56 public void setResponses(List<AbstractMessage> responses) { in setResponses() argument
57 this.responses = new LinkedList<Object>(responses); in setResponses()
61 responses.add(exception); in addException()
66 responses = new LinkedList<>(); in reset()
71 Object response = responses.remove(); in setIamPolicy()
85 Object response = responses.remove(); in getIamPolicy()
101 Object response = responses.remove(); in testIamPermissions()
[all …]
|
| /external/bouncycastle/repackaged/bcprov/src/main/java/com/android/org/bouncycastle/asn1/ocsp/ |
| D | ResponseData.java | 23 * responses SEQUENCE OF SingleResponse,
38 private ASN1Sequence responses; field in ResponseData
45 ASN1Sequence responses, in ResponseData() argument
51 this.responses = responses; in ResponseData()
59 * @param responses
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()
[all …]
|
| /external/bouncycastle/repackaged_platform/bcprov/src/main/java/com/android/internal/org/bouncycastle/asn1/ocsp/ |
| D | ResponseData.java | 23 * responses SEQUENCE OF SingleResponse,
38 private ASN1Sequence responses; field in ResponseData
45 ASN1Sequence responses, in ResponseData() argument
51 this.responses = responses; in ResponseData()
59 * @param responses
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()
[all …]
|
| /external/google-cloud-java/java-security-private-ca/google-cloud-security-private-ca/src/test/java/com/google/cloud/security/privateca/v1/ |
| D | MockCertificateAuthorityServiceImpl.java | 34 private Queue<Object> responses; field in MockCertificateAuthorityServiceImpl
38 responses = new LinkedList<>(); in MockCertificateAuthorityServiceImpl()
46 responses.add(response); in addResponse()
49 public void setResponses(List<AbstractMessage> responses) { in setResponses() argument
50 this.responses = new LinkedList<Object>(responses); in setResponses()
54 responses.add(exception); in addException()
59 responses = new LinkedList<>(); in reset()
65 Object response = responses.poll(); in createCertificate()
86 Object response = responses.poll(); in getCertificate()
107 Object response = responses.poll(); in listCertificates()
[all …]
|
| /external/google-cloud-java/java-aiplatform/google-cloud-aiplatform/src/test/java/com/google/cloud/aiplatform/v1beta1/ |
| D | MockTensorboardServiceImpl.java | 34 private Queue<Object> responses; field in MockTensorboardServiceImpl
38 responses = new LinkedList<>(); in MockTensorboardServiceImpl()
46 responses.add(response); in addResponse()
49 public void setResponses(List<AbstractMessage> responses) { in setResponses() argument
50 this.responses = new LinkedList<Object>(responses); in setResponses()
54 responses.add(exception); in addException()
59 responses = new LinkedList<>(); in reset()
65 Object response = responses.poll(); in createTensorboard()
86 Object response = responses.poll(); in getTensorboard()
108 Object response = responses.poll(); in readTensorboardUsage()
[all …]
|
| D | MockMetadataServiceImpl.java | 34 private Queue<Object> responses; field in MockMetadataServiceImpl
38 responses = new LinkedList<>(); in MockMetadataServiceImpl()
46 responses.add(response); in addResponse()
49 public void setResponses(List<AbstractMessage> responses) { in setResponses() argument
50 this.responses = new LinkedList<Object>(responses); in setResponses()
54 responses.add(exception); in addException()
59 responses = new LinkedList<>(); in reset()
65 Object response = responses.poll(); in createMetadataStore()
86 Object response = responses.poll(); in getMetadataStore()
108 Object response = responses.poll(); in listMetadataStores()
[all …]
|
| /external/google-cloud-java/java-aiplatform/google-cloud-aiplatform/src/test/java/com/google/cloud/aiplatform/v1/ |
| D | MockTensorboardServiceImpl.java | 34 private Queue<Object> responses; field in MockTensorboardServiceImpl
38 responses = new LinkedList<>(); in MockTensorboardServiceImpl()
46 responses.add(response); in addResponse()
49 public void setResponses(List<AbstractMessage> responses) { in setResponses() argument
50 this.responses = new LinkedList<Object>(responses); in setResponses()
54 responses.add(exception); in addException()
59 responses = new LinkedList<>(); in reset()
65 Object response = responses.poll(); in createTensorboard()
86 Object response = responses.poll(); in getTensorboard()
108 Object response = responses.poll(); in readTensorboardUsage()
[all …]
|
| D | MockMetadataServiceImpl.java | 34 private Queue<Object> responses; field in MockMetadataServiceImpl
38 responses = new LinkedList<>(); in MockMetadataServiceImpl()
46 responses.add(response); in addResponse()
49 public void setResponses(List<AbstractMessage> responses) { in setResponses() argument
50 this.responses = new LinkedList<Object>(responses); in setResponses()
54 responses.add(exception); in addException()
59 responses = new LinkedList<>(); in reset()
65 Object response = responses.poll(); in createMetadataStore()
86 Object response = responses.poll(); in getMetadataStore()
108 Object response = responses.poll(); in listMetadataStores()
[all …]
|
| /external/google-cloud-java/java-dataform/google-cloud-dataform/src/test/java/com/google/cloud/dataform/v1beta1/ |
| D | MockDataformImpl.java | 34 private Queue<Object> responses; field in MockDataformImpl
38 responses = new LinkedList<>(); in MockDataformImpl()
46 responses.add(response); in addResponse()
49 public void setResponses(List<AbstractMessage> responses) { in setResponses() argument
50 this.responses = new LinkedList<Object>(responses); in setResponses()
54 responses.add(exception); in addException()
59 responses = new LinkedList<>(); in reset()
65 Object response = responses.poll(); in listRepositories()
86 Object response = responses.poll(); in getRepository()
107 Object response = responses.poll(); in createRepository()
[all …]
|
| /external/google-cloud-java/java-dataform/google-cloud-dataform/src/test/java/com/google/cloud/dataform/v1alpha2/ |
| D | MockDataformImpl.java | 34 private Queue<Object> responses; field in MockDataformImpl
38 responses = new LinkedList<>(); in MockDataformImpl()
46 responses.add(response); in addResponse()
49 public void setResponses(List<AbstractMessage> responses) { in setResponses() argument
50 this.responses = new LinkedList<Object>(responses); in setResponses()
54 responses.add(exception); in addException()
59 responses = new LinkedList<>(); in reset()
65 Object response = responses.poll(); in listRepositories()
86 Object response = responses.poll(); in getRepository()
107 Object response = responses.poll(); in createRepository()
[all …]
|
| /external/scapy/test/contrib/automotive/ |
| D | ecu_am.uts | 29 …[EcuResponse([EcuState(session=1)], responses=UDS() / UDS_RDBIPR(dataIdentifier=0x1234) / Raw(b"de…
58 …[EcuResponse(EcuState(session=2), responses=UDS() / UDS_RDBIPR(dataIdentifier=2) / Raw(b"d…
59 …EcuResponse(EcuState(session=[3, 4]), responses=UDS() / UDS_RDBIPR(dataIdentifier=3) / Raw(b"de…
60 …EcuResponse(EcuState(session=[5, 6, 7]), responses=UDS() / UDS_RDBIPR(dataIdentifier=5) / Raw(b"de…
61 …EcuResponse(EcuState(session=[8, 9]), responses=UDS() / UDS_RDBIPR(dataIdentifier=9) / Raw(b"de…
104 …[EcuResponse(EcuState(session=2), responses=UDS() / UDS_RDBIPR(dataIdentifier=2) / Raw(…
105 …EcuResponse(EcuState(session=range(3,5)), responses=UDS() / UDS_RDBIPR(dataIdentifier=3) / Raw(b…
106 …EcuResponse(EcuState(session=[5,6,7]), responses=UDS() / UDS_RDBIPR(dataIdentifier=5) / Raw(b…
107 …EcuResponse(EcuState(session=9), responses=UDS() / UDS_RDBIPR(dataIdentifier=9) / Raw(b…
108 …EcuResponse([EcuState(), EcuState(session=range(0,8))], responses=UDS() / UDS_DSCPR(diagnosticSe…
[all …]
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/ |
| D | _python_plugin_test.py | 32 import tests.protoc_plugin.protos.responses.test_responses_pb2 as response_pb2
107 responses = []
114 responses.append(response)
115 for response in responses:
320 responses = service.stub.StreamingOutputCall(request)
325 expected_responses, responses
334 responses = service.stub.StreamingOutputCall(
338 list(responses)
348 responses = service.stub.StreamingOutputCall(request)
349 next(responses)
[all …]
|
| /external/google-cloud-java/java-vmmigration/google-cloud-vmmigration/src/test/java/com/google/cloud/vmmigration/v1/ |
| D | MockVmMigrationImpl.java | 34 private Queue<Object> responses; field in MockVmMigrationImpl
38 responses = new LinkedList<>(); in MockVmMigrationImpl()
46 responses.add(response); in addResponse()
49 public void setResponses(List<AbstractMessage> responses) { in setResponses() argument
50 this.responses = new LinkedList<Object>(responses); in setResponses()
54 responses.add(exception); in addException()
59 responses = new LinkedList<>(); in reset()
65 Object response = responses.poll(); in listSources()
85 Object response = responses.poll(); in getSource()
106 Object response = responses.poll(); in createSource()
[all …]
|
| /external/google-cloud-java/java-channel/google-cloud-channel/src/test/java/com/google/cloud/channel/v1/ |
| D | MockCloudChannelServiceImpl.java | 35 private Queue<Object> responses; field in MockCloudChannelServiceImpl
39 responses = new LinkedList<>(); in MockCloudChannelServiceImpl()
47 responses.add(response); in addResponse()
50 public void setResponses(List<AbstractMessage> responses) { in setResponses() argument
51 this.responses = new LinkedList<Object>(responses); in setResponses()
55 responses.add(exception); in addException()
60 responses = new LinkedList<>(); in reset()
66 Object response = responses.poll(); in listCustomers()
86 Object response = responses.poll(); in getCustomer()
108 Object response = responses.poll(); in checkCloudIdentityAccountsExist()
[all …]
|