Process blocks only after a while.

Author: jjos2372

src/main/java/burst/pool/miners/Miner.java

@@ -33,7 +33,7 @@ public void recalculateCapacity(long currentBlockHeight) {
         // Calculate hitSum
         BigInteger hitSumShared = BigInteger.ZERO;
         BigInteger hitSum = BigInteger.ZERO;
-        AtomicInteger deadlineCount = new AtomicInteger(store.getDeadlineCount());
+        int deadlineCount = store.getDeadlineCount();
         List<Deadline> deadlines = store.getDeadlines();
         for(Deadline deadline : deadlines) {
             if (currentBlockHeight - deadline.getHeight() >= propertyService.getInt(Props.nAvg)) {
@@ -56,7 +56,7 @@ public void recalculateCapacity(long currentBlockHeight) {
         }
         // Calculate estimated capacity
         try {
-            store.setSharedCapacity(minerMaths.estimatedEffectivePlotSize(deadlines.size(), deadlineCount.get(), hitSumShared));
+            store.setSharedCapacity(minerMaths.estimatedEffectivePlotSize(deadlines.size(), deadlineCount, hitSumShared));
             store.setTotalCapacity(minerMaths.estimatedTotalPlotSize(deadlines.size(), hitSum));
         } catch (ArithmeticException ignored) {
         }

src/main/java/burst/pool/pool/Pool.java

@@ -31,6 +31,7 @@
 import org.slf4j.LoggerFactory;
 
 import java.math.BigInteger;
+import java.time.Duration;
 import java.time.Instant;
 import java.util.*;
 import java.util.concurrent.Semaphore;
@@ -125,6 +126,15 @@ private Completable processNextBlock() {
                 if (miningInfo.get() == null || processBlockSemaphore.availablePermits() == 0 || miningInfo.get().getHeight() - 1 <= storageService.getLastProcessedBlock() + propertyService.getInt(Props.processLag)) {
                     return;
                 }
+                
+                // Leave the process blocks only a minute after starting a new round
+                // TODO: add a configuration for this
+                Duration roundDuration = Duration.between(roundStartTime.get(), Instant.now());
+                if(roundDuration.toMillis() < 60000) {
+                    return;
+                }
+                
+                logger.info("Started processing block {}", storageService.getLastProcessedBlock() + 1);
 
                 try {
                     processBlockSemaphore.acquire();
@@ -261,6 +271,8 @@ private void onProcessedBlock(StorageService transactionalStorageService, boolea
         if (actuallyProcessed) {
             minerTracker.payoutIfNeeded(storageService, transactionFee.get());
         }
+        
+        logger.info("Finished processing block {}", storageService.getLastProcessedBlock());
     }
 
     private void resetRound(MiningInfo newMiningInfo) {