final

.idea/.gitignore

+
+# Default ignored files
+/workspace.xml
\ No newline at end of file

.idea/.name

+KVServer
\ No newline at end of file

.idea/Chord-DHT.iml

+<?xml version="1.0" encoding="UTF-8"?>
+<module classpath="CMake" type="CPP_MODULE" version="4" />
\ No newline at end of file

.idea/misc.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="CMakeWorkspace" PROJECT_DIR="$PROJECT_DIR$" />
+  <component name="JavaScriptSettings">
+    <option name="languageLevel" value="ES6" />
+  </component>
+</project>
\ No newline at end of file

.idea/modules.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/Chord-DHT.iml" filepath="$PROJECT_DIR$/.idea/Chord-DHT.iml" />
+    </modules>
+  </component>
+</project>
\ No newline at end of file

.idea/vcs.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$" vcs="Git" />
+  </component>
+</project>
\ No newline at end of file

CMakeLists.txt

+cmake_minimum_required(VERSION 3.15)
+
+SET(CMAKE_CXX_FLAGS "-lcrypto -pthread")
+link_libraries(crypto)
+
+project(KVServer)
+add_executable(KVServer KVServer.cpp)
+add_executable(KVClient KVClient.cpp)
\ No newline at end of file

KVCache.cpp

+#include "header.hpp"
+
+//TODO: use hashes instead of filenumber
+
+class KVCache {
+
+    std::pair<std::string, std::string> cacheMatrix[numSetsInCache][sizeOfSet];
+    bool cacheReferenceMatrix[numSetsInCache][sizeOfSet]{};
+    bool entryEmpty[numSetsInCache][sizeOfSet]{true};
+    int lastReplacedEntry[numSetsInCache]{-1};
+
+public:
+
+    KVCache() {
+        for (int i = 0; i < numSetsInCache; i++) {
+            lastReplacedEntry[i] = -1;
+
+            for (int j = 0; j < sizeOfSet; j++) {
+                cacheReferenceMatrix[i][j] = false;
+                entryEmpty[i][j] = true;
+            }
+        }
+
+    }
+
+
+    std::string put(const std::string &, const std::string &);
+
+    std::string get(const std::string &);
+
+    std::string del(const std::string &);
+
+    int entry_to_replace(int id);
+
+    void viewset(int);
+
+    void cacheToXML(const std::string &filename);
+};
+
+
+std::string KVCache::get(const std::string &key) {
+    int setID = getSetId(key);
+    int not_found = 1;
+    for (int i = 0; i < sizeOfSet; i++) {
+        if (key == cacheMatrix[setID][i].first && !entryEmpty[setID][i]) {
+            cacheReferenceMatrix[setID][i] = true;
+            not_found = 0;
+            return cacheMatrix[setID][i].second;
+        }
+    }
+    if (not_found) {
+        return "Does not exist";
+    }
+}
+
+
+std::string KVCache::put(const std::string &key, const std::string &value) {
+    int setID = getSetId(key);
+    for (int i = 0; i < sizeOfSet; i++) {
+        if (entryEmpty[setID][i]) {
+            cacheMatrix[setID][i] = std::make_pair(key, value);
+            entryEmpty[setID][i] = false;
+            cacheReferenceMatrix[setID][i] = false;
+            return "Success";
+        }
+    }
+    int entryToReplace = entry_to_replace(setID);
+    cacheMatrix[setID][entryToReplace] = std::make_pair(key, value);
+    entryEmpty[setID][entryToReplace] = false;
+    cacheReferenceMatrix[setID][entryToReplace] = false;
+    return "Success";
+
+}
+
+std::string KVCache::del(const std::string &key) {
+    int setID = getSetId(key);
+    for (int i = 0; i < sizeOfSet; i++) {
+        if (key == cacheMatrix[setID][i].first) {
+            entryEmpty[setID][i] = true;
+            return "Success";
+        }
+    }
+    return "Does not exist";
+}
+
+int KVCache::entry_to_replace(int setID) {
+    int i = (lastReplacedEntry[setID] + 1) % sizeOfSet;
+
+    if (i == 0) {
+        for (int j = 0; j < sizeOfSet; j++) {
+            cacheReferenceMatrix[setID][j] = false;
+        }
+    }
+    while (cacheReferenceMatrix[setID][i]) {
+        i = (i + 1) % sizeOfSet;
+        if (i == 0) {
+            for (int j = 0; j < sizeOfSet; j++) {
+                cacheReferenceMatrix[setID][j] = false;
+            }
+        }
+    }
+    lastReplacedEntry[setID] = i;
+    return i;
+}
+
+void KVCache::viewset(int setID) {
+    cout << "\n";
+    for (int i = 0; i < sizeOfSet; i++) {
+        cout << cacheMatrix[setID][i].first << cacheMatrix[setID][i].second << std::endl;
+    }
+}
+
+void KVCache::cacheToXML(const std::string &filename) {
+    std::string cacheXML = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n";
+    cacheXML += "<KVCache>\n";
+
+    for (int i = 0; i < numSetsInCache; i++) {
+        cacheXML += " <Set Id=\"" + std::to_string(i) + "\">\n";
+        for (int j = 0; j < sizeOfSet; j++) {
+            std::string isReferenced;
+            std::string isValid;
+            if (cacheReferenceMatrix[i][j]) {
+                isReferenced = "true";
+            } else
+                isReferenced = "false";
+
+            if (entryEmpty[i][j]) {
+                isValid = "false";
+            } else
+                isValid = "true";
+
+            cacheXML += "  <CacheEntry isReferenced=\"" + isReferenced + "\"";
+            cacheXML += " isValid=\"" + isValid + "\">\n";
+            std::string key = cacheMatrix[i][j].first;
+            std::string value = cacheMatrix[i][j].second;
+            cacheXML += "   <Key>" + key + "</Key>\n";
+            cacheXML += "   <Value>" + key + "</Value>\n";
+            cacheXML += "  </CacheEntry>\n";
+        }
+        cacheXML += " </Set>\n";
+    }
+    cacheXML += "</KVCache>\n";
+
+    char chararr_of_XML[cacheXML.length() + 1];
+    strcpy(chararr_of_XML, cacheXML.c_str());
+    FILE *fp = fopen(filename.c_str(), "w");
+
+    fprintf(fp, "%s", chararr_of_XML);
+    fprintf(fp, "\n");
+
+    fclose(fp);
+}

KVClient.cpp

