Struct NetworkController

pub struct NetworkController {
    pub sender_to_saito_controller: Sender<IoEvent>,
    /* private fields */
}

Fields

sender_to_saito_controller: Sender<IoEvent>

Implementations

impl NetworkController

pub async fn send( connection: &mut PeerSender, peer_index: u64, buffer: Vec<u8>, ) -> bool

pub async fn send_outgoing_message( sockets: Arc<Mutex<HashMap<u64, PeerSender>>>, peer_index: u64, buffer: Vec<u8>, )

pub async fn connect_to_peer( event_id: u64, io_controller: Arc<RwLock<NetworkController>>, url: String, peer_index: PeerIndex, )

pub async fn send_to_all( sockets: Arc<Mutex<HashMap<u64, PeerSender>>>, buffer: Vec<u8>, exceptions: Vec<u64>, )

pub async fn fetch_block( block_hash: SaitoHash, peer_index: u64, url: String, event_id: u64, sender_to_core: Sender<IoEvent>, current_queries: Arc<Mutex<HashSet<String>>>, client: Client, block_id: BlockId, )

pub async fn send_new_peer( event_id: u64, peer_index: u64, ip: Option<String>, sockets: Arc<Mutex<HashMap<u64, PeerSender>>>, sender: PeerSender, receiver: PeerReceiver, sender_to_core: Sender<IoEvent>, )

pub async fn disconnect_socket( sockets: Arc<Mutex<HashMap<u64, PeerSender>>>, peer_index: PeerIndex, sender_to_core: Sender<IoEvent>, )

pub async fn receive_message_from_peer( receiver: PeerReceiver, sender: Sender<IoEvent>, peer_index: u64, sockets: Arc<Mutex<HashMap<u64, PeerSender>>>, )