Skip to content

Commit e720d50

Browse files
committed
don't use reflection to load token manager.
1 parent 927d215 commit e720d50

File tree

2 files changed

+6
-40
lines changed

2 files changed

+6
-40
lines changed

s2a/BUILD.bazel

Lines changed: 4 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -32,35 +32,13 @@ java_library(
3232
)
3333

3434
java_library(
35-
name = "token_fetcher",
36-
srcs = ["src/main/java/io/grpc/s2a/internal/handshaker/tokenmanager/TokenFetcher.java"],
35+
name = "token_manager",
36+
srcs = ["src/main/java/io/grpc/s2a/internal/handshaker/tokenmanager/*.java],
3737
deps = [
3838
":s2a_identity",
39-
],
40-
)
41-
42-
java_library(
43-
name = "access_token_manager",
44-
srcs = [
45-
"src/main/java/io/grpc/s2a/internal/handshaker/tokenmanager/AccessTokenManager.java",
46-
],
47-
deps = [
48-
":s2a_identity",
49-
":token_fetcher",
5039
artifact("com.google.code.findbugs:jsr305"),
51-
],
52-
)
53-
54-
java_library(
55-
name = "single_token_fetcher",
56-
srcs = [
57-
"src/main/java/io/grpc/s2a/internal/handshaker/tokenmanager/SingleTokenFetcher.java",
58-
],
59-
deps = [
60-
":s2a_identity",
61-
":token_fetcher",
6240
artifact("com.google.guava:guava"),
63-
],
41+
]
6442
)
6543

6644
java_library(
@@ -77,13 +55,12 @@ java_library(
7755
"src/main/java/io/grpc/s2a/internal/handshaker/SslContextFactory.java",
7856
],
7957
deps = [
80-
":access_token_manager",
58+
":token_manager",
8159
":common_java_proto",
8260
":s2a_channel_pool",
8361
":s2a_identity",
8462
":s2a_java_proto",
8563
":s2a_java_grpc_proto",
86-
":single_token_fetcher",
8764
"//api",
8865
"//core:internal",
8966
"//netty",

s2a/src/main/java/io/grpc/s2a/internal/handshaker/tokenmanager/AccessTokenManager.java

Lines changed: 2 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
package io.grpc.s2a.internal.handshaker.tokenmanager;
1818

1919
import io.grpc.s2a.internal.handshaker.S2AIdentity;
20-
import java.lang.reflect.Method;
2120
import java.util.Optional;
2221
import javax.annotation.concurrent.ThreadSafe;
2322

@@ -28,19 +27,9 @@ public final class AccessTokenManager {
2827

2928
/** Creates an {@code AccessTokenManager} based on the environment where the application runs. */
3029
public static Optional<AccessTokenManager> create() {
31-
Optional<?> tokenFetcher;
32-
try {
33-
Class<?> singleTokenFetcherClass =
34-
Class.forName("io.grpc.s2a.internal.handshaker.tokenmanager.SingleTokenFetcher");
35-
Method createTokenFetcher = singleTokenFetcherClass.getMethod("create");
36-
tokenFetcher = (Optional) createTokenFetcher.invoke(null);
37-
} catch (ClassNotFoundException e) {
38-
tokenFetcher = Optional.empty();
39-
} catch (ReflectiveOperationException e) {
40-
throw new LinkageError(e.getMessage(), e);
41-
}
30+
Optional<TokenFetcher> tokenFetcher = SingleTokenFetcher.create();
4231
return tokenFetcher.isPresent()
43-
? Optional.of(new AccessTokenManager((TokenFetcher) tokenFetcher.get()))
32+
? Optional.of(new AccessTokenManager(tokenFetcher.get()))
4433
: Optional.empty();
4534
}
4635

0 commit comments

Comments
 (0)