chore: release v1.1.2

.github/workflows/deploy-manually.yml

@@ -18,7 +18,7 @@ on:
         required: true
       version:
         description: 'Asset version to deploy'
-        default: 'v1.1.1'
+        default: 'v1.1.2'
         required: true
       arch:
         description: 'Asset binary architecture (Rust format)'

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "bp"
-version = "1.1.1"
+version = "1.1.2"
 authors = ["Micooz Lee <[email protected]>"]
 description = "bp is a lightweight and efficient proxy written in pure Rust."
 repository = "https://github.com/micooz/bp"

USAGE.txt

@@ -1,4 +1,4 @@
-bp 1.1.1
+bp 1.1.2
 Lightweight and efficient proxy written in pure Rust
 
 USAGE:

bp-cli/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "bp-cli"
-version = "1.1.1"
+version = "1.1.2"
 edition = "2021"
 
 [features]

bp-cli/src/bootstrap.rs

@@ -99,15 +99,18 @@ async fn start_main_service(opts: Options, sender_ready: Sender<StartupInfo>) ->
     });
 
     let handle = tokio::spawn(async move {
-        let cnt = Arc::new(Mutex::new(Counter::default()));
+        let mut total_cnt = 0usize;
+        let live_cnt = Arc::new(Mutex::new(Counter::default()));
 
         while let Some(socket) = receiver.recv().await {
             if socket.is_none() {
                 break;
             }
 
-            let cnt = cnt.clone();
-            cnt.lock().inc();
+            total_cnt += 1;
+
+            let live_cnt = live_cnt.clone();
+            live_cnt.lock().inc();
 
             let socket = socket.unwrap();
             let opts = opts.clone();
@@ -116,7 +119,12 @@ async fn start_main_service(opts: Options, sender_ready: Sender<StartupInfo>) ->
             tokio::spawn(async move {
                 let peer_addr = socket.peer_addr();
 
-                log::info!("[{}] connected, {} live connections", peer_addr, cnt.lock());
+                log::info!(
+                    "[{}] connected, {} live connections, {} in total",
+                    peer_addr,
+                    live_cnt.lock(),
+                    total_cnt
+                );
 
                 let mut conn = Connection::new(socket, opts);
 
@@ -125,9 +133,14 @@ async fn start_main_service(opts: Options, sender_ready: Sender<StartupInfo>) ->
                     let _ = conn.close().await;
                 }
 
-                cnt.lock().dec();
+                live_cnt.lock().dec();
 
-                log::info!("[{}] closed, {} live connections", peer_addr, cnt.lock());
+                log::info!(
+                    "[{}] closed, {} live connections, {} in total",
+                    peer_addr,
+                    live_cnt.lock(),
+                    total_cnt
+                );
             });
         }
     });

bp-core/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "bp-core"
-version = "1.1.1"
+version = "1.1.2"
 edition = "2021"
 
 [dependencies]

bp-core/src/net/connection.rs

@@ -152,7 +152,7 @@ impl Connection {
 
             if !acl.is_host_hit(&dest_addr_host) {
                 log::warn!(
-                    "[{}] [{}] [{}] is not matched in white list",
+                    "[{}] [{}] [{}] is NOT matched in white list",
                     self.peer_addr,
                     self.inbound.socket_type(),
                     dest_addr_host,

e2e/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "e2e"
-version = "1.1.1"
+version = "1.1.2"
 authors = ["Micooz Lee <[email protected]>"]
 description = "bp is a lightweight and efficient proxy written in pure Rust."
 repository = "https://github.com/micooz/bp"