清除测试grpc链接使用情况打印的测试日志

nacos-group · May 29, 2024 · 720aa4f · 720aa4f
1 parent 837dc6b
commit 720aa4f
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/loadtest/src/bin/multiple_grpc_conn.rs b/loadtest/src/bin/multiple_grpc_conn.rs
@@ -16,7 +16,7 @@ async fn main() {
     env_logger::init();
     let namespace_id = "public".to_owned();
     let mut list = vec![];
-    for i in 0..CONN_COUNT {
+    for _i in 0..CONN_COUNT {
         let auth_info = None;
         let client = ClientBuilder::new()
             .set_endpoint_addrs("127.0.0.1:8848")

diff --git a/src/grpc/bistream_conn.rs b/src/grpc/bistream_conn.rs
@@ -35,7 +35,7 @@ impl BiStreamConn {
     }
 
     pub fn receive(&mut self, ctx: &mut Context<Self>) {
-        println!("BiStreamConn start receive");
+        //println!("BiStreamConn start receive");
         if let Some(mut receiver_stream) = self.receiver_stream.replace(None) {
             let manage = self.manage.clone();
             let client_id = self.client_id.clone();
@@ -52,7 +52,7 @@ impl BiStreamConn {
             .into_actor(self)
             .map(|_, _, ctx| {
                 //debug
-                println!("stop at receive!");
+                //println!("stop at receive!");
                 ctx.stop();
             })
             .spawn(ctx);
@@ -73,13 +73,13 @@ impl BiStreamConn {
         let sender = self.sender.clone();
         async move {
             //debug
-            println!("close_stream_and_stop! 01");
+            //println!("close_stream_and_stop! 01");
             sender.send(Err(tonic::Status::cancelled("close"))).await
         }
         .into_actor(self)
         .map(|_, _, ctx| {
             //debug
-            println!("stop at close_stream_and_stop!");
+            //println!("stop at close_stream_and_stop!");
             ctx.stop();
         })
         .wait(ctx);

diff --git a/src/grpc/bistream_manage.rs b/src/grpc/bistream_manage.rs
@@ -230,11 +230,11 @@ impl Handler<BiStreamManageCmd> for BiStreamManage {
                 if let Some(naming_addr) = &self.naming_addr {
                     naming_addr.do_send(NamingCmd::RemoveClient(client_id));
                 }
-                println!("|ConnClose|conn size: {}",self.conn_cache.len());
+                //println!("|ConnClose|conn size: {}",self.conn_cache.len());
             }
             BiStreamManageCmd::AddConn(client_id, conn) => {
                 self.add_conn(client_id, conn.start());
-                println!("|AddConn|conn size: {}",self.conn_cache.len());
+                //println!("|AddConn|conn size: {}",self.conn_cache.len());
             }
             BiStreamManageCmd::ActiveClinet(client_id) => {
                 self.active_client(client_id)?;