From 0edeaa35b5add60bec126ffdfdafdd22005bb90d Mon Sep 17 00:00:00 2001 From: afederici <ajf5@illinois.edu> Date: Sat, 28 Nov 2020 10:24:19 -0600 Subject: [PATCH] idk --- src/Node.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/Node.cpp b/src/Node.cpp index 362a895..740fccd 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; -- GitLab