#1870 check opened dbs

skalenetwork · Oct 7, 2024 · 1f4e7ca · 1f4e7ca
1 parent 1f47de9
commit 1f4e7ca
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/libbatched-io/BatchedRotatingHistoricDbIO.cpp b/libbatched-io/BatchedRotatingHistoricDbIO.cpp
@@ -43,8 +43,8 @@ void BatchedRotatingHistoricDbIO::rotate( uint64_t timestamp ) {
 void BatchedRotatingHistoricDbIO::checkOpenedDbsAndCloseIfNeeded() {
     std::lock_guard< std::mutex > lock( mutex );
 
-    if ( ( lastCleanup + std::chrono::seconds( 1000 ) > std::chrono::system_clock::now() ) &&
-         dbsInUse.size() < 10 )
+    if ( ( lastCleanup + OPENED_DB_CHECK_INTERVAL > std::chrono::system_clock::now() ) &&
+         dbsInUse.size() < MAX_OPENED_DB_COUNT )
         return;
 
     for ( auto it = dbsInUse.begin(); it != dbsInUse.end(); ) {