From 1b4231b4e8ae5d10f48ee44a8737077d43a72e22 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=B4=AB=E6=99=B4?= Date: Tue, 17 Aug 2021 11:56:11 +0800 Subject: [PATCH] Add yaml file of codecov (#7124) * Add yaml file of codecov Signed-off-by: wangting0128 * Update code of codecov Signed-off-by: wangting0128 --- codecov.yml | 33 +++++++++++++++++++ .../rocksmq/server/rocksmq/rocksmq_impl.go | 1 + 2 files changed, 34 insertions(+) create mode 100644 codecov.yml diff --git a/codecov.yml b/codecov.yml new file mode 100644 index 0000000000..39257619ee --- /dev/null +++ b/codecov.yml @@ -0,0 +1,33 @@ +coverage: + status: + project: + default: + # basic + target: auto + threshold: 0% + base: auto + flags: + - unit + paths: + - "src" + # advanced settings + branches: + - master + if_ci_failed: error #success, failure, error, ignore + informational: false + only_pulls: false + patch: + # basic + target: 70% + threshold: 0% + base: auto + flags: + - unit + paths: + - "src" + # advanced settings + branches: + - master + if_ci_failed: failure #success, failure, error, ignore + informational: false + only_pulls: false 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) {