+#include "header.hpp"
+
+int PORT;
+
+// to convert the plain text to xml format
+std::string toxml(std::string msg_type, std::string key, std::string value = "") {
+
+    std::string request = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n";
+
+    if (msg_type == "GET") {
+        msg_type = "<KVMessage type=\"getreq\">\n";
+        key = "<Key>" + key + "</Key>\n";
+    }
+    if (msg_type == "PUT") {
+
+        msg_type = "<KVMessage type=\"putreq\">\n";
+        key = "<key>" + key + "</Key>\n";
+        value = "<Value>" + value + "</Value>\n";
+        key = key + value;
+
+    }
+    if (msg_type == "DEL") {
+
+        msg_type = "<KVMessage type=\"delreq\">\n";
+        key = "<Key>" + key + "</Key>\n";
+    }
+
+    request = request + msg_type + key + "</KVMessage>\n";
+
+    return request;
+}
+
+//to get back xml format to plain text
+std::string xmltoplain(std::string str) {
+
+    int i = 0;
+    std::string plain_text;
+    if (str[64] == 'M') {
+        for (i = 72; str[i] != '<'; i++)
+            plain_text += str[i];
+    } else {
+        for (i = 68; str[i] != '<'; i++)
+            plain_text += str[i];
+        plain_text += " ";
+        int j = i + 14;
+        for (; str[j] != '<'; j++)
+            plain_text += str[j];
+
+    }
+    return plain_text;
+}
+
+int checkLenght(const std::string &key, const std::string &value = " ") {
+    if (key.size() > max_key_lenght) {
+        cout << "Oversized key";
+        exit(-1);
+    }
+    if (value.size() > max_value_lenght) {
+        cout << "Oversized value";
+        exit(-1);
+    }
+
+}
+
+//TODO: Increase capacity of request string to store 256KB
+
+int main(int argc, char **argv) {
+
+    int interactiveMode = 1;
+//    cout<<argv[1];
+
+    if (strcmp(argv[1], "port") == 0) {
+        std::istringstream iss(argv[2]);
+        int val;
+        if (iss >> val) {
+            // Conversion successful
+        }
+        PORT = val;
+        cout << "Will run on port " << argv[2] << "." << std::endl;
+    }
+    if (argc == 5) {
+        interactiveMode = 0;
+
+    }
+    std::ifstream infile(argv[3]);
+    if (interactiveMode) {
+        cout << "Enter request in the format\n"
+                "GET,<key>\n"
+                "PUT,<key>,<value>\n"
+                "DEL,<key>\n"
+                "=============================================OR=============================================\n"
+                "Exit the interactive mode and provide two filenames in the commandline in the format\n"
+                "./KVClient [inputfile] [outputfile]\n";
+    }
+
+    std::string request_type;
+    std::string key;
+    std::string value;
+    char buffer1[max_buffer_size] = {0};
+    int valread;
+    std::string finalRequest;
+
+    for (std::string line; interactiveMode || getline(infile, line);) {
+        if (interactiveMode) {
+            while (line.empty())
+                getline(cin, line);
+        }
+
+
+        finalRequest = "";
+        std::vector<std::string> request = split(line.c_str(), ',');
+        if (debugger_mode) {
+            cout << request[0] << "\t" << request[1] << "\t";
+        }
+        if (request.size() < 2 || request[0].empty() || request[1].empty()) {
+            perror("XML Error: Received unparseable message");
+            line.erase();
+            continue;
+
+        }
+        request_type = request[0];
+        key = request[1];
+//        finalRequest.append(request[0]).append(delimiter).append(request[1]);
+        if (request[0] == "PUT") {
+            if (request.size() != 3 || request[2].empty()) {
+                perror("XML Error: Received unparseable message");
+                line.erase();
+                continue;
+            }
+            if (debugger_mode) {
+                cout << request[2];
+            }
+            checkLenght(request[1], request[2]);
+            value = request[2];
+//            finalRequest.append(delimiter).append(request[2]);
+        } else if ((request[0] != "GET" && request[0] != "DEL") || request.size() != 2) {
+            perror("XML Error: Received unparseable message");
+            line.erase();
+//            return errno;
+//            exit(-1);
+            continue;
+        }
+        if (debugger_mode) {
+            cout << "\n";
+        }
+
+
+        finalRequest = toxml(request_type, key, value);
+        if (debugger_mode) {
+            cout << finalRequest << "\n";
+            cout << "###################################### "
+                    "SENDING DATA "
+                    "######################################\n";
+        }
+        struct sockaddr_in serv_addr = {AF_INET, htons(PORT)};
+        memset(&serv_addr, 0, sizeof(struct sockaddr_in));
+        serv_addr.sin_family = AF_INET;
+        serv_addr.sin_port = htons(PORT);
+        //creating a socket
+        int sockfd = socket(AF_INET, SOCK_STREAM, 0);
+        if (debugger_mode) {
+            cout << sockfd << "\n";
+        }
+        if (sockfd < 0) {
+            perror("Network Error: Could not create socket");
+            exit(-1);
+        }
+        int rc = connect(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr));
+        if (rc < 0) {
+            perror("Network Error: Could not create socket");
+            exit(-1);
+            //            return errno;
+        }
+        send(sockfd, finalRequest.c_str(), finalRequest.size(), 0);
+
+        valread = read(sockfd, buffer1, max_buffer_size);
+        close(sockfd);
+
+        buffer1[valread] = '\0';
+        std::string buffer;
+        for (int i = 0; i < valread; i++) {
+            buffer += (buffer1[i]);
+        }
+        std::string buffer2 = xmltoplain(buffer);
+        char chararr_of_buffer[buffer2.length() + 1];
+        strcpy(chararr_of_buffer, buffer2.c_str());
+        if (debugger_mode) {
+            cout << chararr_of_buffer << "\n";
+        }
+
+        if (!interactiveMode) {
+            FILE *fp = fopen(argv[4], "a");
+            if (!fp) {
+//                return -errno;
+                perror("File open error");
+                exit(-1);
+            }
+            fprintf(fp, "%s", chararr_of_buffer);
+            fprintf(fp, "\n");
+            fclose(fp);
+        } else {
+            cout << chararr_of_buffer << std::endl;
+        }
+        line.erase();
+    }
+}
\ No newline at end of file

KVStore.cpp

