commit 107072b264527efbcec0002a7e8c8ddaf6e27f0e
author xiaojin <zte10144398@163.com> Tue Jun 28 10:54:12 2022 +0800
committer GitHub <noreply@github.com> Tue Jun 28 10:54:12 2022 +0800
tree c470591db8ad47485fd02671150058018fe33b2d
parent 509906235aa1c43348c827a0898cc722836c4f0e

param “mq” is read only,pass by reference instead of value (#421)

(cherry picked from commit 57b584103a30ba1386560b8e54d209975ec7b055)

src/transport/ClientRemotingProcessor.cpp

diff --git a/src/transport/ClientRemotingProcessor.cpp b/src/transport/ClientRemotingProcessor.cpp
index 2c67a0c..6303684 100644
--- a/src/transport/ClientRemotingProcessor.cpp
+++ b/src/transport/ClientRemotingProcessor.cpp
@@ -72,7 +72,7 @@
   return m_offsetTable;
 }
 
-void ResetOffsetBody::setOffsetTable(MQMessageQueue mq, int64 offset) {
+void ResetOffsetBody::setOffsetTable(const MQMessageQueue& mq, int64 offset) {
   m_offsetTable[mq] = offset;
 }
 

src/transport/ClientRemotingProcessor.h

diff --git a/src/transport/ClientRemotingProcessor.h b/src/transport/ClientRemotingProcessor.h
index 2b26f28..5d79be4 100644
--- a/src/transport/ClientRemotingProcessor.h
+++ b/src/transport/ClientRemotingProcessor.h
@@ -43,7 +43,7 @@
  public:
   ResetOffsetBody() {}
   virtual ~ResetOffsetBody() { m_offsetTable.clear(); }
-  void setOffsetTable(MQMessageQueue mq, int64 offset);
+  void setOffsetTable(const MQMessageQueue& mq, int64 offset);
   std::map<MQMessageQueue, int64> getOffsetTable();
   static ResetOffsetBody* Decode(const MemoryBlock* mem);