This is an automated email from the ASF dual-hosted git repository.
jihuayu pushed a commit to branch unstable
in repository https://gitbox.apache.org/repos/asf/kvrocks.git
The following commit(s) were added to refs/heads/unstable by this push:
new dd75ac8e5 perf(tests): shorten list blocking timeout cases (#3539)
dd75ac8e5 is described below
commit dd75ac8e57c2d1ee65863c003838fe8ab2e03489
Author: Reilly.tang <[email protected]>
AuthorDate: Mon Jul 20 19:31:27 2026 +0800
perf(tests): shorten list blocking timeout cases (#3539)
fix #3529
Assisted-by: Codex/GPT-5
Co-authored-by: 纪华裕 <[email protected]>
---
tests/gocase/unit/type/list/list_test.go | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/tests/gocase/unit/type/list/list_test.go
b/tests/gocase/unit/type/list/list_test.go
index 2fe9f36dd..4f79d5359 100644
--- a/tests/gocase/unit/type/list/list_test.go
+++ b/tests/gocase/unit/type/list/list_test.go
@@ -42,6 +42,8 @@ var largeValue = map[string]string{
"linkedList": strings.Repeat("hello", 4),
}
+const blockingTimeout = "0.2"
+
func TestLTRIM(t *testing.T) {
configOptions := []util.ConfigOptions{
{
@@ -485,7 +487,7 @@ func testList(t *testing.T, configs
util.KvrocksServerConfigs) {
rd := srv.NewTCPClient()
defer func() { require.NoError(t, rd.Close()) }()
require.NoError(t, rdb.Del(ctx, "blist1",
"blist2").Err())
- require.NoError(t, rd.WriteArgs(popType, "blist1",
"blist2", "1"))
+ require.NoError(t, rd.WriteArgs(popType, "blist1",
"blist2", blockingTimeout))
rd.MustMatch(t, "")
})
@@ -1491,7 +1493,7 @@ func testList(t *testing.T, configs
util.KvrocksServerConfigs) {
rd := srv.NewTCPClient()
defer func() { require.NoError(t, rd.Close()) }()
require.NoError(t, rdb.Del(ctx, key1, key2).Err())
- require.NoError(t, rd.WriteArgs("blmpop", "1", "2",
key1, key2, direction))
+ require.NoError(t, rd.WriteArgs("blmpop",
blockingTimeout, "2", key1, key2, direction))
rd.MustMatch(t, "")
})