Struct opcua_server::comms::tcp_transport::TcpTransport

pub struct TcpTransport { /* private fields */ }

This is the thing that handles input and output for the open connection associated with the session.

Implementations

impl TcpTransport

pub fn new(
    certificate_store: Arc<RwLock<CertificateStore>>,
    server_state: Arc<RwLock<ServerState>>,
    address_space: Arc<RwLock<AddressSpace>>
) -> TcpTransport

pub fn run(
    connection: Arc<RwLock<TcpTransport>>,
    socket: TcpStream,
    looping_interval_ms: f64
)

This is the entry point for the session. This function is asynchronous - it spawns tokio tasks to handle the session execution loop so this function will returns immediately.

pub fn is_server_abort(&self) -> bool

Test if the connection should abort

Trait Implementations

impl Transport for TcpTransport

fn state(&self) -> TransportState

fn finish(&mut self, status_code: StatusCode)

Terminate the session and put the connection in a finished state

fn client_address(&self) -> Option<SocketAddr>

Returns the address of the client (peer) of this connection

fn session_manager(&self) -> Arc<RwLock<SessionManager>>

Returns the session map for the connection

fn has_received_hello(&self) -> bool

fn is_finished(&self) -> bool