Struct chain_p2p::p2p::P2PManager
[−]
[src]
pub struct P2PManager { /* fields omitted */ }
Methods
impl P2PManager[src]
fn new(cap: usize) -> P2PManager[src]
fn set_listen_addr(&mut self, addr: String) -> Result<(), &'static str>[src]
fn listen_addr(&mut self) -> Result<String, &'static str>[src]
fn server_run(&mut self, addr: &str)[src]
在子线程中运行服务器模式，使用时需要主线程 loop{}
fn server_write(
&mut self,
client: SocketAddr,
vec: Vec<u8>
) -> Result<usize, &'static str>[src]
&mut self,
client: SocketAddr,
vec: Vec<u8>
) -> Result<usize, &'static str>
将发送的内容传至对应的写缓存，子线程循环将缓存内容发送至socket
fn server_read(
&mut self,
client: SocketAddr
) -> Result<Option<Vec<u8>>, &'static str>[src]
&mut self,
client: SocketAddr
) -> Result<Option<Vec<u8>>, &'static str>
从对应的读缓存中读取相应内容，子线程将socket中的内容传至缓存中
fn server_table(&mut self) -> Result<Vec<SocketAddr>, &'static str>[src]
查看所有连接的对象 client模式没有加入
fn server_conn_table(&mut self) -> Result<Vec<Vec<u8>>, &'static str>[src]
fn server_update_conn_table(
&mut self,
client: SocketAddr,
conn_addr: Vec<u8>
) -> Result<(), &'static str>[src]
&mut self,
client: SocketAddr,
conn_addr: Vec<u8>
) -> Result<(), &'static str>
fn server_remove(&mut self, client: SocketAddr) -> Result<(), &'static str>[src]
fn create_session(&mut self, addr: &str) -> Result<(), Error>[src]
client模式下与peer建立连接
fn client_dis(&mut self, addr: &str) -> Result<(), &'static str>[src]
fn client_read(&mut self, addr: &str) -> Result<Option<Vec<u8>>, &'static str>[src]
从对应的读缓存获取信息 要对无效信息进行删除 读取一次有效的信息，无效信息为空
fn client_write(
&mut self,
addr: &str,
vec: Vec<u8>
) -> Result<Option<usize>, &'static str>[src]
&mut self,
addr: &str,
vec: Vec<u8>
) -> Result<Option<usize>, &'static str>
从将内容传至对应的写缓存中