Method: GRPC::RpcServer#initialize

Defined in:

src/ruby/lib/grpc/generic/rpc_server.rb

#initialize(pool_size: DEFAULT_POOL_SIZE, max_waiting_requests: DEFAULT_MAX_WAITING_REQUESTS, poll_period: DEFAULT_POLL_PERIOD, pool_keep_alive: Pool::DEFAULT_KEEP_ALIVE, connect_md_proc: nil, server_args: {}, interceptors: []) ⇒ RpcServer

Creates a new RpcServer.

The RPC server is configured using keyword arguments.

There are some specific keyword args used to configure the RpcServer instance.

• pool_size: the size of the thread pool the server uses to run its

threads. No more concurrent requests can be made than the size of the thread pool

• max_waiting_requests: Deprecated due to internal changes to the thread

pool. This is still an argument for compatibility but is ignored.

• poll_period: The amount of time in seconds to wait for

currently-serviced RPC’s to finish before cancelling them when shutting down the server.

• pool_keep_alive: The amount of time in seconds to wait

for currently busy thread-pool threads to finish before forcing an abrupt exit to each thread.

• connect_md_proc:

when non-nil is a proc for determining metadata to send back the client on receiving an invocation req. The proc signature is:

{key: val, ..} func(method_name, {key: val, ...})

• server_args:

A server arguments hash to be passed down to the underlying core server

• interceptors:

An array of GRPC::ServerInterceptor objects that will be used for intercepting server handlers to provide extra functionality. Interceptors are an EXPERIMENTAL API.

# File 'src/ruby/lib/grpc/generic/rpc_server.rb', line 217

def initialize(pool_size: DEFAULT_POOL_SIZE,
               max_waiting_requests: DEFAULT_MAX_WAITING_REQUESTS,
               poll_period: DEFAULT_POLL_PERIOD,
               pool_keep_alive: Pool::DEFAULT_KEEP_ALIVE,
               connect_md_proc: nil,
               server_args: {},
               interceptors: [])
  @connect_md_proc = RpcServer.setup_connect_md_proc(connect_md_proc)
  @max_waiting_requests = max_waiting_requests
  @poll_period = poll_period
  @pool_size = pool_size
  @pool = Pool.new(@pool_size, keep_alive: pool_keep_alive)
  @run_cond = ConditionVariable.new
  @run_mutex = Mutex.new
  # running_state can take 4 values: :not_started, :running, :stopping, and
  # :stopped. State transitions can only proceed in that order.
  @running_state = :not_started
  @server = Core::Server.new(server_args)
  @interceptors = InterceptorRegistry.new(interceptors)
end