diff --git a/src/protocol/PacketDecoder.cpp b/src/protocol/PacketDecoder.cpp index d4e8d7a..8c4824f 100644 --- a/src/protocol/PacketDecoder.cpp +++ b/src/protocol/PacketDecoder.cpp @@ -28,9 +28,18 @@ PacketDecoder::~PacketDecoder() { } void PacketDecoder::reset() { - std::lock_guard buffer_lock(this->packet_buffer_lock); - for(auto& buffer : this->_command_fragment_buffers) { - buffer.reset(); + { + std::lock_guard buffer_lock(this->packet_buffer_lock); + for(auto& buffer : this->_command_fragment_buffers) { + buffer.reset(); + } + } + + { + std::lock_guard estimator_lock{this->incoming_generation_estimator_lock}; + for(auto& estimator : this->incoming_generation_estimators) { + estimator.reset(); + } } }