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 07:48:11 UTC
[rocketmq-client-cpp] 01/04: 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
commit ec800c124d7f5231f22b432ef1240e2fd42178d1
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