aboutsummaryrefslogtreecommitdiffstats
path: root/P1/Template/src/mapreduce.c
diff options
context:
space:
mode:
Diffstat (limited to 'P1/Template/src/mapreduce.c')
-rw-r--r--P1/Template/src/mapreduce.c54
1 files changed, 0 insertions, 54 deletions
diff --git a/P1/Template/src/mapreduce.c b/P1/Template/src/mapreduce.c
deleted file mode 100644
index 5b63f3f..0000000
--- a/P1/Template/src/mapreduce.c
+++ /dev/null
@@ -1,54 +0,0 @@
-#include "mapreduce.h"
-
-int main(int argc, char *argv[]) {
-
- if(argc < 4) {
- printf("Less number of arguments.\n");
- printf("./mapreduce #mappers #reducers inputFile\n");
- exit(0);
- }
-
- // ###### DO NOT REMOVE ######
- int nMappers = strtol(argv[1], NULL, 10);
- int nReducers = strtol(argv[2], NULL, 10);
- char *inputFile = argv[3];
-
- // ###### DO NOT REMOVE ######
- bookeepingCode();
-
- // ###### DO NOT REMOVE ######
- pid_t pid = fork();
- if(pid == 0){
- //send chunks of data to the mappers in RR fashion
- sendChunkData(inputFile, nMappers);
- exit(0);
- }
- sleep(1);
-
-
- // To do
- // spawn mappers processes and run 'mapper' executable using exec
-
- // To do
- // wait for all children to complete execution
-
-
- // ###### DO NOT REMOVE ######
- // shuffle sends the word.txt files generated by mapper
- // to reducer based on a hash function
- pid = fork();
- if(pid == 0){
- shuffle(nMappers, nReducers);
- exit(0);
- }
- sleep(1);
-
-
- // To do
- // spawn reducer processes and run 'reducer' executable using exec
-
- // To do
- // wait for all children to complete execution
-
- return 0;
-} \ No newline at end of file