+#include "header.hpp"
+
+std::mutex DumpToFile;
+std::mutex restoreFromFile;
+std::mutex mapToFile;
+std::mutex addToFile;
+
+
+class KVStore {
+
+public:
+    int dumpToFile(const std::string &filename) {
+        DumpToFile.lock();
+        FILE *dumpFilePtr = fopen(filename.c_str(), "w");
+        if (!dumpFilePtr) {
+            DumpToFile.unlock();
+
+            return -errno;
+        }
+        fprintf(dumpFilePtr, "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n<KVStore>\n");
+        for (int i = 0; i < numSetsInCache; i++) {
+            std::string nameStoreFile = "KVStore/" + std::to_string(i);
+
+            FILE *storeFilePtr = fopen(nameStoreFile.c_str(), "r");
+            if (!storeFilePtr)
+                continue;
+
+            char *buf = nullptr;
+            size_t buflen = 0;
+            while (getline(&buf, &buflen, storeFilePtr) > 0) {
+                char *nl = strchr(buf, '\n');
+                if (nl == nullptr)
+                    continue;
+                *nl = 0;
+
+                char *sep = strchr(buf, '=');
+                if (sep == nullptr)
+                    continue;
+                *sep = 0;
+                sep++;
+
+                std::string key = buf;
+                std::string value = sep;
+
+                fprintf(dumpFilePtr, " <KVPair>\n");
+                fprintf(dumpFilePtr, "%s", ("  <Key>" + key + "</Key>\n").c_str());
+                fprintf(dumpFilePtr, "%s", ("  <Value>" + value + "</Value>\n").c_str());
+                fprintf(dumpFilePtr, " </KVPair>\n");
+
+            }
+            fclose(storeFilePtr);
+        }
+
+        fprintf(dumpFilePtr, "</KVStore>\n");
+
+        fclose(dumpFilePtr);
+
+        DumpToFile.unlock();
+        return 0;
+    }
+
+    int RestoreFromFile(const std::string &filename) {
+        restoreFromFile.lock();
+        std::vector<FILE *> fd_vector;
+
+        for (int i = 0; i < numSetsInCache; i++) {
+            std::string fname = "KVStore/" + std::to_string(i);
+            FILE *fp = fopen(fname.c_str(), "a");
+            if (!fp) {
+                cout << "IO Error";
+                restoreFromFile.unlock();
+
+                return -errno;
+            }
+            fd_vector.push_back(fp);
+        }
+
+        FILE *sourceFile = fopen(filename.c_str(), "r");
+        if (!sourceFile) {
+            restoreFromFile.unlock();
+
+            return -errno;
+        }
+        char *buf = nullptr;
+        size_t buflen = 0;
+        getline(&buf, &buflen, sourceFile);
+        getline(&buf, &buflen, sourceFile);
+        getline(&buf, &buflen, sourceFile);
+
+        while (getline(&buf, &buflen, sourceFile) > 0) {
+
+            std::string key;
+            std::string value;
+
+            std::string line = std::string(buf);
+            if (buf[3] == 'K' && buf[4] == 'e' && buf[5] == 'y') {
+                std::size_t start_of_key = line.find("<Key>");
+                std::size_t end_of_key = line.find_last_of("</Key>");
+                key = line.substr(start_of_key + 5, line.length() - 14);
+            }
+            getline(&buf, &buflen, sourceFile);
+            line = std::string(buf);
+
+            if (buf[3] == 'V' && buf[4] == 'a' && buf[5] == 'l') {
+                std::size_t start_of_Value = line.find("<Value>");
+                std::size_t end_of_Value = line.find_last_of("</Value>");
+                value = line.substr(start_of_Value + 7, line.length() - 18);
+            }
+
+            getline(&buf, &buflen, sourceFile);
+            getline(&buf, &buflen, sourceFile);
+
+            FILE *fp = fd_vector[getSetId(key)];
+//            cout << key << value << std::endl;
+            fprintf(fp, "%s=%s\n", key.c_str(), value.c_str());
+
+
+        }
+        fclose(sourceFile);
+
+        for (int i = 0; i < numSetsInCache; i++) {
+
+            fclose(fd_vector[i]);
+        }
+        restoreFromFile.unlock();
+        return 0;
+    }
+
+
+};
+
+
+// To be used to access key value pairs when not found in cache
+// this will load the required file into the temporary map ie m
+int populateMap(std::string &key, std::map<std::string, std::string> *m) {
+    std::string fname = getFilename(key);
+    int count = 0;
+    if (access(fname.c_str(), R_OK) < 0)
+        return -errno;
+
+    FILE *fp = fopen(fname.c_str(), "r");
+    if (!fp)
+        return -errno;
+
+    m->clear();
+
+    char *buf = nullptr;
+    size_t buflen = 0;
+    while (getline(&buf, &buflen, fp) > 0) {
+        char *nl = strchr(buf, '\n');
+        if (nl == nullptr)
+            continue;
+        *nl = 0;
+
+        char *sep = strchr(buf, '=');
+        if (sep == nullptr)
+            continue;
+        *sep = 0;
+        sep++;
+
+        std::string s1 = buf;
+        std::string s2 = sep;
+
+        (*m)[s1] = s2;
+
+        count++;
+    }
+
+    if (buf)
+        free(buf);
+
+    fclose(fp);
+    return count;
+}
+
+// Rewrites the whole file in case of a delete
+int storeMapToFile(std::string &key, std::map<std::string, std::string> *m) {
+    mapToFile.lock();
+    std::string fname = getFilename(key);
+
+
+    FILE *fp = fopen(fname.c_str(), "w");
+    if (!fp) {
+        return -errno;
+    }
+    int count = 0;
+    if (m->empty()) {
+        fclose(fp);
+        mapToFile.unlock();
+
+        return 0;
+    }
+
+    for (std::map<std::string, std::string>::iterator it = m->begin(); it != m->end(); it++) {
+        fprintf(fp, "%s=%s\n", it->first.c_str(), it->second.c_str());
+        count++;
+    }
+
+//    std::cout << count;
+    fclose(fp);
+    mapToFile.unlock();
+    return count;
+}
+
+
+// Inserts key-value pair incrementally
+int putIntoFile(std::string &key, std::string &value) {
+    addToFile.lock();
+    std::string fname = getFilename(key);
+
+
+    FILE *fp = fopen(fname.c_str(), "a");
+    if (!fp) {
+        addToFile.unlock();
+        return -errno;
+    }
+    fprintf(fp, "%s=%s\n", key.c_str(), value.c_str());
+
+    fclose(fp);
+    addToFile.unlock();
+    return 0;
+}
+
+std::string toXML(std::string str) {
+    std::string response, key, value;
+    std::string header = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n";
+    std::string msg = "<KVMessage type=\"resp\">\n";
+    if (debugger_mode) {
+        cout << "\nstr is =>" << str << "<=\n" << std::endl;
+    }
+    if (str == "Success" || str == "Error Message" || str == "Does not exist")
+        msg = msg + "<Message>" + str + "</Message>\n";
+    else {
+        for (auto i = 0; i < str.length(); i++) {
+            if (str[i] != ' ')
+                key += str[i];
+            else {
+                value = str.substr(i + 1);
+                break;
+            }
+
+        }
+
+        msg = msg + "<Key>" + key + "</Key>\n" + "<Value>" + value + "</Value>\n";
+    }
+    response = header + msg + "</KVMessage>\n";
+    return response;
+}
+
+
+//convert xml format to plain text
+std::string fromxml(std::string str) {
+    std::string request_type;
+    std::string msg_type = str.substr(56, 6);
+    std::string key;
+    std::string value;
+    int i = 0, j = 0;
+    if (msg_type == "putreq") {
+        request_type = "PUT";
+        for (i = 70; str[i] != '<'; i++) {
+            key += str[i];
+        }
+        j = i + 14;
+        for (; str[j] != '<'; j++) {
+            value += str[j];
+        }
+        key = key + delimiter + value;
+    } else if (msg_type == "getreq") {
+        request_type = "GET";
+        for (i = 70; str[i] != '<'; i++) {
+            key += str[i];
+        }
+    } else {
+        request_type = "DEL";
+        for (i = 70; str[i] != '<'; i++) {
+            key += str[i];
+        }
+    }
+    request_type = request_type + delimiter + key;
+    return request_type;
+}
+
+
+//int main() {
+//
+//    KVStore KS;
+//    KS.RestoreFromFile("testfile.xml");
+////    sleep(10);
+//    KS.dumpToFile("testfile.xml");
+//
+//}
\ No newline at end of file

Makefile

+all: do
+
+do: main.o nodeInformation.o helperClass.o init.o port.o functions.o 
+	g++ main.o init.o functions.o port.o nodeInformation.o helperClass.o -o prog -lcrypto -lpthread
+	
+main.o: main.cpp
+		g++ -std=c++11 -c main.cpp
+		
+init.o: init.cpp
+		g++ -std=c++11 -c init.cpp
+
+port.o: port.cpp
+		g++ -std=c++11 -c port.cpp
+		
+functions.o: functions.cpp
+				 g++ -std=c++11 -c functions.cpp
+			 
+nodeInformation.o: nodeInformation.cpp
+				   g++ -std=c++11 -c nodeInformation.cpp
+				   
+helperClass.o: helperClass.cpp
+			   g++ -std=c++11 -c helperClass.cpp			
+
+
+	

README.md

+################################################################################################################################################
+TEAM MEMBERS
+################################################################################################################################################
+1.Vikas Verma(193059003)
+2.Apaar Bansal(193050035)
+3.Ashwini Yadav(193050057)
+4.Parashiv(193050029)
+
+##############################################################################################################################################
+HOW TO EXECUTE THE KVSTORE
+##############################################################################################################################################
+
+
+1.To compile the code
+	g++ KVServer.cpp -lpthread -lssl -lcrypto -o KVServer
+
+2. Execute the KVServer
+	./KVServer
+
+3.option to execute program	
+	Enter 1 to create a new ring
+	Enter 2 to join some existing ring
+	Enter 3 to display finger table
+
+

ThreadPool.h

