Skip to content

Commit

Permalink
chore: replace debug with trace
Browse files Browse the repository at this point in the history
  • Loading branch information
Sid-Ali Teir authored and JohnTitor committed Oct 23, 2024
1 parent cd2dcd5 commit 67c9ca7
Show file tree
Hide file tree
Showing 4 changed files with 11 additions and 11 deletions.
2 changes: 1 addition & 1 deletion src/codecs.rs
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ impl NetlinkMessageCodec for NetlinkCodec {
where
T: NetlinkDeserializable + Debug,
{
debug!("NetlinkCodec: decoding next message");
trace!("NetlinkCodec: decoding next message");

loop {
// If there's nothing to read, return Ok(None)
Expand Down
10 changes: 5 additions & 5 deletions src/connection.rs
Original file line number Diff line number Diff line change
Expand Up @@ -306,21 +306,21 @@ where
trace!("polling Connection");
let pinned = self.get_mut();

debug!("reading incoming messages");
trace!("reading incoming messages");
pinned.poll_read_messages(cx);

debug!("forwarding unsolicited messages to the connection handle");
trace!("forwarding unsolicited messages to the connection handle");
pinned.forward_unsolicited_messages();

debug!(
trace!(
"forwarding responses to previous requests to the connection handle"
);
pinned.forward_responses();

debug!("handling requests");
trace!("handling requests");
pinned.poll_requests(cx);

debug!("sending messages");
trace!("sending messages");
pinned.poll_send_messages(cx);

trace!("done polling Connection");
Expand Down
4 changes: 2 additions & 2 deletions src/handle.rs
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ where
) -> Result<impl Stream<Item = NetlinkMessage<T>>, Error<T>> {
let (tx, rx) = unbounded::<NetlinkMessage<T>>();
let request = Request::from((message, destination, tx));
debug!("handle: forwarding new request to connection");
trace!("handle: forwarding new request to connection");
UnboundedSender::unbounded_send(&self.requests_tx, request).map_err(
|e| {
// the channel is unbounded, so it can't be full. If this
Expand All @@ -65,7 +65,7 @@ where
) -> Result<(), Error<T>> {
let (tx, _rx) = unbounded::<NetlinkMessage<T>>();
let request = Request::from((message, destination, tx));
debug!("handle: forwarding new request to connection");
trace!("handle: forwarding new request to connection");
UnboundedSender::unbounded_send(&self.requests_tx, request)
.map_err(|_| Error::ConnectionClosed)
}
Expand Down
6 changes: 3 additions & 3 deletions src/protocol/protocol.rs
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ where
message.header.sequence_number,
source.port_number(),
);
debug!("handling messages (request id = {:?})", request_id);
trace!("handling messages (request id = {:?})", request_id);
if let hash_map::Entry::Occupied(entry) =
self.pending_requests.entry(request_id)
{
Expand All @@ -101,7 +101,7 @@ where
) {
let entry_key;
let mut request_id = entry.key();
debug!("handling response to request {:?}", request_id);
trace!("handling response to request {:?}", request_id);

// A request is processed if we receive an Ack, Error,
// Done, Overrun, or InnerMessage without the
Expand Down Expand Up @@ -134,7 +134,7 @@ where
metadata,
};
incoming_responses.push_back(response);
debug!("done handling response to request {:?}", request_id);
trace!("done handling response to request {:?}", request_id);
}

pub fn request(&mut self, request: Request<T, M>) {
Expand Down

0 comments on commit 67c9ca7

Please sign in to comment.