[incubator-pulsar] branch master updated: Fixed C++ formatting (#1443)

[mmerli]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 3360b14  Fixed C++ formatting (#1443)
3360b14 is described below

commit 3360b1485a950e473ca6bfb6c7d65b8d868174ca
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Mon Mar 26 10:13:24 2018 -0700

    Fixed C++ formatting (#1443)
---
 pulsar-client-cpp/lib/BatchAcknowledgementTracker.cc | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/pulsar-client-cpp/lib/BatchAcknowledgementTracker.cc 
b/pulsar-client-cpp/lib/BatchAcknowledgementTracker.cc
index 0dcf3be..e780e27 100644
--- a/pulsar-client-cpp/lib/BatchAcknowledgementTracker.cc
+++ b/pulsar-client-cpp/lib/BatchAcknowledgementTracker.cc
@@ -108,11 +108,12 @@ bool BatchAcknowledgementTracker::isBatchReady(const 
MessageId& msgID,
                                                const proto::CommandAck_AckType 
ackType) {
     Lock lock(mutex_);
     // Remove batch index
-    MessageId batchMessageId = MessageId(msgID.partition(), msgID.ledgerId(), 
msgID.entryId(),
-                                         -1 /* Batch index */);
+    MessageId batchMessageId =
+        MessageId(msgID.partition(), msgID.ledgerId(), msgID.entryId(), -1 /* 
Batch index */);
 
     TrackerMap::iterator pos = trackerMap_.find(batchMessageId);
-    if (pos == trackerMap_.end() || std::find(sendList_.begin(), 
sendList_.end(), batchMessageId) != sendList_.end()) {
+    if (pos == trackerMap_.end() ||
+        std::find(sendList_.begin(), sendList_.end(), batchMessageId) != 
sendList_.end()) {
         LOG_DEBUG(
             "Batch is ready since message present in sendList_ or not present 
in trackerMap_ [message ID = "
             << batchMessageId << "]");
@@ -146,8 +147,8 @@ const MessageId 
BatchAcknowledgementTracker::getGreatestCumulativeAckReady(const
     Lock lock(mutex_);
 
     // Remove batch index
-    MessageId batchMessageId = MessageId(messageId.partition(), 
messageId.ledgerId(),
-                                         messageId.entryId(), -1 /* Batch 
index */);
+    MessageId batchMessageId =
+        MessageId(messageId.partition(), messageId.ledgerId(), 
messageId.entryId(), -1 /* Batch index */);
     TrackerMap::iterator pos = trackerMap_.find(batchMessageId);
 
     // element not found

-- 
To stop receiving notification emails like this one, please contact
mme...@apache.org.