+#pragma once
+
+#include <functional>
+#include <future>
+#include <mutex>
+#include <queue>
+#include <thread>
+#include <utility>
+#include <vector>
+
+
+#include <mutex>
+#include <queue>
+
+// Thread safe implementation of a Queue using a std::queue
+template<typename T>
+class SafeQueue {
+private:
+    std::queue<T> m_queue;
+    std::mutex m_mutex;
+public:
+    SafeQueue() {
+
+    }
+
+    SafeQueue(SafeQueue &other) {
+        //TODO:
+    }
+
+    ~SafeQueue() {
+
+    }
+
+
+    bool empty() {
+        std::unique_lock<std::mutex> lock(m_mutex);
+        return m_queue.empty();
+    }
+
+    int size() {
+        std::unique_lock<std::mutex> lock(m_mutex);
+        return m_queue.size();
+    }
+
+    void enqueue(T &t) {
+        std::unique_lock<std::mutex> lock(m_mutex);
+        m_queue.push(t);
+    }
+
+    bool dequeue(T &t) {
+        std::unique_lock<std::mutex> lock(m_mutex);
+
+        if (m_queue.empty()) {
+            return false;
+        }
+        t = std::move(m_queue.front());
+
+        m_queue.pop();
+        return true;
+    }
+};
+
+class ThreadPool {
+private:
+    class ThreadWorker {
+    private:
+        int m_id;
+        ThreadPool *m_pool;
+    public:
+        ThreadWorker(ThreadPool *pool, const int id)
+                : m_pool(pool), m_id(id) {
+        }
+
+        void operator()() {
+            std::function<void()> func;
+            bool dequeued;
+            while (!m_pool->m_shutdown) {
+                {
+                    std::unique_lock<std::mutex> lock(m_pool->m_conditional_mutex);
+                    if (m_pool->m_queue.empty()) {
+                        m_pool->m_conditional_lock.wait(lock);
+                    }
+                    dequeued = m_pool->m_queue.dequeue(func);
+                }
+                if (dequeued) {
+                    func();
+                }
+            }
+        }
+    };
+
+    bool m_shutdown;
+    SafeQueue<std::function<void()>> m_queue;
+    std::vector<std::thread> m_threads;
+    std::mutex m_conditional_mutex;
+    std::condition_variable m_conditional_lock;
+public:
+    ThreadPool(const int n_threads)
+            : m_threads(std::vector<std::thread>(n_threads)), m_shutdown(false) {
+    }
+
+    ThreadPool(const ThreadPool &) = delete;
+
+    ThreadPool(ThreadPool &&) = delete;
+
+    ThreadPool &operator=(const ThreadPool &) = delete;
+
+    ThreadPool &operator=(ThreadPool &&) = delete;
+
+    // Inits thread pool
+    void init() {
+        for (int i = 0; i < m_threads.size(); ++i) {
+            m_threads[i] = std::thread(ThreadWorker(this, i));
+        }
+    }
+
+    // Waits until threads finish their current task and shutdowns the pool
+    void shutdown() {
+        m_shutdown = true;
+        m_conditional_lock.notify_all();
+
+        for (int i = 0; i < m_threads.size(); ++i) {
+            if (m_threads[i].joinable()) {
+                m_threads[i].join();
+            }
+        }
+    }
+
+    // Submit a function to be executed asynchronously by the pool
+    template<typename F, typename...Args>
+    auto submit(F &&f, Args &&... args) -> std::future<decltype(f(args...))> {
+        // Create a function with bounded parameters ready to execute
+        std::function<decltype(f(args...))()> func = std::bind(std::forward<F>(f), std::forward<Args>(args)...);
+        // Encapsulate it into a shared ptr in order to be able to copy construct / assign
+        auto task_ptr = std::make_shared<std::packaged_task<decltype(f(args...))()>>(func);
+
+        // Wrap packaged task into void function
+        std::function<void()> wrapper_func = [task_ptr]() {
+            (*task_ptr)();
+        };
+
+        // Enqueue generic wrapper function
+        m_queue.enqueue(wrapper_func);
+
+        // Wake up one thread if its waiting
+        m_conditional_lock.notify_one();
+
+        // Return future from promise
+        return task_ptr->get_future();
+    }
+};
\ No newline at end of file

cmake-build-debug/CMakeFiles/3.15.3/CMakeCCompiler.cmake

+set(CMAKE_C_COMPILER "/usr/bin/cc")
+set(CMAKE_C_COMPILER_ARG1 "")
+set(CMAKE_C_COMPILER_ID "GNU")
+set(CMAKE_C_COMPILER_VERSION "7.4.0")
+set(CMAKE_C_COMPILER_VERSION_INTERNAL "")
+set(CMAKE_C_COMPILER_WRAPPER "")
+set(CMAKE_C_STANDARD_COMPUTED_DEFAULT "11")
+set(CMAKE_C_COMPILE_FEATURES "c_std_90;c_function_prototypes;c_std_99;c_restrict;c_variadic_macros;c_std_11;c_static_assert")
+set(CMAKE_C90_COMPILE_FEATURES "c_std_90;c_function_prototypes")
+set(CMAKE_C99_COMPILE_FEATURES "c_std_99;c_restrict;c_variadic_macros")
+set(CMAKE_C11_COMPILE_FEATURES "c_std_11;c_static_assert")
+
+set(CMAKE_C_PLATFORM_ID "Linux")
+set(CMAKE_C_SIMULATE_ID "")
+set(CMAKE_C_COMPILER_FRONTEND_VARIANT "")
+set(CMAKE_C_SIMULATE_VERSION "")
+
+
+
+set(CMAKE_AR "/usr/bin/ar")
+set(CMAKE_C_COMPILER_AR "/usr/bin/gcc-ar-7")
+set(CMAKE_RANLIB "/usr/bin/ranlib")
+set(CMAKE_C_COMPILER_RANLIB "/usr/bin/gcc-ranlib-7")
+set(CMAKE_LINKER "/usr/bin/ld")
+set(CMAKE_MT "")
+set(CMAKE_COMPILER_IS_GNUCC 1)
+set(CMAKE_C_COMPILER_LOADED 1)
+set(CMAKE_C_COMPILER_WORKS TRUE)
+set(CMAKE_C_ABI_COMPILED TRUE)
+set(CMAKE_COMPILER_IS_MINGW )
+set(CMAKE_COMPILER_IS_CYGWIN )
+if(CMAKE_COMPILER_IS_CYGWIN)
+  set(CYGWIN 1)
+  set(UNIX 1)
+endif()
+
+set(CMAKE_C_COMPILER_ENV_VAR "CC")
+
+if(CMAKE_COMPILER_IS_MINGW)
+  set(MINGW 1)
+endif()
+set(CMAKE_C_COMPILER_ID_RUN 1)
+set(CMAKE_C_SOURCE_FILE_EXTENSIONS c;m)
+set(CMAKE_C_IGNORE_EXTENSIONS h;H;o;O;obj;OBJ;def;DEF;rc;RC)
+set(CMAKE_C_LINKER_PREFERENCE 10)
+
+# Save compiler ABI information.
+set(CMAKE_C_SIZEOF_DATA_PTR "8")
+set(CMAKE_C_COMPILER_ABI "ELF")
+set(CMAKE_C_LIBRARY_ARCHITECTURE "x86_64-linux-gnu")
+
+if(CMAKE_C_SIZEOF_DATA_PTR)
+  set(CMAKE_SIZEOF_VOID_P "${CMAKE_C_SIZEOF_DATA_PTR}")
+endif()
+
+if(CMAKE_C_COMPILER_ABI)
+  set(CMAKE_INTERNAL_PLATFORM_ABI "${CMAKE_C_COMPILER_ABI}")
+endif()
+
+if(CMAKE_C_LIBRARY_ARCHITECTURE)
+  set(CMAKE_LIBRARY_ARCHITECTURE "x86_64-linux-gnu")
+endif()
+
+set(CMAKE_C_CL_SHOWINCLUDES_PREFIX "")
+if(CMAKE_C_CL_SHOWINCLUDES_PREFIX)
+  set(CMAKE_CL_SHOWINCLUDES_PREFIX "${CMAKE_C_CL_SHOWINCLUDES_PREFIX}")
+endif()
+
+
+
+
+
+set(CMAKE_C_IMPLICIT_INCLUDE_DIRECTORIES "/usr/lib/gcc/x86_64-linux-gnu/7/include;/usr/local/include;/usr/lib/gcc/x86_64-linux-gnu/7/include-fixed;/usr/include/x86_64-linux-gnu;/usr/include")
+set(CMAKE_C_IMPLICIT_LINK_LIBRARIES "gcc;gcc_s;c;gcc;gcc_s")
+set(CMAKE_C_IMPLICIT_LINK_DIRECTORIES "/usr/lib/gcc/x86_64-linux-gnu/7;/usr/lib/x86_64-linux-gnu;/usr/lib;/lib/x86_64-linux-gnu;/lib")
+set(CMAKE_C_IMPLICIT_LINK_FRAMEWORK_DIRECTORIES "")

