From 86be08df29d7a5ce59fb1e46910c5d1d0351ae13 Mon Sep 17 00:00:00 2001
From: pfi79 <pfi79@mail.ru>
Date: Mon, 13 Dec 2021 21:54:53 +0300
Subject: [PATCH] fix restart timers after change leader (#477)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-authored-by: Фёдор Партанский <partanskiy.f@n-t.io>
Co-authored-by: C0rWin <artem@bargr.net>
---
 internal/bft/requestpool.go | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/internal/bft/requestpool.go b/internal/bft/requestpool.go
index a87cb0b5..5345911a 100644
--- a/internal/bft/requestpool.go
+++ b/internal/bft/requestpool.go
@@ -376,9 +376,10 @@ func (rp *Pool) RestartTimers() {
 	for reqInfo, element := range rp.existMap {
 		item := element.Value.(*requestItem)
 		item.timeout.Stop()
+		ri := reqInfo
 		to := time.AfterFunc(
 			rp.options.ForwardTimeout,
-			func() { rp.onRequestTO(item.request, reqInfo) },
+			func() { rp.onRequestTO(item.request, ri) },
 		)
 		item.timeout = to
 	}
@@ -414,7 +415,7 @@ func (rp *Pool) onRequestTO(request []byte, reqInfo types.RequestInfo) {
 		return
 	}
 
-	//start a second timeout
+	// start a second timeout
 	item := element.Value.(*requestItem)
 	item.timeout = time.AfterFunc(
 		rp.options.ComplainTimeout,
@@ -450,7 +451,7 @@ func (rp *Pool) onLeaderFwdRequestTO(request []byte, reqInfo types.RequestInfo)
 		return
 	}
 
-	//start a third timeout
+	// start a third timeout
 	item := element.Value.(*requestItem)
 	item.timeout = time.AfterFunc(
 		rp.options.AutoRemoveTimeout,