mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-03 04:47:39 +03:00
Code Issues Projects Releases Packages Wiki Activity

more logging

Browse source
This commit is contained in:
Nikolay Kim 2020-07-28 16:40:00 +06:00
parent b816fbde44
commit deeccb9f60
2 changed files with 7 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
ntex-codec/src/bcodec.rs
View file

@ -1,4 +1,4 @@
use bytes::{Bytes, BytesMut, Buf};
use bytes::{Buf, Bytes, BytesMut};
use std::io;
use super::{Decoder, Encoder};

6
ntex/src/util/framed.rs
View file

@ -221,6 +221,7 @@ where
let item = match self.framed.next_item(cx) {
Poll::Ready(Some(Ok(el))) => el,
Poll::Ready(Some(Err(err))) => {
log::trace!("Framed decode error");
self.state = FramedState::Shutdown(Some(
DispatcherError::Decoder(err),
));
@ -261,6 +262,7 @@ where
match Pin::new(&mut self.rx).poll_next(cx) {
Poll::Ready(Some(Ok(msg))) => {
if let Err(err) = self.framed.write(msg) {
log::trace!("Framed write error: {:?}", err);
self.state = FramedState::Shutdown(Some(
DispatcherError::Encoder(err),
));
@ -281,6 +283,7 @@ where
match Pin::new(sink).poll_next(cx) {
Poll::Ready(Some(msg)) => {
if let Err(err) = self.framed.write(msg) {
log::trace!("Framed write error from sink: {:?}", err);
self.state = FramedState::Shutdown(Some(
DispatcherError::Encoder(err),
));
@ -337,6 +340,7 @@ where
match Pin::new(&mut self.rx).poll_next(cx) {
Poll::Ready(Some(Ok(msg))) => {
if let Err(err) = self.framed.write(msg) {
log::trace!("Framed write message error: {:?}", err);
self.state = FramedState::Shutdown(Some(
DispatcherError::Encoder(err),
));
@ -344,6 +348,7 @@ where
}
}
Poll::Ready(Some(Err(err))) => {
log::trace!("Sink poll error");
self.state = FramedState::Shutdown(Some(err.into()));
continue;
}
@ -360,6 +365,7 @@ where
Poll::Ready(_) => (),
}
};
log::trace!("Framed flushed, shutdown");
self.state = FramedState::Shutdown(err.take());
}
FramedState::Shutdown(ref mut err) => {