You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by if...@apache.org on 2021/03/28 05:21:08 UTC

[rocketmq-client-cpp] branch re_dev updated: fix: missing cassert header

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

ifplusor pushed a commit to branch re_dev
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-cpp.git


The following commit(s) were added to refs/heads/re_dev by this push:
     new 716316c  fix: missing cassert header
716316c is described below

commit 716316cbb0bedeeabbfd927337891904d3e14940
Author: James Yin <yw...@hotmail.com>
AuthorDate: Sun Mar 28 13:20:32 2021 +0800

    fix: missing cassert header
---
 src/ClientRemotingProcessor.cpp        | 2 ++
 src/MQClientAPIImpl.cpp                | 1 +
 src/common/PullCallbackWrap.cpp        | 2 ++
 src/common/SendCallbackWrap.cpp        | 2 ++
 src/common/UtilAll.cpp                 | 2 ++
 src/concurrent/latch.hpp               | 3 ++-
 src/concurrent/time.hpp                | 1 +
 src/producer/DefaultMQProducerImpl.cpp | 3 ++-
 src/transport/SocketUtil.h             | 1 +
 9 files changed, 15 insertions(+), 2 deletions(-)

diff --git a/src/ClientRemotingProcessor.cpp b/src/ClientRemotingProcessor.cpp
index 32366d6..d4fc34c 100644
--- a/src/ClientRemotingProcessor.cpp
+++ b/src/ClientRemotingProcessor.cpp
@@ -16,6 +16,8 @@
  */
 #include "ClientRemotingProcessor.h"
 
+#include <cassert>
+
 #include "MQProtos.h"
 #include "MessageAccessor.hpp"
 #include "MessageDecoder.h"
diff --git a/src/MQClientAPIImpl.cpp b/src/MQClientAPIImpl.cpp
index e5372d0..6bc5d3e 100644
--- a/src/MQClientAPIImpl.cpp
+++ b/src/MQClientAPIImpl.cpp
@@ -18,6 +18,7 @@
 
 #include <cassert>
 #include <cstring>
+
 #include <typeindex>
 
 #include "ClientRemotingProcessor.h"
diff --git a/src/common/PullCallbackWrap.cpp b/src/common/PullCallbackWrap.cpp
index 9128351..2fa0510 100644
--- a/src/common/PullCallbackWrap.cpp
+++ b/src/common/PullCallbackWrap.cpp
@@ -16,6 +16,8 @@
  */
 #include "PullCallbackWrap.h"
 
+#include <cassert>
+
 namespace rocketmq {
 
 void PullCallback::invokeOnSuccess(std::unique_ptr<PullResult> pull_result) noexcept {
diff --git a/src/common/SendCallbackWrap.cpp b/src/common/SendCallbackWrap.cpp
index eab2fb5..9d324f0 100644
--- a/src/common/SendCallbackWrap.cpp
+++ b/src/common/SendCallbackWrap.cpp
@@ -16,6 +16,8 @@
  */
 #include "SendCallbackWrap.h"
 
+#include <cassert>
+
 #include <typeindex>
 
 #include "DefaultMQProducer.h"
diff --git a/src/common/UtilAll.cpp b/src/common/UtilAll.cpp
index 731d8aa..bb13eae 100644
--- a/src/common/UtilAll.cpp
+++ b/src/common/UtilAll.cpp
@@ -16,6 +16,8 @@
  */
 #include "UtilAll.h"
 
+#include <cassert>
+
 #include <chrono>
 #include <iostream>
 #include <thread>
diff --git a/src/concurrent/latch.hpp b/src/concurrent/latch.hpp
index b583f8f..656d47e 100644
--- a/src/concurrent/latch.hpp
+++ b/src/concurrent/latch.hpp
@@ -17,9 +17,10 @@
 #ifndef ROCKETMQ_CONCURRENT_LATCH_HPP_
 #define ROCKETMQ_CONCURRENT_LATCH_HPP_
 
-#include <atomic>
 #include <cassert>
 #include <cstddef>
+
+#include <atomic>
 #include <future>
 #include <thread>
 
diff --git a/src/concurrent/time.hpp b/src/concurrent/time.hpp
index fef4f4e..35855ea 100644
--- a/src/concurrent/time.hpp
+++ b/src/concurrent/time.hpp
@@ -18,6 +18,7 @@
 #define ROCKETMQ_CONCURRENT_TIME_HPP_
 
 #include <cassert>
+
 #include <chrono>
 
 namespace rocketmq {
diff --git a/src/producer/DefaultMQProducerImpl.cpp b/src/producer/DefaultMQProducerImpl.cpp
index ade43d1..0105bd6 100644
--- a/src/producer/DefaultMQProducerImpl.cpp
+++ b/src/producer/DefaultMQProducerImpl.cpp
@@ -17,8 +17,8 @@
 #include "DefaultMQProducerImpl.h"
 
 #include <cassert>
+
 #include <typeindex>
-#include "MQMessageQueue.h"
 
 #ifndef WIN32
 #include <signal.h>
@@ -33,6 +33,7 @@
 #include "MQClientManager.h"
 #include "MQException.h"
 #include "MQFaultStrategy.h"
+#include "MQMessageQueue.h"
 #include "MQProtos.h"
 #include "MessageBatch.h"
 #include "MessageClientIDSetter.h"
diff --git a/src/transport/SocketUtil.h b/src/transport/SocketUtil.h
index 6bfe535..b40e7dc 100644
--- a/src/transport/SocketUtil.h
+++ b/src/transport/SocketUtil.h
@@ -17,6 +17,7 @@
 #ifndef ROCKETMQ_TRANSPORT_SOCKETUTIL_H_
 #define ROCKETMQ_TRANSPORT_SOCKETUTIL_H_
 
+#include <cassert>  // assert
 #include <cstddef>  // size_t
 #include <cstdint>  // uint16_t