diff options
| -rw-r--r-- | P2/lib/utils.c | 4 | ||||
| -rw-r--r-- | P2/src/mapreduce.c | 3 |
2 files changed, 3 insertions, 4 deletions
diff --git a/P2/lib/utils.c b/P2/lib/utils.c index 5c2a738..9a12ff0 100644 --- a/P2/lib/utils.c +++ b/P2/lib/utils.c @@ -23,13 +23,13 @@ char *getChunkData(int mapperID) { int mid = openQueue("map"); // printf("%d\n", mapperID); msgrcv(mid, &message, MSGSIZE, mapperID, 0); - printf("\n%s\n", message.msgText); + // printf("\n%s\n", message.msgText); // printf("%d\n", strncmp("END", message.msgText, 3)); if (strncmp("END", message.msgText, 3) == 0) return NULL; char* value = message.msgText; // printf("%s\n", message.msgText); - printf("%s\n", value); + // printf("%s\n", value); return value; //return &(message.msgText); } diff --git a/P2/src/mapreduce.c b/P2/src/mapreduce.c index 7f5e8c4..d021bbd 100644 --- a/P2/src/mapreduce.c +++ b/P2/src/mapreduce.c @@ -77,7 +77,6 @@ int main(int argc, char *argv[]) { // wait for all children to complete execution while (wait(&status) > 0); - closeQueue(openQueue("map")); - closeQueue(openQueue("reduce")); + closeQueue(openQueue()); return 0; }
\ No newline at end of file |