From 2af6d72d7eabd0b5179e51847a5c3b52d10d359a Mon Sep 17 00:00:00 2001
From: CJ Cobb <ccobb@ripple.com>
Date: Thu, 25 Mar 2021 21:56:03 -0400
Subject: [PATCH] reduce etl queue size based on number of extractor threads

---
 reporting/ReportingETL.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/reporting/ReportingETL.cpp b/reporting/ReportingETL.cpp
index 704251e4c..80880b8f4 100644
--- a/reporting/ReportingETL.cpp
+++ b/reporting/ReportingETL.cpp
@@ -354,7 +354,7 @@ ReportingETL::runETLPipeline(uint32_t startSequence, int numExtractors)
 
     std::atomic_bool writeConflict = false;
     std::optional<uint32_t> lastPublishedSequence;
-    constexpr uint32_t maxQueueSize = 1000;
+    uint32_t maxQueueSize = 1000 / numExtractors;
     auto begin = std::chrono::system_clock::now();
     using QueueType =
         ThreadSafeQueue<std::optional<org::xrpl::rpc::v1::GetLedgerResponse>>;