support tunneling udp

Cargo.toml

@@ -28,13 +28,14 @@ lazy_static = "1.4"
 async-trait = "0.1"
 byte-pool = { git = "https://github.com/neevek/byte-pool" }
 # rstun = { path = "../rstun" }
-rstun = { git = "https://github.com/neevek/rstun", branch = "dev" }
+rstun = { git = "https://github.com/neevek/rstun" }
 hyper = { version = "0.14", features = ["full"]}
 http = "0.2"
 http-body = "0.4"
 mime_guess = "2.0"
 monolithica = { git = "https://github.com/neevek/monolithica" }
 base64 = "0.22"
+dashmap = "6"
 
 [dev-dependencies]
 jni = "0.19"

README.md

@@ -48,7 +48,7 @@ Examples
 
     `omnip -a socks5://127.0.0.1:8000 -u http://192.168.50.50:9000`
 
-    omnip runs as a SOCKS5 proxy server, which forwards all the proxy requests to the upstream server specified with the `-u|--upstream` option, in this case it simply translates SOCKS5 proxy requests to HTTP proxy requests. the schemes of the upstream can be one of `http`, `socks5`, `socks4` and their QUIC counterparts `http+quic`, `http+socks5` and `http+socks4`.
+    omnip runs as a SOCKS5 proxy server, which forwards all the proxy requests to the upstream server specified with the `-u|--upstream` option, in this case it simply translates SOCKS5 proxy requests to HTTP proxy requests. the schemes of the upstream can be one of `http`, `socks5`, `socks4` and their QUIC counterparts `http+quic`, `socks5+quic` and `socks4+quic`.
 
 3. Running omnip as QUIC secured proxy server:
 

src/bin/omnip.rs

@@ -40,7 +40,7 @@ fn main() -> Result<()> {
         cipher: args.cipher,
         max_idle_timeout_ms: args.max_idle_timeout_ms,
         retry_interval_ms: args.retry_interval_ms,
-        threads: args.threads,
+        workers: args.threads,
     };
 
     let mut server = Server::new(config, common_quic_config);
@@ -109,7 +109,7 @@ struct OmnipArgs {
     #[arg(short = 'a', long, required = true)]
     addr: String,
 
-    /// upstream which the proxy server will relay traffic to based on proxy rules,
+    /// Upstream which the proxy server will relay traffic to based on proxy rules,
     /// [<http|socks5|socks4>://]ip:port for example: http://127.0.0.1:8000, http+quic://127.0.0.1:8000
     #[arg(short = 'u', long, default_value = "")]
     upstream: String,