cmake-build-debug/CMakeFiles/3.15.3/CMakeCXXCompiler.cmake

+set(CMAKE_CXX_COMPILER "/usr/bin/c++")
+set(CMAKE_CXX_COMPILER_ARG1 "")
+set(CMAKE_CXX_COMPILER_ID "GNU")
+set(CMAKE_CXX_COMPILER_VERSION "7.4.0")
+set(CMAKE_CXX_COMPILER_VERSION_INTERNAL "")
+set(CMAKE_CXX_COMPILER_WRAPPER "")
+set(CMAKE_CXX_STANDARD_COMPUTED_DEFAULT "14")
+set(CMAKE_CXX_COMPILE_FEATURES "cxx_std_98;cxx_template_template_parameters;cxx_std_11;cxx_alias_templates;cxx_alignas;cxx_alignof;cxx_attributes;cxx_auto_type;cxx_constexpr;cxx_decltype;cxx_decltype_incomplete_return_types;cxx_default_function_template_args;cxx_defaulted_functions;cxx_defaulted_move_initializers;cxx_delegating_constructors;cxx_deleted_functions;cxx_enum_forward_declarations;cxx_explicit_conversions;cxx_extended_friend_declarations;cxx_extern_templates;cxx_final;cxx_func_identifier;cxx_generalized_initializers;cxx_inheriting_constructors;cxx_inline_namespaces;cxx_lambdas;cxx_local_type_template_args;cxx_long_long_type;cxx_noexcept;cxx_nonstatic_member_init;cxx_nullptr;cxx_override;cxx_range_for;cxx_raw_string_literals;cxx_reference_qualified_functions;cxx_right_angle_brackets;cxx_rvalue_references;cxx_sizeof_member;cxx_static_assert;cxx_strong_enums;cxx_thread_local;cxx_trailing_return_types;cxx_unicode_literals;cxx_uniform_initialization;cxx_unrestricted_unions;cxx_user_literals;cxx_variadic_macros;cxx_variadic_templates;cxx_std_14;cxx_aggregate_default_initializers;cxx_attribute_deprecated;cxx_binary_literals;cxx_contextual_conversions;cxx_decltype_auto;cxx_digit_separators;cxx_generic_lambdas;cxx_lambda_init_captures;cxx_relaxed_constexpr;cxx_return_type_deduction;cxx_variable_templates;cxx_std_17")
+set(CMAKE_CXX98_COMPILE_FEATURES "cxx_std_98;cxx_template_template_parameters")
+set(CMAKE_CXX11_COMPILE_FEATURES "cxx_std_11;cxx_alias_templates;cxx_alignas;cxx_alignof;cxx_attributes;cxx_auto_type;cxx_constexpr;cxx_decltype;cxx_decltype_incomplete_return_types;cxx_default_function_template_args;cxx_defaulted_functions;cxx_defaulted_move_initializers;cxx_delegating_constructors;cxx_deleted_functions;cxx_enum_forward_declarations;cxx_explicit_conversions;cxx_extended_friend_declarations;cxx_extern_templates;cxx_final;cxx_func_identifier;cxx_generalized_initializers;cxx_inheriting_constructors;cxx_inline_namespaces;cxx_lambdas;cxx_local_type_template_args;cxx_long_long_type;cxx_noexcept;cxx_nonstatic_member_init;cxx_nullptr;cxx_override;cxx_range_for;cxx_raw_string_literals;cxx_reference_qualified_functions;cxx_right_angle_brackets;cxx_rvalue_references;cxx_sizeof_member;cxx_static_assert;cxx_strong_enums;cxx_thread_local;cxx_trailing_return_types;cxx_unicode_literals;cxx_uniform_initialization;cxx_unrestricted_unions;cxx_user_literals;cxx_variadic_macros;cxx_variadic_templates")
+set(CMAKE_CXX14_COMPILE_FEATURES "cxx_std_14;cxx_aggregate_default_initializers;cxx_attribute_deprecated;cxx_binary_literals;cxx_contextual_conversions;cxx_decltype_auto;cxx_digit_separators;cxx_generic_lambdas;cxx_lambda_init_captures;cxx_relaxed_constexpr;cxx_return_type_deduction;cxx_variable_templates")
+set(CMAKE_CXX17_COMPILE_FEATURES "cxx_std_17")
+set(CMAKE_CXX20_COMPILE_FEATURES "")
+
+set(CMAKE_CXX_PLATFORM_ID "Linux")
+set(CMAKE_CXX_SIMULATE_ID "")
+set(CMAKE_CXX_COMPILER_FRONTEND_VARIANT "")
+set(CMAKE_CXX_SIMULATE_VERSION "")
+
+
+
+set(CMAKE_AR "/usr/bin/ar")
+set(CMAKE_CXX_COMPILER_AR "/usr/bin/gcc-ar-7")
+set(CMAKE_RANLIB "/usr/bin/ranlib")
+set(CMAKE_CXX_COMPILER_RANLIB "/usr/bin/gcc-ranlib-7")
+set(CMAKE_LINKER "/usr/bin/ld")
+set(CMAKE_MT "")
+set(CMAKE_COMPILER_IS_GNUCXX 1)
+set(CMAKE_CXX_COMPILER_LOADED 1)
+set(CMAKE_CXX_COMPILER_WORKS TRUE)
+set(CMAKE_CXX_ABI_COMPILED TRUE)
+set(CMAKE_COMPILER_IS_MINGW )
+set(CMAKE_COMPILER_IS_CYGWIN )
+if(CMAKE_COMPILER_IS_CYGWIN)
+  set(CYGWIN 1)
+  set(UNIX 1)
+endif()
+
+set(CMAKE_CXX_COMPILER_ENV_VAR "CXX")
+
+if(CMAKE_COMPILER_IS_MINGW)
+  set(MINGW 1)
+endif()
+set(CMAKE_CXX_COMPILER_ID_RUN 1)
+set(CMAKE_CXX_IGNORE_EXTENSIONS inl;h;hpp;HPP;H;o;O;obj;OBJ;def;DEF;rc;RC)
+set(CMAKE_CXX_SOURCE_FILE_EXTENSIONS C;M;c++;cc;cpp;cxx;mm;CPP)
+set(CMAKE_CXX_LINKER_PREFERENCE 30)
+set(CMAKE_CXX_LINKER_PREFERENCE_PROPAGATES 1)
+
+# Save compiler ABI information.
+set(CMAKE_CXX_SIZEOF_DATA_PTR "8")
+set(CMAKE_CXX_COMPILER_ABI "ELF")
+set(CMAKE_CXX_LIBRARY_ARCHITECTURE "x86_64-linux-gnu")
+
+if(CMAKE_CXX_SIZEOF_DATA_PTR)
+  set(CMAKE_SIZEOF_VOID_P "${CMAKE_CXX_SIZEOF_DATA_PTR}")
+endif()
+
+if(CMAKE_CXX_COMPILER_ABI)
+  set(CMAKE_INTERNAL_PLATFORM_ABI "${CMAKE_CXX_COMPILER_ABI}")
+endif()
+
+if(CMAKE_CXX_LIBRARY_ARCHITECTURE)
+  set(CMAKE_LIBRARY_ARCHITECTURE "x86_64-linux-gnu")
+endif()
+
+set(CMAKE_CXX_CL_SHOWINCLUDES_PREFIX "")
+if(CMAKE_CXX_CL_SHOWINCLUDES_PREFIX)
+  set(CMAKE_CL_SHOWINCLUDES_PREFIX "${CMAKE_CXX_CL_SHOWINCLUDES_PREFIX}")
+endif()
+
+
+
+
+
+set(CMAKE_CXX_IMPLICIT_INCLUDE_DIRECTORIES "/usr/include/c++/7;/usr/include/x86_64-linux-gnu/c++/7;/usr/include/c++/7/backward;/usr/lib/gcc/x86_64-linux-gnu/7/include;/usr/local/include;/usr/lib/gcc/x86_64-linux-gnu/7/include-fixed;/usr/include/x86_64-linux-gnu;/usr/include")
+set(CMAKE_CXX_IMPLICIT_LINK_LIBRARIES "crypto;stdc++;m;gcc_s;gcc;pthread;c;gcc_s;gcc")
+set(CMAKE_CXX_IMPLICIT_LINK_DIRECTORIES "/usr/lib/gcc/x86_64-linux-gnu/7;/usr/lib/x86_64-linux-gnu;/usr/lib;/lib/x86_64-linux-gnu;/lib")
+set(CMAKE_CXX_IMPLICIT_LINK_FRAMEWORK_DIRECTORIES "")

