tcp

src/main.rs

@@ -68,7 +68,7 @@ fn main() -> Result<()> {
             .unique_by(|r| r.config.src_port)
         {
             println!("listen on port {}", router.config.src_port);
-            let socket = router.listen_tcp().unwrap();
+            let socket = router.listen_tcp();
             s.spawn(move |s| {
                 // listen 或 accept 出错直接 panic
                 loop {

src/router.rs

@@ -92,14 +92,14 @@ impl Router {
         }
     }
 
-    pub fn listen_tcp(&self) -> Result<Socket> {
+    pub fn listen_tcp(&self) -> Socket {
         // listener
-        let result = Socket::new(self.config.family, Type::STREAM, Some(Protocol::TCP))?;
+        let result = Socket::new(self.config.family, Type::STREAM, Some(Protocol::TCP)).unwrap();
         let addr = Router::bind_addr(&self.config);
-        result.set_reuse_address(true)?;
-        result.bind(&addr)?;
-        result.listen(100)?;
-        Ok(result)
+        result.set_reuse_address(true).unwrap();
+        result.bind(&addr).unwrap();
+        result.listen(100).unwrap();
+        result
     }
 
     pub fn connect_tcp(&self) -> Result<Socket> {