grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

android: Use InternalManagedChannelProvider instead of reflection 

This fixes up cda0e9d to be compatible with Proguard without
configuration. Since the methods are now accessed directly there is no
need for manual -keep configuration.
This commit is contained in:
Eric Anderson 2022-03-31 11:11:57 -07:00
parent 86e3362298
commit 40c929e39f
2 changed files with 22 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java
View File

@ -33,8 +33,10 @@ import io.grpc.ClientCall;
import io.grpc.ConnectivityState;
import io.grpc.ExperimentalApi;
import io.grpc.ForwardingChannelBuilder;
import io.grpc.InternalManagedChannelProvider;
import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import io.grpc.ManagedChannelProvider;
import io.grpc.MethodDescriptor;
import io.grpc.internal.GrpcUtil;
import java.util.concurrent.TimeUnit;
@ -55,30 +57,32 @@ public final class AndroidChannelBuilder extends ForwardingChannelBuilder<Androi
private static final String LOG_TAG = "AndroidChannelBuilder";
@Nullable private static final Object OKHTTP_CHANNEL_PROVIDER = findOkHttp();
@Nullable private static final ManagedChannelProvider OKHTTP_CHANNEL_PROVIDER = findOkHttp();
private static Object findOkHttp() {
Class<?> klass;
private static ManagedChannelProvider findOkHttp() {
Class<?> klassRaw;
try {
klass = Class.forName("io.grpc.okhttp.OkHttpChannelProvider");
klassRaw = Class.forName("io.grpc.okhttp.OkHttpChannelProvider");
} catch (ClassNotFoundException e) {
Log.w(LOG_TAG, "Failed to find OkHttpChannelProvider", e);
return null;
}
Object provider;
Class<? extends ManagedChannelProvider> klass;
try {
klass = klassRaw.asSubclass(ManagedChannelProvider.class);
} catch (ClassCastException e) {
Log.w(LOG_TAG, "Couldn't cast OkHttpChannelProvider to ManagedChannelProvider", e);
return null;
}
ManagedChannelProvider provider;
try {
provider = klass.getConstructor().newInstance();
} catch (Exception e) {
Log.w(LOG_TAG, "Failed to construct OkHttpChannelProvider", e);
return null;
}
try {
if (!(Boolean) klass.getMethod("isAvailable").invoke(provider)) {
Log.w(LOG_TAG, "OkHttpChannelProvider.isAvailable() returned false");
return null;
}
} catch (Exception e) {
Log.w(LOG_TAG, "Failed to check OkHttpChannelProvider.isAvailable()", e);
if (!InternalManagedChannelProvider.isAvailable(provider)) {
Log.w(LOG_TAG, "OkHttpChannelProvider.isAvailable() returned false");
return null;
}
return provider;
@ -135,15 +139,8 @@ public final class AndroidChannelBuilder extends ForwardingChannelBuilder<Androi
if (OKHTTP_CHANNEL_PROVIDER == null) {
throw new UnsupportedOperationException("Unable to load OkHttpChannelProvider");
}
try {
delegateBuilder =
(ManagedChannelBuilder)
OKHTTP_CHANNEL_PROVIDER.getClass()
.getMethod("builderForTarget", String.class)
.invoke(OKHTTP_CHANNEL_PROVIDER, target);
} catch (Exception e) {
throw new RuntimeException("Failed to create ManagedChannelBuilder", e);
}
delegateBuilder =
InternalManagedChannelProvider.builderForTarget(OKHTTP_CHANNEL_PROVIDER, target);
}
private AndroidChannelBuilder(ManagedChannelBuilder<?> delegateBuilder) {

4
api/src/main/java/io/grpc/InternalManagedChannelProvider.java
View File

@ -25,6 +25,10 @@ public final class InternalManagedChannelProvider {
private InternalManagedChannelProvider() {
}
public static boolean isAvailable(ManagedChannelProvider provider) {
return provider.isAvailable();
}
public static ManagedChannelBuilder<?> builderForAddress(ManagedChannelProvider provider,
String name, int port) {
return provider.builderForAddress(name, port);