From 9df10b2063af40aec2fecf86c29a803bf1f36fc2 Mon Sep 17 00:00:00 2001 From: clinx Date: Mon, 24 Feb 2025 17:25:43 +0800 Subject: [PATCH] fix(flashnode): reset test limiter#23061931 Signed-off-by: clinx --- flashnode/flashnode_op_test.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/flashnode/flashnode_op_test.go b/flashnode/flashnode_op_test.go index e3b086313..491f2ff28 100644 --- a/flashnode/flashnode_op_test.go +++ b/flashnode/flashnode_op_test.go @@ -72,7 +72,7 @@ func testTCPCachePrepare(t *testing.T) { flashServer.readLimiter.SetBurst(200) flashServer.readLimiter.SetLimit(20) - + time.Sleep(time.Second) p.Opcode = proto.OpFlashNodeCachePrepare require.NoError(t, p.WriteToConn(conn)) require.NoError(t, r.ReadFromConn(conn, 3)) @@ -122,7 +122,9 @@ func testTCPCacheRead(t *testing.T) { defer conn.Close() p := proto.NewPacketReqID() r := proto.NewPacket() - + flashServer.readLimiter.SetBurst(0) + flashServer.readLimiter.SetLimit(0) + time.Sleep(time.Second) p.Opcode = proto.OpFlashNodeCacheRead require.NoError(t, p.WriteToConn(conn)) require.NoError(t, r.ReadFromConn(conn, 3))