From ae3afc6801572f8867c6e91a391920f3f89102d1 Mon Sep 17 00:00:00 2001
From: hwzhangchuang <zhangchuang.zhang@huawei.com>
Date: Fri, 29 Dec 2023 15:25:43 +0800
Subject: [PATCH] add

Signed-off-by: hwzhangchuang <zhangchuang.zhang@huawei.com>
---
 .../transport/src/distributed_input_sink_transport.cpp   | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/services/sink/transport/src/distributed_input_sink_transport.cpp b/services/sink/transport/src/distributed_input_sink_transport.cpp
index 843f506..4d70517 100644
--- a/services/sink/transport/src/distributed_input_sink_transport.cpp
+++ b/services/sink/transport/src/distributed_input_sink_transport.cpp
@@ -234,12 +234,15 @@ void DistributedInputSinkTransport::SendKeyStateNodeMsgBatch(const int32_t sessi
     }
     DHLOGI("SendKeyStateNodeMsgBatch sessionId: %d, event size: %d ", sessionId, events.size());
 
+    int32_t cnt = 0;
     std::vector<struct RawEvent> eventBatch;
-    for (int32_t i = 0; i < events.size(); i++) {
-        eventBatch.push_back(events[i]);
-        if (i == MSG_BTACH_MAX_SIZE) {
+    for (auto ev : events) {
+        eventBatch.push_back(ev);
+        cnt++;
+        if (cnt == MSG_BTACH_MAX_SIZE) {
             DoSendMsgBatch(sessionId, eventBatch);
             eventBatch.clear();
+            cnt = 0;
         }
     }