diff --git a/src/Node.cpp b/src/Node.cpp index 362a895b57500f64b674c86b03b67c153a0574fc..740fccd4062a83f2987f8a5c874e7a7e06102a89 100644 --- a/src/Node.cpp +++ b/src/Node.cpp @@ -765,7 +765,7 @@ void Node::checkFileListConsistency(){ } for (auto& element: fileList) { if(element.second.size() < 4){ - cout << "Need to rereplicate " << element.first << endl; + //cout << "Need to rereplicate " << element.first << endl; //First check the closest node, successor and predecessor int closestNodePostion = hashRing->locateClosestNode(element.first); int pred = hashRing->getPredecessor(closestNodePostion); @@ -823,7 +823,7 @@ vector<tuple<string,string, string>> Node::getRandomNodesToGossipTo() void Node::handleMaplejuiceQ(){ if (!maplejuiceQ.empty() && !workerRing->size() && !isBlackout){ for (auto &e: fileList) { - if (e.second.size() < 4) return; //make sure replication is good first + if (e.second.size() < 3) return; //make sure replication is good first } string msgCopy(maplejuiceQ.front()); cout << "[QUEUE] sending next maple/juice to be processed " << msgCopy << endl;