Class InProcessServer

java.lang.Object

io.grpc.inprocess.InProcessServer

All Implemented Interfaces:

InternalServer

@ThreadSafe
final class InProcessServer
extends Object
implements InternalServer

Field Summary

Fields

Modifier and Type	Field	Description
private final SocketAddress	listenAddress
private ServerListener	listener
private final int	maxInboundMetadataSize
private static final ConcurrentMap<String, InProcessServer>	registry
private ScheduledExecutorService	scheduler	Only used to make sure the scheduler has at least one reference.
private final ObjectPool<ScheduledExecutorService>	schedulerPool	Defaults to be a SharedResourcePool.
private boolean	shutdown
private final List<ServerStreamTracer.Factory>	streamTracerFactories

Constructor Summary

Constructors

Constructor	Description
InProcessServer(InProcessServerBuilder builder, List<? extends ServerStreamTracer.Factory> streamTracerFactories)

Method Summary

Modifier and Type	Method	Description
(package private) static InProcessServer	findServer(SocketAddress addr)
SocketAddress	getListenSocketAddress()	Returns the first listening socket address.
List<? extends SocketAddress>	getListenSocketAddresses()	Returns a list of listening socket addresses.
InternalInstrumented<InternalChannelz.SocketStats>	getListenSocketStats()	Returns the first listen socket stats of this server.
List<InternalInstrumented<InternalChannelz.SocketStats>>	getListenSocketStatsList()	Returns a list of listen socket stats of this server.
(package private) int	getMaxInboundMetadataSize()
(package private) ObjectPool<ScheduledExecutorService>	getScheduledExecutorServicePool()
(package private) List<ServerStreamTracer.Factory>	getStreamTracerFactories()
(package private) ServerTransportListener	register(InProcessTransport transport)
private void	registerInstance()
void	shutdown()	Initiates an orderly shutdown of the server.
void	start(ServerListener serverListener)	Starts transport.
String	toString()
private void	unregisterInstance()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

registry

private static final ConcurrentMap<String, InProcessServer> registry

listenAddress

private final SocketAddress listenAddress

maxInboundMetadataSize

private final int maxInboundMetadataSize

streamTracerFactories

private final List<ServerStreamTracer.Factory> streamTracerFactories

listener

private ServerListener listener

shutdown

private boolean shutdown

schedulerPool

private final ObjectPool<ScheduledExecutorService> schedulerPool

Defaults to be a SharedResourcePool.

scheduler

private ScheduledExecutorService scheduler

Only used to make sure the scheduler has at least one reference. Since child transports can outlive this server, they must get their own reference.

Constructor Details

InProcessServer

InProcessServer(InProcessServerBuilder builder,
 List<? extends ServerStreamTracer.Factory> streamTracerFactories)

Method Details

findServer

static InProcessServer findServer(SocketAddress addr)

start

public void start(ServerListener serverListener)
           throws IOException

Description copied from interface: InternalServer

Starts transport. Implementations must not call listener until after start() returns. The method only returns after it has done the equivalent of bind()ing, so it will be able to service any connections created after returning.

Specified by:

start in interface InternalServer

Parameters:

serverListener - non-null listener of server events

Throws:

IOException - if unable to bind

registerInstance

private void registerInstance()
                       throws IOException

Throws:

IOException

getListenSocketAddress

public SocketAddress getListenSocketAddress()

Description copied from interface: InternalServer

Returns the first listening socket address. May change after InternalServer.start(ServerListener) is called.

Specified by:

getListenSocketAddress in interface InternalServer

getListenSocketAddresses

public List<? extends SocketAddress> getListenSocketAddresses()

Description copied from interface: InternalServer

Returns a list of listening socket addresses. May change after InternalServer.start(ServerListener) is called.

Specified by:

getListenSocketAddresses in interface InternalServer

getListenSocketStats

public InternalInstrumented<InternalChannelz.SocketStats> getListenSocketStats()

Description copied from interface: InternalServer

Returns the first listen socket stats of this server. May return null.

Specified by:

getListenSocketStats in interface InternalServer

getListenSocketStatsList

public List<InternalInstrumented<InternalChannelz.SocketStats>> getListenSocketStatsList()

Description copied from interface: InternalServer

Returns a list of listen socket stats of this server. May return null.

Specified by:

getListenSocketStatsList in interface InternalServer

shutdown

public void shutdown()

Description copied from interface: InternalServer

Initiates an orderly shutdown of the server. Existing transports continue, but new transports will not be created (once ServerListener.serverShutdown() callback is called). This method may only be called once. Blocks until the listening socket(s) have been closed. If interrupted, this method will not wait for the close to complete, but it will happen asynchronously.

Specified by:

shutdown in interface InternalServer

unregisterInstance

private void unregisterInstance()

toString

public String toString()

Overrides:

toString in class Object

register

ServerTransportListener register(InProcessTransport transport)

getScheduledExecutorServicePool

ObjectPool<ScheduledExecutorService> getScheduledExecutorServicePool()

getMaxInboundMetadataSize

int getMaxInboundMetadataSize()

getStreamTracerFactories

List<ServerStreamTracer.Factory> getStreamTracerFactories()