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

binder: BinderTransportTest uses a realistic Executor. (#10803)

This commit is contained in:
John Cormie 2024-01-11 10:49:03 -08:00 committed by GitHub
parent 100d5a55fd
commit 4352099c7f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
binder/src/androidTest/java/io/grpc/binder/internal/BinderTransportTest.java
View File

@ -20,7 +20,6 @@ import android.content.Context;
import androidx.core.content.ContextCompat; import androidx.core.content.ContextCompat;
import androidx.test.core.app.ApplicationProvider; import androidx.test.core.app.ApplicationProvider;
import androidx.test.ext.junit.runners.AndroidJUnit4; import androidx.test.ext.junit.runners.AndroidJUnit4;
import com.google.common.util.concurrent.MoreExecutors;
import io.grpc.ServerStreamTracer; import io.grpc.ServerStreamTracer;
import io.grpc.binder.AndroidComponentAddress; import io.grpc.binder.AndroidComponentAddress;
import io.grpc.binder.BindServiceFlags; import io.grpc.binder.BindServiceFlags;
@ -30,13 +29,13 @@ import io.grpc.binder.HostServices;
import io.grpc.binder.InboundParcelablePolicy; import io.grpc.binder.InboundParcelablePolicy;
import io.grpc.binder.SecurityPolicies; import io.grpc.binder.SecurityPolicies;
import io.grpc.internal.AbstractTransportTest; import io.grpc.internal.AbstractTransportTest;
import io.grpc.internal.FixedObjectPool;
import io.grpc.internal.GrpcUtil; import io.grpc.internal.GrpcUtil;
import io.grpc.internal.InternalServer; import io.grpc.internal.InternalServer;
import io.grpc.internal.ManagedClientTransport; import io.grpc.internal.ManagedClientTransport;
import io.grpc.internal.ObjectPool; import io.grpc.internal.ObjectPool;
import io.grpc.internal.SharedResourcePool; import io.grpc.internal.SharedResourcePool;
import java.util.List; import java.util.List;
import java.util.concurrent.Executor;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;
import org.junit.After; import org.junit.After;
import org.junit.Ignore; import org.junit.Ignore;
@ -55,6 +54,8 @@ public final class BinderTransportTest extends AbstractTransportTest {
private final Context appContext = ApplicationProvider.getApplicationContext(); private final Context appContext = ApplicationProvider.getApplicationContext();
private final ObjectPool<ScheduledExecutorService> executorServicePool = private final ObjectPool<ScheduledExecutorService> executorServicePool =
SharedResourcePool.forResource(GrpcUtil.TIMER_SERVICE); SharedResourcePool.forResource(GrpcUtil.TIMER_SERVICE);
private final ObjectPool<Executor> offloadExecutorPool =
SharedResourcePool.forResource(GrpcUtil.SHARED_CHANNEL_EXECUTOR);
@Override @Override
@After @After
@ -104,7 +105,7 @@ public final class BinderTransportTest extends AbstractTransportTest {
BindServiceFlags.DEFAULTS, BindServiceFlags.DEFAULTS,
ContextCompat.getMainExecutor(appContext), ContextCompat.getMainExecutor(appContext),
executorServicePool, executorServicePool,
new FixedObjectPool<>(MoreExecutors.directExecutor()), offloadExecutorPool,
SecurityPolicies.internalOnly(), SecurityPolicies.internalOnly(),
InboundParcelablePolicy.DEFAULT, InboundParcelablePolicy.DEFAULT,
eagAttrs()); eagAttrs());