From 780a4d2c8ea7bd2e8a331c51a3f6ef28ba5625a5 Mon Sep 17 00:00:00 2001 From: wt Date: Mon, 23 Aug 2021 22:01:51 +0800 Subject: [PATCH] Update script of run_go_codecov (#7248) Signed-off-by: wangting0128 --- internal/util/rocksmq/server/rocksmq/rocksmq_impl.go | 1 + scripts/run_go_codecov.sh | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index 3170cb77eb..b784e71e88 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -287,6 +287,7 @@ func (rmq *rocksmq) ExistConsumerGroup(topicName, groupName string) (bool, *Cons // keyExist = rmq.checkKeyExist(key) // } // } + if rmq.checkKeyExist(key) { if vals, ok := rmq.consumers.Load(topicName); ok { for _, v := range vals.([]*Consumer) { diff --git a/scripts/run_go_codecov.sh b/scripts/run_go_codecov.sh index c9d5f25a44..9110b10147 100755 --- a/scripts/run_go_codecov.sh +++ b/scripts/run_go_codecov.sh @@ -4,7 +4,7 @@ set -e echo "" > coverage.txt for d in $(go list ./internal... | grep -v vendor); do - go test -race -coverprofile=profile.out -covermode=atomic "$d" + go test -race -coverpkg=./... -coverprofile=profile.out -covermode=atomic "$d" if [ -f profile.out ]; then cat profile.out >> coverage.txt rm profile.out