diff options
| author | Matt Strapp <strap012@umn.edu> | 2020-10-06 08:26:44 -0500 |
|---|---|---|
| committer | Matt Strapp <strap012@umn.edu> | 2020-10-06 08:26:44 -0500 |
| commit | e66e195e7c175c738d0f11ba6d42eb4273f33b94 (patch) | |
| tree | 311d24d47f7e905c7e04f2d3ad6a92569f09336c /P1 | |
| parent | Change error (diff) | |
| download | csci4061-e66e195e7c175c738d0f11ba6d42eb4273f33b94.tar csci4061-e66e195e7c175c738d0f11ba6d42eb4273f33b94.tar.gz csci4061-e66e195e7c175c738d0f11ba6d42eb4273f33b94.tar.bz2 csci4061-e66e195e7c175c738d0f11ba6d42eb4273f33b94.tar.lz csci4061-e66e195e7c175c738d0f11ba6d42eb4273f33b94.tar.xz csci4061-e66e195e7c175c738d0f11ba6d42eb4273f33b94.tar.zst csci4061-e66e195e7c175c738d0f11ba6d42eb4273f33b94.zip | |
Add another define
Increase buffer size
Diffstat (limited to 'P1')
| -rw-r--r-- | P1/include/utils.h | 3 | ||||
| -rw-r--r-- | P1/src/mapper.c | 2 | ||||
| -rw-r--r-- | P1/src/reducer.c | 2 |
3 files changed, 4 insertions, 3 deletions
diff --git a/P1/include/utils.h b/P1/include/utils.h index c88c447..8be5169 100644 --- a/P1/include/utils.h +++ b/P1/include/utils.h @@ -18,7 +18,8 @@ #define MSGSIZE 1100 #define ENDTYPE 1000 #define ACKTYPE 1100 -#define BUFFSIZE 1000 +#define BUFFSIZE 500 +#define DIRSIZE 150 struct msgBuffer { long msgType; diff --git a/P1/src/mapper.c b/P1/src/mapper.c index 3a197e0..b401607 100644 --- a/P1/src/mapper.c +++ b/P1/src/mapper.c @@ -119,7 +119,7 @@ void writeIntermediateDS() { } // Put words and their corresponding 1's in a file named [the word].txt - char filename[BUFFSIZE] = ""; + char filename[DIRSIZE] = ""; sprintf(filename, "%s/%s.txt", mapOutDir, tempNode -> key); FILE* fptr = fopen(filename, "w"); fprintf(fptr, "%s %s", tempNode -> key, ones); diff --git a/P1/src/reducer.c b/P1/src/reducer.c index f70c072..92914e2 100644 --- a/P1/src/reducer.c +++ b/P1/src/reducer.c @@ -75,7 +75,7 @@ void writeFinalDS(int reducerID){ while(tempNode != NULL) { // Shove word and number of occurances in a file named word.txt - char filename[BUFFSIZE] = ""; + char filename[DIRSIZE] = ""; sprintf(filename, "output/ReduceOut/Reduce_%d.txt", reducerID); FILE* fptr = fopen(filename, "a"); //append, not overwrite. fprintf(fptr, "%s %d\n", tempNode -> key, tempNode -> value); |