High performance C++ framework for concurrent servers
Classes | Public Member Functions | Public Attributes | List of all members
seastar::rpc::server Class Reference
Inheritance diagram for seastar::rpc::server:
seastar::rpc::protocol< Serializer, MsgType >::server


class  connection

Public Member Functions

 server (protocol_base *proto, const socket_address &addr, resource_limits memory_limit=resource_limits())
 server (protocol_base *proto, server_options opts, const socket_address &addr, resource_limits memory_limit=resource_limits())
 server (protocol_base *proto, server_socket, resource_limits memory_limit=resource_limits(), server_options opts=server_options{})
 server (protocol_base *proto, server_options opts, server_socket, resource_limits memory_limit=resource_limits())
void accept ()
future stop ()
future shutdown ()
template<typename Func >
void foreach_connection (Func &&f)
void abort_connection (connection_id id)
gatereply_gate ()

Public Attributes

friend connection
friend client

Member Function Documentation

◆ abort_connection()

void seastar::rpc::server::abort_connection ( connection_id  id)

Abort the given connection, causing it to stop receiving any further messages. It's safe to abort a connection from an RPC handler running on that connection. Does nothing if there is no connection with the given ID on this server.

idthe ID of the connection to abort.

◆ shutdown()

future seastar::rpc::server::shutdown ( )

Shuts down the server.

Light version of the stop, that just makes sure the server is not visible by remote clients, i.e. – no new rpcs are admitted and no replies on the previously running handlers will be sent. Currently running handlers may still run.

Caller of shutdown() mush wait for it to resolve before calling stop.

◆ stop()

future seastar::rpc::server::stop ( )

Stops the server.

It makes sure that no new rpcs are admitted, no rpc handlers issued on this connection are running any longer and no replies on the previously running handlers will be sent.

The documentation for this class was generated from the following file: