From 6176a17ad2953a8c68b1fe56ff4d91e120192620 Mon Sep 17 00:00:00 2001
From: Matias Romeo <matias.romeo@gmail.com>
Date: Thu, 7 Nov 2024 01:37:13 -0300
Subject: [PATCH] Remove blocks ack request in ship client

---
 src/ship_receiver_plugin.cpp | 19 +------------------
 1 file changed, 1 insertion(+), 18 deletions(-)

diff --git a/src/ship_receiver_plugin.cpp b/src/ship_receiver_plugin.cpp
index f118ea0..ae3d4ae 100644
--- a/src/ship_receiver_plugin.cpp
+++ b/src/ship_receiver_plugin.cpp
@@ -118,7 +118,7 @@ class ship_receiver_plugin_impl : std::enable_shared_from_this<ship_receiver_plu
          eosio::ship_protocol::request req = eosio::ship_protocol::get_blocks_request_v0{
             .start_block_num        = start,
             .end_block_num          = std::numeric_limits<uint32_t>::max(),
-            .max_messages_in_flight = 4*1024,
+            .max_messages_in_flight = std::numeric_limits<uint32_t>::max(),
             .have_positions         = {},
             .irreversible_only      = false,
             .fetch_block            = true,
@@ -133,11 +133,6 @@ class ship_receiver_plugin_impl : std::enable_shared_from_this<ship_receiver_plu
          return send_request(req);
       }
 
-      auto send_get_blocks_ack_request(uint32_t num_messages) {
-         eosio::ship_protocol::request req = eosio::ship_protocol::get_blocks_ack_request_v0{num_messages};
-         return send_request(req);
-      }
-
       template <typename Buffer>
       eosio::ship_protocol::result get_result(Buffer&& b){
          auto data = b->data();
@@ -348,12 +343,10 @@ class ship_receiver_plugin_impl : std::enable_shared_from_this<ship_receiver_plu
       }
 
       void start_read() {
-         static size_t num_messages = 0;
          async_read([this](const auto ec, auto buff) {
             if (ec) {
                SILK_INFO << "Trying to recover from SHiP read failure.";
                // Reconnect and restart sync.
-               num_messages = 0;
                reset_connection();
                return;
             }
@@ -371,16 +364,6 @@ class ship_receiver_plugin_impl : std::enable_shared_from_this<ship_receiver_plu
 
             native_blocks_channel.publish(80, std::make_shared<channels::native_block>(std::move(*block)));
 
-            if(++num_messages % 1024 == 0) {
-               //SILK_INFO << "Block #" << block->block_num;
-               auto ec = send_get_blocks_ack_request(num_messages);
-               if (ec) {
-                  num_messages = 0;
-                  reset_connection();
-                  return;
-               }
-            }
-
             start_read();
          });
       }