aboutsummaryrefslogtreecommitdiffstats
path: root/P2
diff options
context:
space:
mode:
authorMatt Strapp <strap012@umn.edu>2020-10-28 17:54:38 -0500
committerMatt Strapp <strap012@umn.edu>2020-10-28 17:54:38 -0500
commite8ba6edc687cd4d198d93259f5889482723ac43b (patch)
tree32383b55bb4219273c8b4c10c1a9eef8d8aae958 /P2
parentAdd closequeue (diff)
downloadcsci4061-e8ba6edc687cd4d198d93259f5889482723ac43b.tar
csci4061-e8ba6edc687cd4d198d93259f5889482723ac43b.tar.gz
csci4061-e8ba6edc687cd4d198d93259f5889482723ac43b.tar.bz2
csci4061-e8ba6edc687cd4d198d93259f5889482723ac43b.tar.lz
csci4061-e8ba6edc687cd4d198d93259f5889482723ac43b.tar.xz
csci4061-e8ba6edc687cd4d198d93259f5889482723ac43b.tar.zst
csci4061-e8ba6edc687cd4d198d93259f5889482723ac43b.zip
Add a close function
Diffstat (limited to '')
-rw-r--r--P2/src/mapreduce.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/P2/src/mapreduce.c b/P2/src/mapreduce.c
index 962a9ca..7f87019 100644
--- a/P2/src/mapreduce.c
+++ b/P2/src/mapreduce.c
@@ -49,6 +49,7 @@ int main(int argc, char *argv[]) {
pid_t pid = fork();
if(pid == 0){
//send chunks of data to the mappers in RR fashion
+ printf("TEST\n");
sendChunkData(inputFile, nMappers);
exit(0);
}
@@ -77,5 +78,6 @@ int main(int argc, char *argv[]) {
// wait for all children to complete execution
while (wait(&status) > 0);
+ closeQueue();
return 0;
} \ No newline at end of file