diff --git a/lib/files/files.go b/lib/files/files.go index d469ae2..d51db87 100644 --- a/lib/files/files.go +++ b/lib/files/files.go @@ -7,7 +7,6 @@ import ( func CheckNotExist(src string) bool { _, err := os.Stat(src) - return os.IsNotExist(err) } diff --git a/lib/idgenerator/snowflake_test.go b/lib/idgenerator/snowflake_test.go index 727319e..9042101 100644 --- a/lib/idgenerator/snowflake_test.go +++ b/lib/idgenerator/snowflake_test.go @@ -5,7 +5,7 @@ import "testing" func TestMGenerator(t *testing.T) { gen := MakeGenerator("a") ids := make(map[int64]struct{}) - size := int(maxSequence) - 1 + size := int(1e6) for i := 0; i < size; i++ { id := gen.NextId() _, ok := ids[id] diff --git a/redis/client/client.go b/redis/client/client.go index 6e30a10..5b538b2 100644 --- a/redis/client/client.go +++ b/redis/client/client.go @@ -134,6 +134,7 @@ func (client *Client) doHeartbeat() { request := &Request{ args: [][]byte{[]byte("PING")}, heartbeat: true, + waiting: &wait.Wait{}, } request.waiting.Add(1) client.working.Add(1) diff --git a/redis/client/client_test.go b/redis/client/client_test.go index 500a82b..61bba97 100644 --- a/redis/client/client_test.go +++ b/redis/client/client_test.go @@ -60,6 +60,7 @@ func TestClient(t *testing.T) { } } + client.doHeartbeat() // random do heartbeat result = client.Send([][]byte{ []byte("GET"), []byte("a"),