aboutsummaryrefslogtreecommitdiffstats
path: root/P1
diff options
context:
space:
mode:
authorMatt Strapp <strap012@umn.edu>2020-09-24 13:29:01 -0500
committerMatt Strapp <strap012@umn.edu>2020-09-24 13:29:01 -0500
commitee8e300b7d5dd481533aabe30d3e07a2c8647d95 (patch)
tree877bd369fd48bb2e86da96c323e06cb87d5aaef0 /P1
parentChange perms, add VScode thing (diff)
downloadcsci4061-ee8e300b7d5dd481533aabe30d3e07a2c8647d95.tar
csci4061-ee8e300b7d5dd481533aabe30d3e07a2c8647d95.tar.gz
csci4061-ee8e300b7d5dd481533aabe30d3e07a2c8647d95.tar.bz2
csci4061-ee8e300b7d5dd481533aabe30d3e07a2c8647d95.tar.lz
csci4061-ee8e300b7d5dd481533aabe30d3e07a2c8647d95.tar.xz
csci4061-ee8e300b7d5dd481533aabe30d3e07a2c8647d95.tar.zst
csci4061-ee8e300b7d5dd481533aabe30d3e07a2c8647d95.zip
Start Master
Diffstat (limited to '')
-rw-r--r--P1/src/mapreduce.c30
1 files changed, 24 insertions, 6 deletions
diff --git a/P1/src/mapreduce.c b/P1/src/mapreduce.c
index e879864..ed1f9e5 100644
--- a/P1/src/mapreduce.c
+++ b/P1/src/mapreduce.c
@@ -26,11 +26,19 @@ int main(int argc, char *argv[]) {
sleep(1);
- //TODO: spawn mappers processes and run 'mapper' executable using exec
-
+ pid_t mapperPid;
+ for (int i = 0; i < nMappers; i++) {
+ mapperPid = fork();
+ if (mapperPid != 0) {
+ //TODO: exec here
+ }
+ }
- // TODO: wait for all children to complete execution
-
+ for (int i = 0; i < nMappers; i++) {
+ //Hopefully this works
+ wait(NULL);
+ }
+
// ###### DO NOT REMOVE ######
// shuffle sends the word.txt files generated by mapper
@@ -43,9 +51,19 @@ int main(int argc, char *argv[]) {
sleep(1);
- // TODO: spawn reducer processes and run 'reducer' executable using exec
- //TODO: wait for all children to complete execution
+ pid_t reducerPid;
+ for (int i = 0; i < nReducers; i++) {
+ reducerPid = fork();
+ if (reducerPid != 0) {
+ //TODO: exec here
+ }
+ }
+
+ for (int i = 0; i < nReducers; i++) {
+ //Maybe this works too?
+ wait(NULL);
+ }
return 0;
} \ No newline at end of file