You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by GitBox <gi...@apache.org> on 2019/01/15 01:52:18 UTC
[rocketmq-client-cpp] Diff for: [GitHub] ShannonDing merged pull request
#66: Resolve the compile warning and bug
diff --git a/src/consumer/PullRequest.cpp b/src/consumer/PullRequest.cpp
index 8510e430..b261d82d 100644
--- a/src/consumer/PullRequest.cpp
+++ b/src/consumer/PullRequest.cpp
@@ -28,8 +28,8 @@ PullRequest::PullRequest(const string& groupname)
m_queueOffsetMax(0),
m_bDroped(false),
m_bLocked(false),
- m_bPullMsgEventInprogress(false),
- m_latestPullRequestOpaque(0) {}
+ m_latestPullRequestOpaque(0),
+ m_bPullMsgEventInprogress(false) {}
PullRequest::~PullRequest() {
m_msgTreeMapTemp.clear();
@@ -262,7 +262,7 @@ bool PullRequest::addPullMsgEvent() {
return false;
}
-int PullRequest::getLatestPullRequestOpaque() const {
+int PullRequest::getLatestPullRequestOpaque() {
boost::lock_guard<boost::mutex> lock(m_pullRequestLock);
return m_latestPullRequestOpaque;
}
diff --git a/src/consumer/PullRequest.h b/src/consumer/PullRequest.h
index 80c286ae..57ab70b5 100644
--- a/src/consumer/PullRequest.h
+++ b/src/consumer/PullRequest.h
@@ -69,7 +69,7 @@ class PullRequest {
boost::timed_mutex& getPullRequestCriticalSection();
void removePullMsgEvent();
bool addPullMsgEvent();
- int getLatestPullRequestOpaque() const;
+ int getLatestPullRequestOpaque();
void setLatestPullRequestOpaque(int opaque);
public:
With regards,
Apache Git Services