IS 495 change timeouts only for sync nodes

skalenetwork · Dec 26, 2024 · 8e5f6f2 · 8e5f6f2
1 parent 1eeea96
commit 8e5f6f2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/catchup/client/CatchupClientAgent.cpp b/catchup/client/CatchupClientAgent.cpp
@@ -75,8 +75,9 @@ nlohmann::json CatchupClientAgent::readCatchupResponseHeader(
     const ptr< ClientSocket >& _socket, ptr< CatchupRequestHeader > _requestHeader ) {
     CHECK_ARGUMENT( _socket )
     CHECK_ARGUMENT( _requestHeader )
+    uint32_t timeoutSec = getNode()->isSyncOnlyNode() ? 300 : 30;
     auto result = sChain->getIo()->readJsonHeader( _socket->getDescriptor(),
-        "Read catchup response", 300, _socket->getIP(), MAX_CATCHUP_DOWNLOAD_BYTES );
+        "Read catchup response", timeoutSec, _socket->getIP(), MAX_CATCHUP_DOWNLOAD_BYTES );
     return result;
 }
 

diff --git a/network/IO.cpp b/network/IO.cpp
@@ -264,7 +264,8 @@ nlohmann::json IO::readJsonHeader( file_descriptor descriptor, const char* _erro
     auto buf2 = make_shared< vector< uint8_t > >( sizeof( uint64_t ) );
 
     try {
-        readBytes( descriptor, buf2, msg_len( sizeof( uint64_t ) ), 300 );
+        uint32_t timeoutSec = sChain->getNode()->isSyncOnlyNode() ? 300 : 6;
+        readBytes( descriptor, buf2, msg_len( sizeof( uint64_t ) ), timeoutSec );
     } catch ( ExitRequestedException& ) {
         throw;
     } catch ( ... ) {