cmake-build-debug/CMakeFiles/3.15.3/CMakeSystem.cmake

+set(CMAKE_HOST_SYSTEM "Linux-5.0.0-31-generic")
+set(CMAKE_HOST_SYSTEM_NAME "Linux")
+set(CMAKE_HOST_SYSTEM_VERSION "5.0.0-31-generic")
+set(CMAKE_HOST_SYSTEM_PROCESSOR "x86_64")
+
+
+
+set(CMAKE_SYSTEM "Linux-5.0.0-31-generic")
+set(CMAKE_SYSTEM_NAME "Linux")
+set(CMAKE_SYSTEM_VERSION "5.0.0-31-generic")
+set(CMAKE_SYSTEM_PROCESSOR "x86_64")
+
+set(CMAKE_CROSSCOMPILING "FALSE")
+
+set(CMAKE_SYSTEM_LOADED 1)

cmake-build-debug/CMakeFiles/CMakeDirectoryInformation.cmake

+# CMAKE generated file: DO NOT EDIT!
+# Generated by "Unix Makefiles" Generator, CMake Version 3.15
+
+# Relative path conversion top directories.
+set(CMAKE_RELATIVE_PATH_TOP_SOURCE "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT")
+set(CMAKE_RELATIVE_PATH_TOP_BINARY "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug")
+
+# Force unix paths in dependencies.
+set(CMAKE_FORCE_UNIX_PATHS 1)
+
+
+# The C and CXX include file regular expressions for this directory.
+set(CMAKE_C_INCLUDE_REGEX_SCAN "^.*$")
+set(CMAKE_C_INCLUDE_REGEX_COMPLAIN "^$")
+set(CMAKE_CXX_INCLUDE_REGEX_SCAN ${CMAKE_C_INCLUDE_REGEX_SCAN})
+set(CMAKE_CXX_INCLUDE_REGEX_COMPLAIN ${CMAKE_C_INCLUDE_REGEX_COMPLAIN})

cmake-build-debug/CMakeFiles/KVClient.dir/DependInfo.cmake

+# The set of languages for which implicit dependencies are needed:
+set(CMAKE_DEPENDS_LANGUAGES
+  "CXX"
+  )
+# The set of files for implicit dependencies of each language:
+set(CMAKE_DEPENDS_CHECK_CXX
+  "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/KVClient.cpp" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/CMakeFiles/KVClient.dir/KVClient.cpp.o"
+  )
+set(CMAKE_CXX_COMPILER_ID "GNU")
+
+# The include file search paths:
+set(CMAKE_CXX_TARGET_INCLUDE_PATH
+  )
+
+# Targets to which this target links.
+set(CMAKE_TARGET_LINKED_INFO_FILES
+  )
+
+# Fortran module output directory.
+set(CMAKE_Fortran_TARGET_MODULE_DIR "")

cmake-build-debug/CMakeFiles/KVClient.dir/build.make

+# CMAKE generated file: DO NOT EDIT!
+# Generated by "Unix Makefiles" Generator, CMake Version 3.15
+
+# Delete rule output on recipe failure.
+.DELETE_ON_ERROR:
+
+
+#=============================================================================
+# Special targets provided by cmake.
+
+# Disable implicit rules so canonical targets will work.
+.SUFFIXES:
+
+
+# Remove some rules from gmake that .SUFFIXES does not remove.
+SUFFIXES =
+
+.SUFFIXES: .hpux_make_needs_suffix_list
+
+
+# Suppress display of executed commands.
+$(VERBOSE).SILENT:
+
+
+# A target that is always out of date.
+cmake_force:
+
+.PHONY : cmake_force
+
+#=============================================================================
+# Set environment variables for the build.
+
+# The shell in which to execute make rules.
+SHELL = /bin/sh
+
+# The CMake executable.
+CMAKE_COMMAND = /home/apaar/Downloads/clion-2019.2.5/bin/cmake/linux/bin/cmake
+
+# The command to remove a file.
+RM = /home/apaar/Downloads/clion-2019.2.5/bin/cmake/linux/bin/cmake -E remove -f
+
+# Escaping for special characters.
+EQUALS = =
+
+# The top-level source directory on which CMake was run.
+CMAKE_SOURCE_DIR = "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT"
+
+# The top-level build directory on which CMake was run.
+CMAKE_BINARY_DIR = "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug"
+
+# Include any dependencies generated for this target.
+include CMakeFiles/KVClient.dir/depend.make
+
+# Include the progress variables for this target.
+include CMakeFiles/KVClient.dir/progress.make
+
+# Include the compile flags for this target's objects.
+include CMakeFiles/KVClient.dir/flags.make
+
+CMakeFiles/KVClient.dir/KVClient.cpp.o: CMakeFiles/KVClient.dir/flags.make
+CMakeFiles/KVClient.dir/KVClient.cpp.o: ../KVClient.cpp
+	@$(CMAKE_COMMAND) -E cmake_echo_color --switch=$(COLOR) --green --progress-dir="/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/CMakeFiles" --progress-num=$(CMAKE_PROGRESS_1) "Building CXX object CMakeFiles/KVClient.dir/KVClient.cpp.o"
+	/usr/bin/c++  $(CXX_DEFINES) $(CXX_INCLUDES) $(CXX_FLAGS) -o CMakeFiles/KVClient.dir/KVClient.cpp.o -c "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/KVClient.cpp"
+
+CMakeFiles/KVClient.dir/KVClient.cpp.i: cmake_force
+	@$(CMAKE_COMMAND) -E cmake_echo_color --switch=$(COLOR) --green "Preprocessing CXX source to CMakeFiles/KVClient.dir/KVClient.cpp.i"
+	/usr/bin/c++ $(CXX_DEFINES) $(CXX_INCLUDES) $(CXX_FLAGS) -E "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/KVClient.cpp" > CMakeFiles/KVClient.dir/KVClient.cpp.i
+
+CMakeFiles/KVClient.dir/KVClient.cpp.s: cmake_force
+	@$(CMAKE_COMMAND) -E cmake_echo_color --switch=$(COLOR) --green "Compiling CXX source to assembly CMakeFiles/KVClient.dir/KVClient.cpp.s"
+	/usr/bin/c++ $(CXX_DEFINES) $(CXX_INCLUDES) $(CXX_FLAGS) -S "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/KVClient.cpp" -o CMakeFiles/KVClient.dir/KVClient.cpp.s
+
+# Object files for target KVClient
+KVClient_OBJECTS = \
+"CMakeFiles/KVClient.dir/KVClient.cpp.o"
+
+# External object files for target KVClient
+KVClient_EXTERNAL_OBJECTS =
+
+KVClient: CMakeFiles/KVClient.dir/KVClient.cpp.o
+KVClient: CMakeFiles/KVClient.dir/build.make
+KVClient: CMakeFiles/KVClient.dir/link.txt
+	@$(CMAKE_COMMAND) -E cmake_echo_color --switch=$(COLOR) --green --bold --progress-dir="/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/CMakeFiles" --progress-num=$(CMAKE_PROGRESS_2) "Linking CXX executable KVClient"
+	$(CMAKE_COMMAND) -E cmake_link_script CMakeFiles/KVClient.dir/link.txt --verbose=$(VERBOSE)
+
+# Rule to build all files generated by this target.
+CMakeFiles/KVClient.dir/build: KVClient
+
+.PHONY : CMakeFiles/KVClient.dir/build
+
+CMakeFiles/KVClient.dir/clean:
+	$(CMAKE_COMMAND) -P CMakeFiles/KVClient.dir/cmake_clean.cmake
+.PHONY : CMakeFiles/KVClient.dir/clean
+
+CMakeFiles/KVClient.dir/depend:
+	cd "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug" && $(CMAKE_COMMAND) -E cmake_depends "Unix Makefiles" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/CMakeFiles/KVClient.dir/DependInfo.cmake" --color=$(COLOR)
+.PHONY : CMakeFiles/KVClient.dir/depend
+

