[incubator-tubemq] 09/50: [TUBEMQ-262]Create C++ flow control handler

[gx...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gxcheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git

commit 3cf5c56aaba6692eab45e5bef280d6fbaac10996
Author: gosonzhang <go...@tencent.com>
AuthorDate: Thu Jul 2 17:23:39 2020 +0800

    [TUBEMQ-262]Create C++ flow control handler
---
 tubemq-client-twins/tubemq-client-cpp/inc/const_config.h   | 2 +-
 tubemq-client-twins/tubemq-client-cpp/src/client_config.cc | 4 ++--
 tubemq-client-twins/tubemq-client-cpp/src/utils.cc         | 2 ++
 3 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/tubemq-client-twins/tubemq-client-cpp/inc/const_config.h b/tubemq-client-twins/tubemq-client-cpp/inc/const_config.h
index 5ec1709..a48873d 100644
--- a/tubemq-client-twins/tubemq-client-cpp/inc/const_config.h
+++ b/tubemq-client-twins/tubemq-client-cpp/inc/const_config.h
@@ -66,7 +66,7 @@ static const int kRebWaitPeriodWhenShutdownMs = 10000;
 // max int value
 static const int kMaxIntValue = 0x7fffffff;
 // max long value
-static const int kMaxLongValue = 0x7fffffffffffffffL;
+static const long kMaxLongValue = 0x7fffffffffffffffL;
 
 // invalid value
 static const int kInvalidValue = -2;
diff --git a/tubemq-client-twins/tubemq-client-cpp/src/client_config.cc b/tubemq-client-twins/tubemq-client-cpp/src/client_config.cc
index f7fde92..e668f81 100644
--- a/tubemq-client-twins/tubemq-client-cpp/src/client_config.cc
+++ b/tubemq-client-twins/tubemq-client-cpp/src/client_config.cc
@@ -421,7 +421,7 @@ bool ConsumerConfig::setGroupConsumeTarget(string& err_info, bool is_bound_consu
   string part_key;
   map<string, long> tmp_parts_map;
   map<string, long>::const_iterator it_part;
-  for (itPart = part_offset_map.begin(); it_part != part_offset_map.end(); ++it_part) {
+  for (it_part = part_offset_map.begin(); it_part != part_offset_map.end(); ++it_part) {
     vector<string> result;
     Utils::Split(it_part->first, result, delimiter::kDelimiterColon);
     if (result.size() != 3) {
@@ -566,7 +566,7 @@ string ConsumerConfig::ToString() {
       ss << ",";
     }
     ss << "'";
-    ss << itMap->first;
+    ss << it_map->first;
     ss << "'=[";
     int j=0;
     set<string> topic_set = it_map->second;
diff --git a/tubemq-client-twins/tubemq-client-cpp/src/utils.cc b/tubemq-client-twins/tubemq-client-cpp/src/utils.cc
index f8ee3c2..9ddd3b0 100644
--- a/tubemq-client-twins/tubemq-client-cpp/src/utils.cc
+++ b/tubemq-client-twins/tubemq-client-cpp/src/utils.cc
@@ -21,6 +21,8 @@
 #include <sstream> 
 #include <regex.h>
 #include <stdlib.h>
+#include <unistd.h>
+#include <sys/time.h>
 #include "utils.h"
 #include "const_config.h"