The buffer of decoder grows until it panic

[another-s347]

Version

0.1.0-alpha.1

Platform

Linux pc 4.19.69-1-MANJARO #1 SMP PREEMPT Thu Aug 29 08:51:46 UTC 2019 x86_64 GNU/Linux

Description

It seems decoder didn't free its buffer in time so it gets panic very soon when transmitting messages continuously.
Backtrace:

tokio-runtime-worker-4' panicked at 'assertion failed: self.remaining_mut() >= src.remaining()', /home/skye/.cargo/registry/src/github.com-1ecc6299db9ec823/bytes-0.4.12/src/buf/buf_mut.rs:230:9
stack backtrace:                                                                                                                                                                                                                                                                      
   0:     0x55b8f58d6be2 - backtrace::backtrace::libunwind::trace::hc13eee94dc9acf87                                                                       
                               at /cargo/registry/src/github.com-1ecc6299db9ec823/backtrace-0.3.35/src/backtrace/libunwind.rs:88                           
   1:     0x55b8f58d6be2 - backtrace::backtrace::trace_unsynchronized::heb95bad2d38970b7                                                                   
                               at /cargo/registry/src/github.com-1ecc6299db9ec823/backtrace-0.3.35/src/backtrace/mod.rs:66                                 
   2:     0x55b8f58d6be2 - std::sys_common::backtrace::_print::hc7c53d16b772cd09                                                                           
                               at src/libstd/sys_common/backtrace.rs:47                                                                                    
   3:     0x55b8f58d6be2 - std::sys_common::backtrace::print::h1a5c96cc746359e4                                                                            
                               at src/libstd/sys_common/backtrace.rs:36                                                                                    
   4:     0x55b8f58d6be2 - std::panicking::default_hook::{{closure}}::h09e52b8c91cd08d3                                                                    
                               at src/libstd/panicking.rs:200                                                                                              
   5:     0x55b8f58d68c6 - std::panicking::default_hook::h683e3e2fe7c55791                                                                                 
                               at src/libstd/panicking.rs:214                                                                                              
   6:     0x55b8f58d7335 - std::panicking::rust_panic_with_hook::h185be11cf56dd6c5                                                                         
                               at src/libstd/panicking.rs:477                                                                                              
   7:     0x55b8f5861545 - std::panicking::begin_panic::h26f44ad2be4189d7                                                                                  
                               at /rustc/9eae1fc0ea9b00341b8fe191582c4decb5cb86a3/src/libstd/panicking.rs:411                                              
   8:     0x55b8f4f3c1e6 - bytes::buf::buf_mut::BufMut::put::h1eda9ff079116541                                                                             
                               at /home/skye/rusty-p4/benchmark/<::std::macros::panic macros>:3                                                            
   9:     0x55b8f4e29730 - <tonic::codec::decode::Streaming<T> as futures_core::stream::Stream>::poll_next::hbf98f28ee14a6dcc                              
                               at /home/skye/.cargo/registry/src/github.com-1ecc6299db9ec823/tonic-0.1.0-alpha.1/src/codec/decode.rs:237

[LucioFranco]

@another-s347 hi! Do you know how you were able to produce this?

I've just run into it, let me take a look...

[LucioFranco]

@another-s347 hi this should be fixed on master.