From 29bd6b354d00d89623be64a95a51f5f0ac48b94a Mon Sep 17 00:00:00 2001
From: Matt Strapp <strap012@umn.edu>
Date: Thu, 29 Oct 2020 10:28:31 -0500
Subject: Make two different queues

---
 P2/lib/utils.c | 26 ++++++++------------------
 1 file changed, 8 insertions(+), 18 deletions(-)

(limited to 'P2/lib/utils.c')

diff --git a/P2/lib/utils.c b/P2/lib/utils.c
index 56bd3cc..a565717 100644
--- a/P2/lib/utils.c
+++ b/P2/lib/utils.c
@@ -1,20 +1,10 @@
 #include "utils.h"
 
-int openQueue() {
-	int id = msgget(ftok("4061 Project 2 SS", 'S'), 0666 | IPC_CREAT);
-	if (id < 0) {
-		perror("Cannot open queue.\n");
-		return -1;
-	}
-	return id;
+int openQueue(char* path) {
+	return msgget(ftok(path, 253), 0666 | IPC_CREAT);
 }
-void closeQueue() {
-	int msgid = msgget(ftok("4061 Project 2 SS", 'S'), 0666);
-	if (msgid < 0) {
-		perror("Cannot open queue. It may already exist.\n");
-		exit(-1);
-	}
-	msgctl(msgid, IPC_RMID, NULL);
+int closeQueue(int id) {
+	return msgctl(id, IPC_RMID, NULL);
 }
 
 char *getChunkData(int mapperID) {
@@ -22,7 +12,7 @@ char *getChunkData(int mapperID) {
 	//Message
 	struct msgBuffer message;
 	//Queue ID
-	int mid = openQueue();
+	int mid = openQueue("map");
 	msgrcv(mid, &message, sizeof(message.msgText), mapperID, 0);
 	if (strncmp("END", message.msgText, 3)) {
 		return NULL;
@@ -36,7 +26,7 @@ void sendChunkData(char *inputFile, int nMappers) {
 	printf("SENDING CHUNK DATA\n");
 	struct msgBuffer message;
 	// open message queue
-	int msgid = openQueue();
+	int msgid = openQueue("map");
 	int map = 1;
 	// message.msgText = 1;
 	int fd = open(inputFile, O_RDONLY);
@@ -88,7 +78,7 @@ int hashFunction(char* Qkey, int reducers){
 int getInterData(char *Qkey, int reducerID) {
 	struct msgBuffer message;
 	//make sure it work.
-	int id = openQueue();
+	int id = openQueue("reduce");
 	msgrcv(id, &message, chunkSize, reducerID, 0);
 	Qkey = message.msgText;
 	return strncmp("END", message.msgText, 3);
@@ -103,7 +93,7 @@ int getInterData(char *Qkey, int reducerID) {
 void shuffle(int nMappers, int nReducers) {
 	struct msgBuffer message;
 	//Once again, MAKE SURE THIS WORKS PROPERLY!
-	int id = openQueue();
+	int id = openQueue("reduce");
 	for (int i = 1; i <= nMappers; i++) {
 		//Extra for loop traversing directory
 		//TODO: Actually traverse directory
-- 
cgit v1.2.3