Class BinderServer

binder/src/main/java/io/grpc/binder/internal/BinderServer.java:62–316

A gRPC InternalServer which accepts connections via a host AndroidService. Multiple incoming connections transports may be active at a time. IMPORTANT : This implementation must comply with this published wire format. https://github.com/grpc/proposal/blob/master/L73-java-binderchannel/

 * https://github.com/grpc/proposal/blob/master/L73-java-binderchannel/wireformat.md
 */
@ThreadSafe
public final class BinderServer implements InternalServer, LeakSafeOneWayBinder.TransactionHandler {
  private static final Logger logger = Logger.getLogger(BinderServer.class.getName());

  private final ObjectPool<ScheduledExecutorService> executorServicePool;
  private final ObjectPool<? extends Executor> executorPool;
  private final ImmutableList<ServerStreamTracer.Factory> streamTracerFactories;
  private final AndroidComponentAddress listenAddress;
  private final LeakSafeOneWayBinder hostServiceBinder;
  private final BinderTransportSecurity.ServerPolicyChecker serverPolicyChecker;
  private final InboundParcelablePolicy inboundParcelablePolicy;
  private final OneWayBinderProxy.Decorator clientBinderDecorator;

  @GuardedBy("this")
  private ServerListener listener;

  @GuardedBy("this")
  private ScheduledExecutorService executorService;

  @Nullable // Before start() and after termination.
  @GuardedBy("this")
  private Executor executor;

  @GuardedBy("this")
  private boolean shutdown;

  private BinderServer(Builder builder) {
    this.listenAddress = checkNotNull(builder.listenAddress);
    this.executorPool = checkNotNull(builder.executorPool);
    this.executorServicePool = builder.executorServicePool;
    this.streamTracerFactories =
        ImmutableList.copyOf(checkNotNull(builder.streamTracerFactories, "streamTracerFactories"));
    this.serverPolicyChecker = BinderInternal.createPolicyChecker(builder.serverSecurityPolicy);
    this.inboundParcelablePolicy = builder.inboundParcelablePolicy;
    this.clientBinderDecorator = builder.clientBinderDecorator;
    hostServiceBinder = new LeakSafeOneWayBinder(this);
  }

  /** Return the binder we're listening on. */
  public IBinder getHostBinder() {
    return hostServiceBinder;
  }

  @Override
  public synchronized void start(ServerListener serverListener) throws IOException {
    listener = new ActiveTransportTracker(serverListener, this::onTerminated);
    executorService = executorServicePool.getObject();
    executor = executorPool.getObject();
  }

  @Override
  public SocketAddress getListenSocketAddress() {
    return listenAddress;
  }

  @Override
  public List<? extends SocketAddress> getListenSocketAddresses() {
    return ImmutableList.of(listenAddress);