Struct chain_peer::peer::Peer

pub struct Peer {
    pub w_queues: Arc<Mutex<HashMap<SocketAddr, Arc<Mutex<Vec<Vec<u8>>>>>>>,
    // some fields omitted
}

Fields

w_queues: Arc<Mutex<HashMap<SocketAddr, Arc<Mutex<Vec<Vec<u8>>>>>>>

Methods

impl Peer

fn new(
    r_q: Arc<Mutex<HashMap<SocketAddr, Arc<Mutex<Vec<Vec<u8>>>>>>>,
    w_q: Arc<Mutex<HashMap<SocketAddr, Arc<Mutex<Vec<Vec<u8>>>>>>>,
    client_r: Arc<Mutex<Vec<u8>>>,
    client_w: Arc<Mutex<Vec<Vec<u8>>>>
) -> Peer

fn run_server(&mut self, addr: String)

fn read_from(&mut self, key: SocketAddr, buf: &mut Vec<Vec<u8>>) -> usize

fn write_to(&mut self, key: SocketAddr, buf: &mut Vec<u8>) -> usize

fn conns(&mut self) -> Vec<SocketAddr>

fn run_client(&mut self, addr: String)

fn read_from_server(&mut self)

fn write_to_server(&mut self, buf: Vec<u8>)

Trait Implementations

impl Debug for Peer

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Clone for Peer

fn clone(&self) -> Peer

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.