Struct Peer

pub struct Peer {
    id: Id,
    tx: Option<Sender<Message>>,
    terminated: Arc<AtomicBool>,
    read_thread: Option<JoinHandle<()>>,
    write_thread: Option<JoinHandle<()>>,
}

Peer connection

Fields

id: Id

tx: Option<Sender<Message>>

terminated: Arc<AtomicBool>

read_thread: Option<JoinHandle<()>>

write_thread: Option<JoinHandle<()>>

Implementations

impl Peer

pub fn listen(listener: &TcpListener, server_tx: &Sender<Event>)

Blocking incoming peer connection accept loop

pub fn connect( config: &Arc<Config>, peer: &Peer, server_tx: &Sender<Event>, ) -> Result<JoinSuccess, HandshakeError>

Initiate peer connection

pub fn new( stream: TcpStream, id: Id, server_tx: Sender<Event>, heartbeat_timeout: Duration, ) -> Self

Start peer IO threads

pub fn start_handshake( stream: TcpStream, config: &Arc<Config>, expected_id: Id, server_tx: Sender<Event>, ) -> Result<JoinSuccess, HandshakeError>

pub fn send_message(&self, message: Message)

fn read_thread_fn( stream: &mut TcpStream, peer_id: Id, server_tx: &Sender<Event>, terminated: &Arc<AtomicBool>, )

fn write_thread_fn( stream: &mut TcpStream, peer_id: Id, rx: &Receiver<Message>, timeout: Duration, )

Trait Implementations

impl Debug for Peer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for Peer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for Peer

fn drop(&mut self)

Executes the destructor for this type.