Revert "Optimizations"

This reverts commit 063d001.
seredat · Jul 26, 2018 · c695830 · c695830 · aivve · Jul 27, 2018
1 parent 080090d
commit c695830
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/src/System/TcpStream.cpp b/src/System/TcpStream.cpp
@@ -82,9 +82,7 @@ bool TcpStreambuf::dumpBuffer(bool finalize) {
     } else {
       if(!finalize) {
         size_t front = 0;
-        size_t pos = transferred;
-        for (uint64_t i = count - transferred; i--; ) {
-          ++pos, ++front;
+        for (size_t pos = transferred; pos < count; ++pos, ++front) {
           writeBuf[front] = writeBuf[pos];
         }
 

diff --git a/src/Transfers/TransfersConsumer.cpp b/src/Transfers/TransfersConsumer.cpp
@@ -210,8 +210,7 @@ bool TransfersConsumer::onNewBlocks(const CompleteBlock* blocks, uint32_t startH
   std::atomic<bool> stopProcessing(false);
 
   auto pushingThread = std::async(std::launch::async, [&] {
-    uint32_t i = 0;
-    for (uint32_t j = count - 1; j--; ) {
+    for( uint32_t i = 0; i < count && !stopProcessing; ++i) {
       const auto& block = blocks[i].block;
 
       if (!block.is_initialized()) {
@@ -239,7 +238,6 @@ bool TransfersConsumer::onNewBlocks(const CompleteBlock* blocks, uint32_t startH
         inputQueue.push(item);
         ++blockInfo.transactionIndex;
       }
-	  i++;
     }
 
     inputQueue.close();