Stream rapid reset count handling (#54)

Author: fafhrd91

src/connection.rs

@@ -696,7 +696,7 @@ impl RecvHalfConnection {
         let count = self.0.rst_count.get() + 1;
         let streams_count = self.0.streams_count.get();
         if streams_count >= 10 && count >= streams_count >> 1 {
-            Err(Either::Left(ConnectionError::ConcurrencyOverflow))
+            Err(Either::Left(ConnectionError::StreamResetsLimit))
         } else {
             self.0.rst_count.set(count);
             Ok(())

src/dispatcher.rs

@@ -71,7 +71,12 @@ where
             }
             Err(Either::Right(err)) => {
                 let (stream, kind) = err.into_inner();
-                log::error!("{}: Failed to handle message: {:?}", stream.tag(), stream);
+                log::error!(
+                    "{}: Failed to handle message, err: {:?} stream: {:?}",
+                    stream.tag(),
+                    kind,
+                    stream
+                );
 
                 stream.set_failed_stream(kind.into());
                 self.connection

src/error.rs

@@ -33,6 +33,8 @@ pub enum ConnectionError {
     WindowValueOverflow,
     #[error("Max concurrent streams count achieved")]
     ConcurrencyOverflow,
+    #[error("Stream rapid reset count achieved")]
+    StreamResetsLimit,
     /// Keep-alive timeout
     #[error("Keep-alive timeout")]
     KeepaliveTimeout,
@@ -72,6 +74,8 @@ impl ConnectionError {
                 .set_data("Updated value for window is overflowed"),
             ConnectionError::ConcurrencyOverflow => GoAway::new(Reason::FLOW_CONTROL_ERROR)
                 .set_data("Max concurrent streams count achieved"),
+            ConnectionError::StreamResetsLimit => GoAway::new(Reason::FLOW_CONTROL_ERROR)
+                .set_data("Stream rapid reset count achieved"),
             ConnectionError::KeepaliveTimeout => {
                 GoAway::new(Reason::NO_ERROR).set_data("Keep-alive timeout")
             }