diff options
| author | Matt Strapp <strap012@umn.edu> | 2020-11-03 11:01:07 -0600 |
|---|---|---|
| committer | Matt Strapp <strap012@umn.edu> | 2020-11-03 11:01:07 -0600 |
| commit | b9fe3dbcb7b6829ed19abd631f1b725538d4822e (patch) | |
| tree | 00ed529589dc7608fd04832c95547d2535de267c /P2 | |
| parent | change queue seed (diff) | |
| download | csci4061-b9fe3dbcb7b6829ed19abd631f1b725538d4822e.tar csci4061-b9fe3dbcb7b6829ed19abd631f1b725538d4822e.tar.gz csci4061-b9fe3dbcb7b6829ed19abd631f1b725538d4822e.tar.bz2 csci4061-b9fe3dbcb7b6829ed19abd631f1b725538d4822e.tar.lz csci4061-b9fe3dbcb7b6829ed19abd631f1b725538d4822e.tar.xz csci4061-b9fe3dbcb7b6829ed19abd631f1b725538d4822e.tar.zst csci4061-b9fe3dbcb7b6829ed19abd631f1b725538d4822e.zip | |
fix made problem
Diffstat (limited to 'P2')
| -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 |