Move INFO level traces to DEBUG (#537)

INFO level traces/logs are usually reserved for the application.

All of the existing INFO level traces were changed, except for those in
examples.

resolves #536

Co-authored-by: Tim <tikue@google.com>

Author: azdle

tarpc/src/client.rs

@@ -419,7 +419,7 @@ where
         cx: &mut Context<'_>,
     ) -> Poll<Option<Result<DispatchRequest<Req, Resp>, ChannelError<C::Error>>>> {
         if self.in_flight_requests().len() >= self.config.max_in_flight_requests {
-            tracing::info!(
+            tracing::debug!(
                 "At in-flight request capacity ({}/{}).",
                 self.in_flight_requests().len(),
                 self.config.max_in_flight_requests
@@ -437,7 +437,7 @@ where
                 Some(request) => {
                     if request.response_completion.is_closed() {
                         let _entered = request.span.enter();
-                        tracing::info!("AbortRequest");
+                        tracing::debug!("AbortRequest");
                         continue;
                     }
 
@@ -522,7 +522,7 @@ where
             .insert_request(request_id, ctx, span.clone(), response_completion)
             .expect("Request IDs should be unique");
         match self.start_send(request) {
-            Ok(()) => tracing::info!("SendRequest"),
+            Ok(()) => tracing::debug!("SendRequest"),
             Err(e) => {
                 self.in_flight_requests()
                     .complete_request(request_id, Err(RpcError::Send(Box::new(e))));
@@ -553,7 +553,7 @@ where
         };
         self.start_send(cancel)
             .map_err(|e| ChannelError::Write(Arc::new(e)))?;
-        tracing::info!("CancelRequest");
+        tracing::debug!("CancelRequest");
         Poll::Ready(Some(Ok(())))
     }
 
@@ -564,7 +564,7 @@ where
             response.message.map_err(RpcError::Server),
         ) {
             let _entered = span.enter();
-            tracing::info!("ReceiveResponse");
+            tracing::debug!("ReceiveResponse");
             return true;
         }
         false
@@ -594,7 +594,7 @@ where
                 }) => {
                     let _entered = span.enter();
                     if response_completion.is_closed() {
-                        tracing::info!("AbortRequest");
+                        tracing::debug!("AbortRequest");
                     } else {
                         tracing::warn!("RpcError::Channel");
                         let _ = response_completion.send(Err(RpcError::Channel(e.clone())));
@@ -612,15 +612,15 @@ where
         loop {
             match (self.as_mut().pump_read(cx)?, self.as_mut().pump_write(cx)?) {
                 (Poll::Ready(None), _) => {
-                    tracing::info!("Shutdown: read half closed, so shutting down.");
+                    tracing::debug!("Shutdown: read half closed, so shutting down.");
                     return Poll::Ready(Ok(()));
                 }
                 (read, Poll::Ready(None)) => {
                     if self.in_flight_requests.is_empty() {
-                        tracing::info!("Shutdown: write half closed, and no requests in flight.");
+                        tracing::debug!("Shutdown: write half closed, and no requests in flight.");
                         return Poll::Ready(Ok(()));
                     }
-                    tracing::info!(
+                    tracing::debug!(
                         "Shutdown: write half closed, and {} requests in flight.",
                         self.in_flight_requests().len()
                     );
@@ -648,7 +648,7 @@ where
     ) -> Poll<Result<(), ChannelError<C::Error>>> {
         loop {
             if let Some(e) = self.terminal_error_mut() {
-                tracing::info!("RpcError::Channel");
+                tracing::debug!("RpcError::Channel");
                 let e: ChannelError<C::Error> = e
                     .clone()
                     .downcast()

tarpc/src/server.rs

@@ -220,7 +220,7 @@ where
             request.context.trace_context.new_child()
         });
         let entered = span.enter();
-        tracing::info!("ReceiveRequest");
+        tracing::debug!("ReceiveRequest");
         let start = self.in_flight_requests_mut().start_request(
             request.id,
             request.context.deadline,
@@ -450,7 +450,7 @@ where
                 Poll::Ready(Some(request_id)) => {
                     if let Some(span) = self.in_flight_requests_mut().remove_request(request_id) {
                         let _entered = span.enter();
-                        tracing::info!("ResponseCancelled");
+                        tracing::debug!("ResponseCancelled");
                     }
                     Ready
                 }
@@ -545,7 +545,7 @@ where
             .remove_request(response.request_id)
         {
             let _entered = span.enter();
-            tracing::info!("SendResponse");
+            tracing::debug!("SendResponse");
             self.project()
                 .transport
                 .start_send(response)
@@ -650,7 +650,7 @@ where
                 response_guard.cancel = true;
                 {
                     let _entered = span.enter();
-                    tracing::info!("BeginRequest");
+                    tracing::debug!("BeginRequest");
                 }
                 InFlightRequest {
                     request,
@@ -884,13 +884,13 @@ impl<Req, Res> InFlightRequest<Req, Res> {
         let _ = Abortable::new(
             async move {
                 let message = serve.serve(context, message).await;
-                tracing::info!("CompleteRequest");
+                tracing::debug!("CompleteRequest");
                 let response = Response {
                     request_id,
                     message,
                 };
                 let _ = response_tx.send(response).await;
-                tracing::info!("BufferResponse");
+                tracing::debug!("BufferResponse");
             },
             abort_registration,
         )
@@ -1097,7 +1097,7 @@ mod tests {
         }
         impl<Resp> AfterRequest<Resp> for PrintLatency {
             async fn after(&mut self, _: &mut context::Context, _: &mut Result<Resp, ServerError>) {
-                tracing::info!("Elapsed: {:?}", self.start.elapsed());
+                tracing::debug!("Elapsed: {:?}", self.start.elapsed());
             }
         }
 

tarpc/src/server/in_flight_requests.rs

@@ -74,7 +74,7 @@ impl InFlightRequests {
             self.request_data.compact(0.1);
             abort_handle.abort();
             self.deadlines.remove(&deadline_key);
-            tracing::info!("ReceiveCancel");
+            tracing::debug!("ReceiveCancel");
             true
         } else {
             false

tarpc/src/server/limits/channels_per_key.rs

@@ -16,7 +16,7 @@ use std::{
     collections::hash_map::Entry, convert::TryFrom, fmt, hash::Hash, marker::Unpin, pin::Pin,
 };
 use tokio::sync::mpsc;
-use tracing::{debug, info, trace};
+use tracing::{debug, trace};
 
 /// An [`Incoming`](crate::server::incoming::Incoming) stream that drops new channels based on
 /// per-key limits.
@@ -198,7 +198,7 @@ where
             Entry::Occupied(mut o) => {
                 let count = o.get().strong_count();
                 if count >= usize::try_from(*self_.channels_per_key).unwrap() {
-                    info!(
+                    debug!(
                         channel_filter_key = %key,
                         open_channels = count,
                         max_open_channels = *self_.channels_per_key,

tarpc/src/server/limits/requests_per_channel.rs

@@ -60,7 +60,7 @@ where
             match ready!(self.as_mut().project().inner.poll_next(cx)?) {
                 Some(r) => {
                     let _entered = r.span.enter();
-                    tracing::info!(
+                    tracing::debug!(
                         in_flight_requests = self.as_mut().in_flight_requests(),
                         "ThrottleRequest",
                     );