From 357bd974d197a12d66643fc1e896ab3d0a42263a Mon Sep 17 00:00:00 2001
From: Anurag Yadav <yanurag994@gmail.com>
Date: Fri, 1 Nov 2024 18:33:19 -0400
Subject: [PATCH] Enabled Distributed Helix Algorithm

---
 Pipes/basePipe.cpp     |  8 ++++----
 Utils/multifileops.cpp | 19 +++++++++++--------
 2 files changed, 15 insertions(+), 12 deletions(-)

diff --git a/Pipes/basePipe.cpp b/Pipes/basePipe.cpp
index b1fdc34..31b1d7f 100644
--- a/Pipes/basePipe.cpp
+++ b/Pipes/basePipe.cpp
@@ -92,10 +92,10 @@ basePipe<nodeType> *basePipe<nodeType>::newPipe(const std::string &pipeType, con
 	{
 		return new helixPipe<nodeType>();
 	}
-	// else if (pipeType == "helixDistPipe")
-	// {
-	// 	return new helixDistPipe<nodeType>();
-	// }
+	else if (pipeType == "helixDistPipe")
+	{
+		return new helixDistPipe<nodeType>();
+	}
 
 	return 0;
 }
diff --git a/Utils/multifileops.cpp b/Utils/multifileops.cpp
index 076a9c3..f025440 100644
--- a/Utils/multifileops.cpp
+++ b/Utils/multifileops.cpp
@@ -181,8 +181,8 @@ bool MultiFile<FileType, baseType>::readValue()
  * @return true
  * @return false
  */
-template <typename FileType, class baseType>
-bool MultiFile<FileType, baseType>::readUnique()
+template <>
+bool MultiFile<MapBinaryFile, std::pair<std::vector<short>,short>>::readUnique()
 {
     while (readValue())
     {
@@ -227,14 +227,14 @@ MultiFile<FileType, baseType>::MultiFile(const std::string &directory)
  * @param outputFileName
  * @param iterationCounter
  */
-template <typename FileType, class baseType>
-void MultiFile<FileType, baseType>::compressMap(const std::string &outputFileName, int iterationCounter)
+template <>
+void MultiFile<MapBinaryFile, std::pair<std::vector<short>, short>>::compressMap(const std::string &outputFileName, int iterationCounter)
 {
     // Open the output file for writing
     std::ofstream outputFile(outputFileName, std::ios::out | std::ios::binary);
 
     // Read from the previous iteration's data file
-    FileType previousReader("input/" + std::to_string(iterationCounter) + ".dat");
+    MapBinaryFile previousReader("input/" + std::to_string(iterationCounter) + ".dat");
 
     // Initialize variables for map size and vector size
     size_t mapSize = 0, vectorSize = previousReader.cache.first.size();
@@ -277,8 +277,8 @@ void MultiFile<FileType, baseType>::compressMap(const std::string &outputFileNam
  * @param outputFileName
  * @return size_t
  */
-template <typename FileType, class baseType>
-size_t MultiFile<FileType, baseType>::writeCSV(const std::string &outputFileName)
+template <>
+size_t MultiFile<VectorBinaryFile, std::vector<short>>::writeCSV(const std::string &outputFileName)
 {
     std::ofstream outputFile(outputFileName, std::ios::out);
     size_t size = 0;
@@ -296,4 +296,7 @@ size_t MultiFile<FileType, baseType>::writeCSV(const std::string &outputFileName
     }
     outputFile.close();
     return size;
-};
\ No newline at end of file
+};
+
+template class MultiFile<MapBinaryFile, std::pair<std::vector<short>, short>>;
+template class MultiFile<VectorBinaryFile, std::vector<short>>;
\ No newline at end of file