cmake-build-debug/CMakeFiles/KVClient.dir/cmake_clean.cmake

+file(REMOVE_RECURSE
+  "CMakeFiles/KVClient.dir/KVClient.cpp.o"
+  "KVClient"
+  "KVClient.pdb"
+)
+
+# Per-language clean rules from dependency scanning.
+foreach(lang CXX)
+  include(CMakeFiles/KVClient.dir/cmake_clean_${lang}.cmake OPTIONAL)
+endforeach()

cmake-build-debug/CMakeFiles/KVClient.dir/depend.make

+# Empty dependencies file for KVClient.
+# This may be replaced when dependencies are built.

cmake-build-debug/CMakeFiles/KVClient.dir/flags.make

+# CMAKE generated file: DO NOT EDIT!
+# Generated by "Unix Makefiles" Generator, CMake Version 3.15
+
+# compile CXX with /usr/bin/c++
+CXX_FLAGS = -lcrypto -pthread -g  
+
+CXX_DEFINES = 
+
+CXX_INCLUDES = 
+

cmake-build-debug/CMakeFiles/KVClient.dir/link.txt

+/usr/bin/c++  -lcrypto -pthread -g   CMakeFiles/KVClient.dir/KVClient.cpp.o  -o KVClient -lcrypto 

cmake-build-debug/CMakeFiles/KVClient.dir/progress.make

+CMAKE_PROGRESS_1 = 1
+CMAKE_PROGRESS_2 = 2
+

cmake-build-debug/CMakeFiles/KVServer.dir/DependInfo.cmake

+# The set of languages for which implicit dependencies are needed:
+set(CMAKE_DEPENDS_LANGUAGES
+  "CXX"
+  )
+# The set of files for implicit dependencies of each language:
+set(CMAKE_DEPENDS_CHECK_CXX
+  "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/KVServer.cpp" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/CMakeFiles/KVServer.dir/KVServer.cpp.o"
+  )
+set(CMAKE_CXX_COMPILER_ID "GNU")
+
+# The include file search paths:
+set(CMAKE_CXX_TARGET_INCLUDE_PATH
+  )
+
+# Targets to which this target links.
+set(CMAKE_TARGET_LINKED_INFO_FILES
+  )
+
+# Fortran module output directory.
+set(CMAKE_Fortran_TARGET_MODULE_DIR "")

cmake-build-debug/CMakeFiles/KVServer.dir/build.make

+# CMAKE generated file: DO NOT EDIT!
+# Generated by "Unix Makefiles" Generator, CMake Version 3.15
+
+# Delete rule output on recipe failure.
+.DELETE_ON_ERROR:
+
+
+#=============================================================================
+# Special targets provided by cmake.
+
+# Disable implicit rules so canonical targets will work.
+.SUFFIXES:
+
+
+# Remove some rules from gmake that .SUFFIXES does not remove.
+SUFFIXES =
+
+.SUFFIXES: .hpux_make_needs_suffix_list
+
+
+# Suppress display of executed commands.
+$(VERBOSE).SILENT:
+
+
+# A target that is always out of date.
+cmake_force:
+
+.PHONY : cmake_force
+
+#=============================================================================
+# Set environment variables for the build.
+
+# The shell in which to execute make rules.
+SHELL = /bin/sh
+
+# The CMake executable.
+CMAKE_COMMAND = /home/apaar/Downloads/clion-2019.2.5/bin/cmake/linux/bin/cmake
+
+# The command to remove a file.
+RM = /home/apaar/Downloads/clion-2019.2.5/bin/cmake/linux/bin/cmake -E remove -f
+
+# Escaping for special characters.
+EQUALS = =
+
+# The top-level source directory on which CMake was run.
+CMAKE_SOURCE_DIR = "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT"
+
+# The top-level build directory on which CMake was run.
+CMAKE_BINARY_DIR = "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug"
+
+# Include any dependencies generated for this target.
+include CMakeFiles/KVServer.dir/depend.make
+
+# Include the progress variables for this target.
+include CMakeFiles/KVServer.dir/progress.make
+
+# Include the compile flags for this target's objects.
+include CMakeFiles/KVServer.dir/flags.make
+
+CMakeFiles/KVServer.dir/KVServer.cpp.o: CMakeFiles/KVServer.dir/flags.make
+CMakeFiles/KVServer.dir/KVServer.cpp.o: ../KVServer.cpp
+	@$(CMAKE_COMMAND) -E cmake_echo_color --switch=$(COLOR) --green --progress-dir="/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/CMakeFiles" --progress-num=$(CMAKE_PROGRESS_1) "Building CXX object CMakeFiles/KVServer.dir/KVServer.cpp.o"
+	/usr/bin/c++  $(CXX_DEFINES) $(CXX_INCLUDES) $(CXX_FLAGS) -o CMakeFiles/KVServer.dir/KVServer.cpp.o -c "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/KVServer.cpp"
+
+CMakeFiles/KVServer.dir/KVServer.cpp.i: cmake_force
+	@$(CMAKE_COMMAND) -E cmake_echo_color --switch=$(COLOR) --green "Preprocessing CXX source to CMakeFiles/KVServer.dir/KVServer.cpp.i"
+	/usr/bin/c++ $(CXX_DEFINES) $(CXX_INCLUDES) $(CXX_FLAGS) -E "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/KVServer.cpp" > CMakeFiles/KVServer.dir/KVServer.cpp.i
+
+CMakeFiles/KVServer.dir/KVServer.cpp.s: cmake_force
+	@$(CMAKE_COMMAND) -E cmake_echo_color --switch=$(COLOR) --green "Compiling CXX source to assembly CMakeFiles/KVServer.dir/KVServer.cpp.s"
+	/usr/bin/c++ $(CXX_DEFINES) $(CXX_INCLUDES) $(CXX_FLAGS) -S "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/KVServer.cpp" -o CMakeFiles/KVServer.dir/KVServer.cpp.s
+
+# Object files for target KVServer
+KVServer_OBJECTS = \
+"CMakeFiles/KVServer.dir/KVServer.cpp.o"
+
+# External object files for target KVServer
+KVServer_EXTERNAL_OBJECTS =
+
+KVServer: CMakeFiles/KVServer.dir/KVServer.cpp.o
+KVServer: CMakeFiles/KVServer.dir/build.make
+KVServer: CMakeFiles/KVServer.dir/link.txt
+	@$(CMAKE_COMMAND) -E cmake_echo_color --switch=$(COLOR) --green --bold --progress-dir="/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/CMakeFiles" --progress-num=$(CMAKE_PROGRESS_2) "Linking CXX executable KVServer"
+	$(CMAKE_COMMAND) -E cmake_link_script CMakeFiles/KVServer.dir/link.txt --verbose=$(VERBOSE)
+
+# Rule to build all files generated by this target.
+CMakeFiles/KVServer.dir/build: KVServer
+
+.PHONY : CMakeFiles/KVServer.dir/build
+
+CMakeFiles/KVServer.dir/clean:
+	$(CMAKE_COMMAND) -P CMakeFiles/KVServer.dir/cmake_clean.cmake
+.PHONY : CMakeFiles/KVServer.dir/clean
+
+CMakeFiles/KVServer.dir/depend:
+	cd "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug" && $(CMAKE_COMMAND) -E cmake_depends "Unix Makefiles" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/CMakeFiles/KVServer.dir/DependInfo.cmake" --color=$(COLOR)
+.PHONY : CMakeFiles/KVServer.dir/depend
+

