Struct re_ws_comms::server::RerunServer

pub struct RerunServer {
    local_addr: SocketAddr,
    listener_join_handle: Option<JoinHandle<()>>,
    poller: Arc<Poller>,
    shutdown_flag: Arc<AtomicBool>,
    num_accepted_clients: Arc<AtomicU64>,
}

Websocket host for relaying [LogMsg]s to a web viewer.

When dropped, the server will be shut down.

Fields

local_addr: SocketAddr

listener_join_handle: Option<JoinHandle<()>>

poller: Arc<Poller>

shutdown_flag: Arc<AtomicBool>

num_accepted_clients: Arc<AtomicU64>

Total count; never decreasing.

Implementations

impl RerunServer

pub fn new( rerun_rx: ReceiveSet<LogMsg>, bind_ip: &str, port: RerunServerPort, server_memory_limit: MemoryLimit ) -> Result<Self, RerunServerError>

Create new RerunServer to relay [LogMsg]s to a websocket. The websocket will be available at port.

A bind_ip of "0.0.0.0" is a good default. A port of 0 will let the OS choose a free port.

Once created, the server will immediately start listening for connections.

pub fn server_url(&self) -> String

Contains the ws:// or wss:// prefix.

pub fn num_accepted_clients(&self) -> u64

Total count; never decreasing.

pub fn block(self)

Blocks execution as long as the server is running.

There’s no way of shutting the server down from the outside right now.

fn listen_thread_func( poller: &Poller, listener_socket: &TcpListener, message_broadcaster: &ReceiveSetBroadcaster, shutdown_flag: &AtomicBool, num_accepted_clients: &AtomicU64 )

fn accept_connection( listener_socket: &TcpListener, message_broadcaster: &ReceiveSetBroadcaster, poller: &Poller, listener_poll_key: usize, num_accepted_clients: &AtomicU64 )

fn stop_listener(&mut self)

Trait Implementations

impl Drop for RerunServer

fn drop(&mut self)

Executes the destructor for this type.