Merge pull request #32 from weibocom/dev

Dev
weibocom · Nov 5, 2021 · 3a8424b · 3a8424b
2 parents 724144f + 191c357
commit 3a8424b
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 2 deletions.
diff --git a/endpoint/src/cacheservice/topology/inner.rs b/endpoint/src/cacheservice/topology/inner.rs
@@ -80,7 +80,7 @@ impl<T> Inner<T> {
         sorted.sort_by(|a, b| a.1.cmp(&b.1));
         let mut layers = Vec::with_capacity(sorted.len());
         for (role, pool, streams) in sorted {
-            log::info!(
+            log::debug!(
                 "builded for layer:{:?}, pool:{}, addr:{:?}",
                 role,
                 pool,

diff --git a/stream/src/io/receiver.rs b/stream/src/io/receiver.rs
@@ -77,7 +77,12 @@ impl Receiver {
         if let Some(ref mut req) = self.req {
             req.set_request_id(*rid);
             metric.req_done(req.operation(), req.len(), req.keys().len());
-            log::debug!("parsed: {} => {}", self.buff, req);
+            log::debug!(
+                "parsed client req/{:?}:  {} => {}",
+                req.id(),
+                self.buff,
+                req
+            );
             ready!(writer.as_mut().poll_write(cx, &req))?;
             self.buff.advance_read(req.len());
         }

diff --git a/stream/src/io/sender.rs b/stream/src/io/sender.rs
@@ -75,6 +75,13 @@ impl Sender {
         while self.buf.len() > 0 {
             let data = self.buf.as_bytes();
             let n = ready!(w.as_mut().poll_write(cx, data))?;
+            log::debug!(
+                "flush to client, rid:{:?}/{}/{} - {:?}",
+                rid,
+                n,
+                data.len(),
+                data
+            );
             if n == 0 {
                 return Poll::Ready(Err(Error::new(ErrorKind::WriteZero, "write zero response")));
             }