cmake-build-debug/CMakeFiles/KVServer.dir/cmake_clean.cmake

+file(REMOVE_RECURSE
+  "CMakeFiles/KVServer.dir/KVServer.cpp.o"
+  "KVServer"
+  "KVServer.pdb"
+)
+
+# Per-language clean rules from dependency scanning.
+foreach(lang CXX)
+  include(CMakeFiles/KVServer.dir/cmake_clean_${lang}.cmake OPTIONAL)
+endforeach()

cmake-build-debug/CMakeFiles/KVServer.dir/depend.make

+# Empty dependencies file for KVServer.
+# This may be replaced when dependencies are built.

cmake-build-debug/CMakeFiles/KVServer.dir/flags.make

+# CMAKE generated file: DO NOT EDIT!
+# Generated by "Unix Makefiles" Generator, CMake Version 3.15
+
+# compile CXX with /usr/bin/c++
+CXX_FLAGS = -lcrypto -pthread -g  
+
+CXX_DEFINES = 
+
+CXX_INCLUDES = 
+

cmake-build-debug/CMakeFiles/KVServer.dir/link.txt

+/usr/bin/c++  -lcrypto -pthread -g   CMakeFiles/KVServer.dir/KVServer.cpp.o  -o KVServer -lcrypto 

cmake-build-debug/CMakeFiles/KVServer.dir/progress.make

+CMAKE_PROGRESS_1 = 3
+CMAKE_PROGRESS_2 = 4
+

cmake-build-debug/CMakeFiles/TargetDirectories.txt

+/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/CMakeFiles/rebuild_cache.dir
+/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/CMakeFiles/edit_cache.dir
+/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/CMakeFiles/KVServer.dir
+/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/CMakeFiles/KVClient.dir

cmake-build-debug/CMakeFiles/clion-environment.txt

+ToolSet: 1.0 (local)Options: 
+
+Options:
\ No newline at end of file

cmake-build-debug/CMakeFiles/clion-log.txt

+/home/apaar/Downloads/clion-2019.2.5/bin/cmake/linux/bin/cmake -DCMAKE_BUILD_TYPE=Debug -G "CodeBlocks - Unix Makefiles" "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT"
+-- The C compiler identification is GNU 7.4.0
+-- The CXX compiler identification is GNU 7.4.0
+-- Check for working C compiler: /usr/bin/cc
+-- Check for working C compiler: /usr/bin/cc -- works
+-- Detecting C compiler ABI info
+-- Detecting C compiler ABI info - done
+-- Detecting C compile features
+-- Detecting C compile features - done
+-- Check for working CXX compiler: /usr/bin/c++
+-- Check for working CXX compiler: /usr/bin/c++ -- works
+-- Detecting CXX compiler ABI info
+-- Detecting CXX compiler ABI info - done
+-- Detecting CXX compile features
+-- Detecting CXX compile features - done
+-- Configuring done
+-- Generating done
+-- Build files have been written to: /home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug

cmake-build-debug/CMakeFiles/cmake.check_cache

+# This file is generated by cmake for dependency checking of the CMakeCache.txt file

cmake-build-debug/CMakeFiles/progress.marks

+4

cmake-build-debug/cmake_install.cmake

+# Install script for directory: /home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT
+
+# Set the install prefix
+if(NOT DEFINED CMAKE_INSTALL_PREFIX)
+  set(CMAKE_INSTALL_PREFIX "/usr/local")
+endif()
+string(REGEX REPLACE "/$" "" CMAKE_INSTALL_PREFIX "${CMAKE_INSTALL_PREFIX}")
+
+# Set the install configuration name.
+if(NOT DEFINED CMAKE_INSTALL_CONFIG_NAME)
+  if(BUILD_TYPE)
+    string(REGEX REPLACE "^[^A-Za-z0-9_]+" ""
+           CMAKE_INSTALL_CONFIG_NAME "${BUILD_TYPE}")
+  else()
+    set(CMAKE_INSTALL_CONFIG_NAME "Debug")
+  endif()
+  message(STATUS "Install configuration: \"${CMAKE_INSTALL_CONFIG_NAME}\"")
+endif()
+
+# Set the component getting installed.
+if(NOT CMAKE_INSTALL_COMPONENT)
+  if(COMPONENT)
+    message(STATUS "Install component: \"${COMPONENT}\"")
+    set(CMAKE_INSTALL_COMPONENT "${COMPONENT}")
+  else()
+    set(CMAKE_INSTALL_COMPONENT)
+  endif()
+endif()
+
+# Install shared libraries without execute permission?
+if(NOT DEFINED CMAKE_INSTALL_SO_NO_EXE)
+  set(CMAKE_INSTALL_SO_NO_EXE "1")
+endif()
+
+# Is this installation the result of a crosscompile?
+if(NOT DEFINED CMAKE_CROSSCOMPILING)
+  set(CMAKE_CROSSCOMPILING "FALSE")
+endif()
+
+if(CMAKE_INSTALL_COMPONENT)
+  set(CMAKE_INSTALL_MANIFEST "install_manifest_${CMAKE_INSTALL_COMPONENT}.txt")
+else()
+  set(CMAKE_INSTALL_MANIFEST "install_manifest.txt")
+endif()
+
+string(REPLACE ";" "\n" CMAKE_INSTALL_MANIFEST_CONTENT
+       "${CMAKE_INSTALL_MANIFEST_FILES}")
+file(WRITE "/home/apaar/Desktop/mtech-1sem/system/final project/Chord-DHT/cmake-build-debug/${CMAKE_INSTALL_MANIFEST}"
+     "${CMAKE_INSTALL_MANIFEST_CONTENT}")