You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2022/08/25 01:30:24 UTC
[inlong] branch master updated: [INLONG-5672][TubeMQ] Add SetLogPrintLevel() in TubeMQServiceConfig class (#5673)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 05286b7ee [INLONG-5672][TubeMQ] Add SetLogPrintLevel() in TubeMQServiceConfig class (#5673)
05286b7ee is described below
commit 05286b7eec00a7c78cac2a7782b5095026f10a53
Author: Goson Zhang <46...@qq.com>
AuthorDate: Thu Aug 25 09:30:19 2022 +0800
[INLONG-5672][TubeMQ] Add SetLogPrintLevel() in TubeMQServiceConfig class (#5673)
---
.../tubemq-client-cpp/example/consumer/test_consumer.cc | 1 +
.../tubemq-client-cpp/include/tubemq/tubemq_config.h | 1 +
.../tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc | 5 ++++-
3 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/example/consumer/test_consumer.cc b/inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/example/consumer/test_consumer.cc
index b2dea441f..10b83111a 100644
--- a/inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/example/consumer/test_consumer.cc
+++ b/inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/example/consumer/test_consumer.cc
@@ -74,6 +74,7 @@ int main(int argc, char* argv[]) {
topic_list.insert(topic_name);
ConsumerConfig consumer_config;
TubeMQServiceConfig serviceConfig;
+ serviceConfig.SetLogPrintLevel(3);
consumer_config.SetRpcReadTimeoutMs(20000);
result = consumer_config.SetMasterAddrInfo(err_info, master_addr);
diff --git a/inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/include/tubemq/tubemq_config.h b/inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/include/tubemq/tubemq_config.h
index 3ba918283..9df738de0 100644
--- a/inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/include/tubemq/tubemq_config.h
+++ b/inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/include/tubemq/tubemq_config.h
@@ -41,6 +41,7 @@ class TubeMQServiceConfig {
~TubeMQServiceConfig();
void SetLogCofigInfo(int32_t log_max_num,
int32_t log_max_size, int32_t log_level, const string& log_path);
+ void SetLogPrintLevel(int32_t log_level);
const int32_t GetMaxLogFileNum() const;
const int32_t GetMaxLogFileSize() const;
const int32_t GetLogPrintLevel() const;
diff --git a/inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc b/inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc
index 537dc94db..6fb8a3773 100644
--- a/inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc
+++ b/inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc
@@ -53,11 +53,14 @@ void TubeMQServiceConfig::SetLogCofigInfo(int32_t log_max_num,
int32_t log_max_size, int32_t log_level, const string& log_path) {
log_num_ = log_max_num;
log_size_ = log_max_size;
- log_level_ = log_level;
log_path_ = log_path;
log_level_ = TUBEMQ_MID(log_level, 4, 0);
}
+void TubeMQServiceConfig::SetLogPrintLevel(int32_t log_level) {
+ log_level_ = TUBEMQ_MID(log_level, 4, 0);
+}
+
void TubeMQServiceConfig::SetDnsXfsPeriodInMs(int32_t dns_xfs_period_ms) {
dns_xfs_period_ms_ =
TUBEMQ_MID(dns_xfs_period_ms, tb_config::kMaxIntValue, 10000);