p2p_channel 0.5.0

use crate::channel::{Channel, Status};
use crate::idle::Idle;
use crate::punch::Punch;
use crossbeam::atomic::AtomicCell;
use crossbeam::channel::bounded;
use crossbeam::sync::Parker;
use crossbeam_skiplist::SkipMap;
use std::hash::Hash;
use std::io;
use std::sync::Arc;

pub struct Boot {}

impl Boot {
    /// size指定对称网络类型时用于打洞的端口数量，根据需要设置，较大的相对打洞速度越快，太大会导致网络压力从而引发丢包和限流
    /// read_idle/write_idle指定添加到路由表的路由读/写超时时间

    pub fn new<ID: Eq + Hash>(
        size: usize,
        read_idle: i64,
        write_idle: i64,
    ) -> io::Result<(Channel<ID>, Punch<ID>, Idle<ID>)> {
        let (cone_sender, cone_receiver) = bounded(1);
        let (symmetric_sender, symmetric_receiver) = bounded(1);
        let direct_route_table_time = Arc::new(SkipMap::new());
        let parker = Parker::new();
        let un_parker = parker.unparker().clone();
        let status = Arc::new(AtomicCell::new(Status::Cone));
        let channel = Channel::<ID>::new(
            size,
            cone_sender,
            symmetric_sender,
            direct_route_table_time.clone(),
            un_parker,
            status.clone(),
        )?;
        let sender = channel.sender()?;
        let punch = Punch::new(cone_receiver, symmetric_receiver, sender);
        let idle = Idle::new(
            read_idle,
            write_idle,
            parker,
            direct_route_table_time,
            status,
        );
        Ok((channel, punch, idle))
    }
}