| /external/tensorflow/tensorflow/core/data/service/ |
| D | auto_shard_rewriter_test.cc | 207 WorkerIndexResolver resolver(std::vector<std::string>{"localhost"}); in TEST() local
208 EXPECT_THAT(resolver.GetWorkerIndex("localhost:12345"), in TEST()
211 TF_EXPECT_OK(resolver.ValidateWorker("localhost:12345")); in TEST()
212 resolver.AddWorker("localhost:12345"); in TEST()
213 EXPECT_THAT(resolver.GetWorkerIndex("localhost:12345"), IsOkAndHolds(0)); in TEST()
217 WorkerIndexResolver resolver(std::vector<std::string>{ in TEST() local
219 TF_EXPECT_OK(resolver.ValidateWorker("/worker/task/2:12345")); in TEST()
220 TF_EXPECT_OK(resolver.ValidateWorker("/worker/task/1:23456")); in TEST()
221 TF_EXPECT_OK(resolver.ValidateWorker("/worker/task/0:34567")); in TEST()
222 resolver.AddWorker("/worker/task/2:12345"); in TEST()
[all …]
|
| /external/libtextclassifier/native/utils/ |
| D | tflite-model-executor.cc | 109 void RegisterSelectedOps(tflite::MutableOpResolver* resolver) { in RegisterSelectedOps() argument
110 resolver->AddBuiltin(tflite::BuiltinOperator_ADD, in RegisterSelectedOps()
114 resolver->AddBuiltin(tflite::BuiltinOperator_CONCATENATION, in RegisterSelectedOps()
118 resolver->AddBuiltin(tflite::BuiltinOperator_CONV_2D, in RegisterSelectedOps()
122 resolver->AddBuiltin(tflite::BuiltinOperator_DEPTHWISE_CONV_2D, in RegisterSelectedOps()
126 resolver->AddBuiltin(tflite::BuiltinOperator_AVERAGE_POOL_2D, in RegisterSelectedOps()
130 resolver->AddBuiltin(::tflite::BuiltinOperator_EQUAL, in RegisterSelectedOps()
133 resolver->AddBuiltin(tflite::BuiltinOperator_FULLY_CONNECTED, in RegisterSelectedOps()
137 resolver->AddBuiltin(::tflite::BuiltinOperator_GREATER_EQUAL, in RegisterSelectedOps()
139 resolver->AddBuiltin(tflite::BuiltinOperator_L2_NORMALIZATION, in RegisterSelectedOps()
[all …]
|
| /external/cldr/tools/cldr-code/src/test/java/org/unicode/cldr/unittest/ |
| D | TestHelper.java | 357 VoteResolver<String> resolver = new VoteResolver<>(getTestVoterInfoList()); in TestTrunkStatus() local
358 resolver.setLocale(CLDRLocale.getInstance("de"), null); in TestTrunkStatus()
359 resolver.setBaileyValue("bailey"); in TestTrunkStatus()
360 resolver.setBaseline("new-item", Status.approved); in TestTrunkStatus()
361 assertEquals("", "new-item", resolver.getWinningValue()); in TestTrunkStatus()
371 VoteResolver<String> resolver = new VoteResolver<>(getTestVoterInfoList()); in TestVoteResolverNgombaTrunkStatus() local
372 resolver.setBaileyValue("bailey"); in TestVoteResolverNgombaTrunkStatus()
373 resolver.setLocale(CLDRLocale.getInstance("jgo"), null); in TestVoteResolverNgombaTrunkStatus()
378 resolver.setBaseline(jgo22trunk, Status.approved); // seed/jgo.xml from 22 in TestVoteResolverNgombaTrunkStatus()
381 logln(resolver.toString()); in TestVoteResolverNgombaTrunkStatus()
[all …]
|
| /external/tflite-support/tensorflow_lite_support/java/src/native/task/core/ |
| D | minimal_op_resolver.cc | 27 MutableOpResolver resolver; in CreateOpResolver() local
28 resolver.AddBuiltin(::tflite::BuiltinOperator_RESHAPE, in CreateOpResolver()
30 resolver.AddBuiltin(::tflite::BuiltinOperator_GATHER, in CreateOpResolver()
32 resolver.AddBuiltin(::tflite::BuiltinOperator_STRIDED_SLICE, in CreateOpResolver()
34 resolver.AddBuiltin(::tflite::BuiltinOperator_FULLY_CONNECTED, in CreateOpResolver()
36 resolver.AddBuiltin(::tflite::BuiltinOperator_CAST, in CreateOpResolver()
38 resolver.AddBuiltin(::tflite::BuiltinOperator_MUL, in CreateOpResolver()
40 resolver.AddBuiltin(::tflite::BuiltinOperator_ADD, in CreateOpResolver()
42 resolver.AddBuiltin(::tflite::BuiltinOperator_TRANSPOSE, in CreateOpResolver()
44 resolver.AddBuiltin(::tflite::BuiltinOperator_SPLIT, in CreateOpResolver()
[all …]
|
| /external/ksp/test-utils/src/main/kotlin/com/google/devtools/ksp/processor/ |
| D | ReplaceWithErrorTypeArgsProcessor.kt | 27 override fun process(resolver: Resolver): List<KSAnnotated> { in process()
30 resolver.getClassDeclarationByName("KS")!!, in process()
31 resolver.getClassDeclarationByName("KL")!!, in process()
32 resolver.getClassDeclarationByName("JS")!!, in process()
33 resolver.getClassDeclarationByName("JL")!!, in process()
35 resolver.getClassDeclarationByName("KS1")!!, in process()
36 resolver.getClassDeclarationByName("KL1")!!, in process()
37 resolver.getClassDeclarationByName("JS1")!!, in process()
38 resolver.getClassDeclarationByName("JL1")!!, in process()
39 resolver.getClassDeclarationByName("JSE")!!, in process()
[all …]
|
| D | BuiltInTypesProcessor.kt | 28 override fun process(resolver: Resolver): List<KSAnnotated> { in <lambda>()
29 val files = resolver.getNewFiles() in <lambda>()
37 resolver.builtIns.annotationType, in <lambda>()
38 resolver.builtIns.anyType, in <lambda>()
39 resolver.builtIns.arrayType, in <lambda>()
40 resolver.builtIns.booleanType, in <lambda>()
41 resolver.builtIns.byteType, in <lambda>()
42 resolver.builtIns.charType, in <lambda>()
43 resolver.builtIns.doubleType, in <lambda>()
44 resolver.builtIns.floatType, in <lambda>()
[all …]
|
| D | AsMemberOfProcessor.kt | 18 override fun process(resolver: Resolver): List<KSAnnotated> { in <lambda>()
19 val base = resolver.getClassDeclarationByName("Base")!! in <lambda>()
20 val child1 = resolver.getClassDeclarationByName("Child1")!! in <lambda>()
21 addToResults(resolver, base, child1.asStarProjectedType()) in <lambda>()
22 val child2 = resolver.getClassDeclarationByName("Child2")!! in <lambda>()
23 addToResults(resolver, base, child2.asStarProjectedType()) in <lambda>()
24 val child2WithString = resolver.getDeclaration<KSPropertyDeclaration>("child2WithString") in <lambda>()
25 addToResults(resolver, base, child2WithString.type.resolve()) in <lambda>()
28 val notAChild = resolver.getClassDeclarationByName("NotAChild")!! in <lambda>()
29 addToResults(resolver, base, notAChild.asStarProjectedType()) in <lambda>()
[all …]
|
| D | JavaSubtypeProcessor.kt | 18 override fun process(resolver: Resolver): List<KSAnnotated> { in process()
19 …val javaCollection = resolver.getJavaClassByName("kotlin.collections.Collection")!!.asStarProjecte… in process()
20 val javaSet = resolver.getJavaClassByName("kotlin.collections.Set")!!.asStarProjectedType() in process()
21 …val ktFunctionJava = resolver.getJavaClassByName("kotlin.jvm.functions.Function0")!!.asStarProject… in process()
22 …val ktCollection = resolver.getClassDeclarationByName("kotlin.collections.Collection")!!.asStarPro… in process()
23 … val ktSet = resolver.getClassDeclarationByName("kotlin.collections.Set")!!.asStarProjectedType() in process()
24 …val ktFunction = resolver.getClassDeclarationByName("kotlin.jvm.functions.Function0")!!.asStarProj… in process()
25 val javaCollectionRef = resolver.createKSTypeReferenceFromKSType(javaCollection) in process()
26 val ktCollectionRef = resolver.createKSTypeReferenceFromKSType(ktCollection) in process()
27 val javaSetRef = resolver.createKSTypeReferenceFromKSType(javaSet) in process()
[all …]
|
| D | OverrideeProcessor.kt | 31 override fun process(resolver: Resolver): List<KSAnnotated> { in toResult()
32 logSubject(resolver, "NoOverride") in toResult()
33 logSubject(resolver, "Subject") in toResult()
34 logSubject(resolver, "JavaSubject.Subject") in toResult()
35 logSubject(resolver, "lib.Subject") in toResult()
36 logSubject(resolver, "ConflictingSubject1") in toResult()
37 logSubject(resolver, "ConflictingSubject2") in toResult()
38 logSubject(resolver, "ConflictingSubject3") in toResult()
39 logSubject(resolver, "ConflictingSubject4") in toResult()
40 logSubject(resolver, "OverrideOrder1") in toResult()
[all …]
|
| D | CheckOverrideProcessor.kt | 32 override fun process(resolver: Resolver): List<KSAnnotated> { in process()
40 val javaList = resolver.getClassDeclarationByName(resolver.getKSNameFromString("JavaList")) in process()
42 … val kotlinList = resolver.getClassDeclarationByName(resolver.getKSNameFromString("KotlinList")) in process()
44 … val getFunKt = resolver.getSymbolsWithAnnotation("GetAnno").single() as KSFunctionDeclaration in process()
47 … val fooFunKt = resolver.getSymbolsWithAnnotation("FooAnno").single() as KSFunctionDeclaration in process()
48 … val foooFunKt = resolver.getSymbolsWithAnnotation("BarAnno").single() as KSFunctionDeclaration in process()
51 … val bazPropKt = resolver.getSymbolsWithAnnotation("BazAnno").single() as KSPropertyDeclaration in process()
52 … val baz2PropKt = resolver.getSymbolsWithAnnotation("Baz2Anno").single() as KSPropertyDeclaration in process()
53 val bazzPropKt = resolver.getSymbolsWithAnnotation("BazzAnno") in process()
55 … val bazz2PropKt = resolver.getSymbolsWithAnnotation("Bazz2Anno").single() as KSPropertyDeclaration in process()
[all …]
|
| D | ThrowListProcessor.kt | 20 override fun process(resolver: Resolver): List<KSAnnotated> { in process()
21 val klass = resolver.getClassDeclarationByName("ThrowsKt")!! in process()
22 val jlass = resolver.getClassDeclarationByName("ThrowsException")!! in process()
24 resolver.getJvmCheckedException( in process()
31 resolver.getJvmCheckedException( in process()
40 result.add(resolver.getJvmCheckedException(propertyA.getter!!).toResult()) in process()
41 result.add(resolver.getJvmCheckedException(propertyA.setter!!).toResult()) in process()
42 val jlib = resolver.getClassDeclarationByName("JavaLib")!! in process()
43 val klib = resolver.getClassDeclarationByName("KtLib")!! in process()
45 resolver.getJvmCheckedException(it as KSFunctionDeclaration).toResult() in process()
[all …]
|
| D | MangledNamesProcessor.kt | 15 override fun process(resolver: Resolver): List<KSAnnotated> { in <lambda>()
17 resolver.getAllFiles().sortedBy { it.fileName }.forEach { in <lambda>()
18 it.accept(MangledNamesVisitor(resolver), mangleSourceNames) in <lambda>()
22 resolver.getClassDeclarationByName("libPackage.Foo")?.accept( in <lambda>()
23 MangledNamesVisitor(resolver), mangledDependencyNames in <lambda>()
25 resolver.getClassDeclarationByName("libPackage.AbstractKotlinClass")?.accept( in <lambda>()
26 MangledNamesVisitor(resolver), mangledDependencyNames in <lambda>()
28 resolver.getClassDeclarationByName("libPackage.MyInterface")?.accept( in <lambda>()
29 MangledNamesVisitor(resolver), mangledDependencyNames in <lambda>()
45 val resolver: Resolver in <lambda>() constant in com.google.devtools.ksp.processor.MangledNamesProcessor.MangledNamesVisitor
[all …]
|
| /external/webrtc/p2p/base/ |
| D | basic_async_resolver_factory_unittest.cc | 30 rtc::AsyncResolverInterface* resolver = factory.Create(); in TestCreate() local
31 ASSERT_TRUE(resolver); in TestCreate()
32 resolver->SignalDone.connect( in TestCreate()
36 resolver->Start(address); in TestCreate()
38 resolver->Destroy(false); in TestCreate()
41 void SetAddressResolved(rtc::AsyncResolverInterface* resolver) { in SetAddressResolved() argument
61 std::unique_ptr<AsyncDnsResolverInterface> resolver(factory.Create()); in TEST() local
62 ASSERT_TRUE(resolver); in TEST()
66 resolver->Start(address, [&address_resolved]() { address_resolved = true; }); in TEST()
68 resolver.reset(); in TEST()
[all …]
|
| /external/tensorflow/tensorflow/lite/ |
| D | mutable_op_resolver_test.cc | 68 MutableOpResolver resolver; in TEST() local
69 resolver.AddBuiltin(BuiltinOperator_ADD, GetDummyRegistration()); in TEST()
72 resolver.FindOp(BuiltinOperator_ADD, 1); in TEST()
80 MutableOpResolver resolver; in TEST() local
81 resolver.AddBuiltin(BuiltinOperator_ADD, GetDummyRegistration()); in TEST()
84 resolver.FindOp(BuiltinOperator_CONV_2D, 1); in TEST()
89 MutableOpResolver resolver; in TEST() local
91 resolver.AddBuiltin(BuiltinOperator_ADD, GetDummyRegistration(), 2); in TEST()
95 found_registration = resolver.FindOp(BuiltinOperator_ADD, 1); in TEST()
98 found_registration = resolver.FindOp(BuiltinOperator_ADD, 2); in TEST()
[all …]
|
| /external/cronet/stable/net/dns/ |
| D | mapped_host_resolver_unittest.cc | 50 auto resolver = in TEST() local
57 resolver->CreateRequest(HostPortPair("www.google.com", 80), in TEST()
67 EXPECT_TRUE(resolver->AddRuleFromString("map *.google.com baz.com")); in TEST()
71 request = resolver->CreateRequest(HostPortPair("www.google.com", 80), in TEST()
83 request = resolver->CreateRequest(HostPortPair("foo.com", 77), in TEST()
94 EXPECT_TRUE(resolver->AddRuleFromString("Map *.org proxy:99")); in TEST()
97 request = resolver->CreateRequest(HostPortPair("chromium.org", 61), in TEST()
115 auto resolver = in TEST() local
117 ASSERT_TRUE(resolver->AddRuleFromString("MAP to.map.test remapped.test")); in TEST()
120 resolver->CreateRequest( in TEST()
[all …]
|
| /external/cronet/tot/net/dns/ |
| D | mapped_host_resolver_unittest.cc | 50 auto resolver = in TEST() local
57 resolver->CreateRequest(HostPortPair("www.google.com", 80), in TEST()
67 EXPECT_TRUE(resolver->AddRuleFromString("map *.google.com baz.com")); in TEST()
71 request = resolver->CreateRequest(HostPortPair("www.google.com", 80), in TEST()
83 request = resolver->CreateRequest(HostPortPair("foo.com", 77), in TEST()
94 EXPECT_TRUE(resolver->AddRuleFromString("Map *.org proxy:99")); in TEST()
97 request = resolver->CreateRequest(HostPortPair("chromium.org", 61), in TEST()
115 auto resolver = in TEST() local
117 ASSERT_TRUE(resolver->AddRuleFromString("MAP to.map.test remapped.test")); in TEST()
120 resolver->CreateRequest( in TEST()
[all …]
|
| /external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/multipart/ |
| D | MultipartConfigurationResolverTest.java | 30 MultipartConfigurationResolver resolver = new MultipartConfigurationResolver(configuration); in resolveThresholdInBytes_valueNotProvided_shouldSameAsPartSize() local
31 assertThat(resolver.thresholdInBytes()).isEqualTo(10L); in resolveThresholdInBytes_valueNotProvided_shouldSameAsPartSize()
40 MultipartConfigurationResolver resolver = new MultipartConfigurationResolver(configuration); in resolveThresholdInBytes_valueProvided_shouldHonor() local
41 assertThat(resolver.thresholdInBytes()).isEqualTo(12L); in resolveThresholdInBytes_valueProvided_shouldHonor()
49 MultipartConfigurationResolver resolver = new MultipartConfigurationResolver(configuration); in resolveApiCallBufferSize_valueProvided_shouldHonor() local
50 assertThat(resolver.apiCallBufferSize()).isEqualTo(100L); in resolveApiCallBufferSize_valueProvided_shouldHonor()
58 MultipartConfigurationResolver resolver = new MultipartConfigurationResolver(configuration); in resolveApiCallBufferSize_valueNotProvided_shouldComputeBasedOnPartSize() local
59 assertThat(resolver.apiCallBufferSize()).isEqualTo(40L); in resolveApiCallBufferSize_valueNotProvided_shouldComputeBasedOnPartSize()
69 MultipartConfigurationResolver resolver = new MultipartConfigurationResolver(configuration); in valueProvidedForAllFields_shouldHonor() local
70 assertThat(resolver.minimalPartSizeInBytes()).isEqualTo(10L); in valueProvidedForAllFields_shouldHonor()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/runtime/ |
| D | symbolic_shape_test.cc | 93 SymbolicShapesResolver resolver(type, constraints); in TEST() local
97 auto symbolic = resolver.Resolve(operands); in TEST()
98 auto hash = resolver.ResolveHash(operands); in TEST()
109 auto symbolic = resolver.Resolve(operands); in TEST()
110 auto hash = resolver.ResolveHash(operands); in TEST()
121 auto symbolic = resolver.Resolve(operands); in TEST()
122 auto hash = resolver.ResolveHash(operands); in TEST()
133 auto symbolic = resolver.Resolve(operands); in TEST()
134 auto hash = resolver.ResolveHash(operands); in TEST()
155 SymbolicShapesResolver resolver(type, constraints); in TEST() local
[all …]
|
| /external/grpc-grpc/test/core/client_channel/resolvers/ |
| D | fake_resolver_test.cc | 156 auto resolver = CreateResolver(); in TEST_F() local
157 ASSERT_NE(resolver, nullptr); in TEST_F()
166 auto resolver = CreateResolver(); in TEST_F() local
167 ASSERT_NE(resolver, nullptr); in TEST_F()
170 RunSynchronously([resolver = resolver.get()] { resolver->StartLocked(); }); in TEST_F()
178 auto resolver = CreateResolver(); in TEST_F() local
179 ASSERT_NE(resolver, nullptr); in TEST_F()
186 RunSynchronously([resolver = resolver.get()] { resolver->StartLocked(); }); in TEST_F()
194 auto resolver = CreateResolver(); in TEST_F() local
195 ASSERT_NE(resolver, nullptr); in TEST_F()
[all …]
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/fake/ |
| D | fake_resolver.cc | 162 explicit FakeResolverResponseSetter(RefCountedPtr<FakeResolver> resolver, in FakeResolverResponseSetter() argument
166 : resolver_(std::move(resolver)), in FakeResolverResponseSetter()
218 RefCountedPtr<FakeResolver> resolver; in SetResponse() local
226 resolver = resolver_->Ref(); in SetResponse()
229 new FakeResolverResponseSetter(resolver, std::move(result)); in SetResponse()
230 resolver->work_serializer_->Run([arg]() { arg->SetResponseLocked(); }, in SetResponse()
236 RefCountedPtr<FakeResolver> resolver; in SetReresolutionResponse() local
240 resolver = resolver_->Ref(); in SetReresolutionResponse()
243 resolver, std::move(result), true /* has_result */); in SetReresolutionResponse()
244 resolver->work_serializer_->Run( in SetReresolutionResponse()
[all …]
|
| /external/cronet/tot/net/proxy_resolution/ |
| D | configured_proxy_resolution_service_unittest.cc | 355 JobMap GetPendingJobsForURLs(const MockAsyncProxyResolver& resolver, in GetPendingJobsForURLs() argument
368 for (MockAsyncProxyResolver::Job* it : resolver.pending_jobs()) { in GetPendingJobsForURLs()
379 JobMap GetCancelledJobsForURLs(const MockAsyncProxyResolver& resolver, in GetCancelledJobsForURLs() argument
393 resolver.cancelled_jobs()) { in GetCancelledJobsForURLs()
621 MockAsyncProxyResolver resolver; in TEST_F() local
653 factory_ptr->pending_requests()[0]->CompleteNowWithForwarder(OK, &resolver); in TEST_F()
655 ASSERT_EQ(2u, resolver.pending_jobs().size()); in TEST_F()
660 if (resolver.pending_jobs()[i]->url() == url) { in TEST_F()
668 resolver.pending_jobs()[deleting_job]->results()->UseNamedProxy("foopy"); in TEST_F()
669 resolver.pending_jobs()[deleting_job]->CompleteNow(OK); in TEST_F()
[all …]
|
| /external/cronet/stable/net/proxy_resolution/ |
| D | configured_proxy_resolution_service_unittest.cc | 355 JobMap GetPendingJobsForURLs(const MockAsyncProxyResolver& resolver, in GetPendingJobsForURLs() argument
368 for (MockAsyncProxyResolver::Job* it : resolver.pending_jobs()) { in GetPendingJobsForURLs()
379 JobMap GetCancelledJobsForURLs(const MockAsyncProxyResolver& resolver, in GetCancelledJobsForURLs() argument
393 resolver.cancelled_jobs()) { in GetCancelledJobsForURLs()
621 MockAsyncProxyResolver resolver; in TEST_F() local
653 factory_ptr->pending_requests()[0]->CompleteNowWithForwarder(OK, &resolver); in TEST_F()
655 ASSERT_EQ(2u, resolver.pending_jobs().size()); in TEST_F()
660 if (resolver.pending_jobs()[i]->url() == url) { in TEST_F()
668 resolver.pending_jobs()[deleting_job]->results()->UseNamedProxy("foopy"); in TEST_F()
669 resolver.pending_jobs()[deleting_job]->CompleteNow(OK); in TEST_F()
[all …]
|
| /external/sdv/vsomeip/third_party/boost/asio/test/ip/ |
| D | icmp.cpp | 441 boost::asio::ip::icmp::resolver::results_type) {} in operator ()()
461 ip::icmp::resolver::query q(ip::icmp::v4(), "localhost", "0"); in test()
467 ip::icmp::resolver resolver(ioc); in test() local
468 ip::icmp::resolver resolver2(ioc_ex); in test()
471 ip::icmp::resolver resolver3(std::move(resolver)); in test()
477 resolver = ip::icmp::resolver(ioc); in test()
478 resolver = std::move(resolver3); in test()
483 ip::icmp::resolver::executor_type ex = resolver.get_executor(); in test()
488 resolver.cancel(); in test()
491 ip::icmp::resolver::results_type results1 = resolver.resolve(q); in test()
[all …]
|
| /external/guice/core/test/com/google/inject/ |
| D | TypeLiteralTypeResolutionTest.java | 97 TypeLiteral<?> resolver = TypeLiteral.get(arrayListOfString); in testDirectInheritance() local
100 resolver.getReturnType(List.class.getMethod("subList", int.class, int.class)).getType()); in testDirectInheritance()
103 resolver.getParameterTypes(Collection.class.getMethod("add", Object.class))); in testDirectInheritance()
107 TypeLiteral<?> resolver = TypeLiteral.get(arrayListOfString); in testGenericSupertype() local
110 resolver.getSupertype(Collection.class).getType()); in testGenericSupertype()
113 resolver.getSupertype(Iterable.class).getType()); in testGenericSupertype()
116 resolver.getSupertype(AbstractList.class).getType()); in testGenericSupertype()
117 assertEquals(Object.class, resolver.getSupertype(Object.class).getType()); in testGenericSupertype()
121 TypeLiteral<?> resolver = TypeLiteral.get(MyInteger.class); in testRecursiveTypeVariable() local
122 assertEquals(MyInteger.class, resolver.getParameterTypes(comparableCompareTo).get(0).getType()); in testRecursiveTypeVariable()
[all …]
|
| /external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/datasource/src/main/java/com/google/android/exoplayer2/upstream/ |
| D | ResolvingDataSource.java | 66 private final Resolver resolver; field in ResolvingDataSource.Factory
73 public Factory(DataSource.Factory upstreamFactory, Resolver resolver) { in Factory() argument
75 this.resolver = resolver; in Factory()
80 return new ResolvingDataSource(upstreamFactory.createDataSource(), resolver); in createDataSource()
85 private final Resolver resolver; field in ResolvingDataSource
93 public ResolvingDataSource(DataSource upstreamDataSource, Resolver resolver) { in ResolvingDataSource() argument
95 this.resolver = resolver; in ResolvingDataSource()
106 DataSpec resolvedDataSpec = resolver.resolveDataSpec(dataSpec); in open()
120 return reportedUri == null ? null : resolver.resolveReportedUri(reportedUri); in getUri()
|