Struct NetworkRestoreServer 

pub struct NetworkRestoreServer { /* private fields */ }

Serves log files to nodes performing a network restore.

Implements both standalone TCP serving and the ServiceHandler trait so it can be plugged into a TcpServiceDispatcher.

Implementations

impl NetworkRestoreServer

pub fn new(env_home: impl Into<PathBuf>) -> Self

Create a new restore server that will serve files from env_home.

pub fn into_arc(self) -> Arc<Self>

Wrap in Arc so the same instance can be shared between the accept loop thread and the ServiceHandler registration.

pub fn stop(&self)

Stop the standalone accept loop (if one was started).

pub fn is_running(&self) -> bool

Whether the standalone accept loop is running.

pub fn start(self: &Arc<Self>, addr: SocketAddr) -> Result<SocketAddr>

Start a dedicated TCP accept loop on addr.

Returns the actual bound address (useful when addr has port 0). Connections are handled in per-connection threads.

Trait Implementations

impl ServiceHandler for NetworkRestoreServer

NetworkRestoreServer can be registered with TcpServiceDispatcher under the "RESTORE" service name. The service dispatcher reads the service name from each new connection before calling handle(); the channel passed here is ready for the RESTORE protocol (magic bytes onward).

fn service_name(&self) -> &str

The name of this service, used for routing.

fn handle(&self, channel: Box<dyn Channel>) -> Result<()>

Handle an incoming connection on this service.