Nauka kolejek komunikatow

Maciej Andrearczyk · Maciej Andrearczyk · commit 1907551bb4c6 · 2013-12-22T01:45:24.000+01:00
diff --git a/Makefile b/Makefile
@@ -1,14 +1,15 @@
 CFLAGS=-Wall -std=c99
 S=serwer.c
 K=klient.c
+E=err.c
 
 all: serwer klient
 
-serwer: $(S)
-	gcc $(CFLAGS) $(S) -o serwer
+serwer: $(S) $(E)
+	gcc $(CFLAGS) $(S) $(E) -o serwer
 
-klient: $(K)
-	gcc $(CFLAGS) $(K) -o klient
+klient: $(K) $(E)
+	gcc $(CFLAGS) $(K) $(E) -o klient
 
 clean:
 	rm -f serwer klient
diff --git a/err.c b/err.c
@@ -0,0 +1,38 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <stdarg.h>
+#include <errno.h>
+#include <sys/types.h>
+#include <sys/wait.h>
+#include <string.h>
+#include "err.h"
+
+extern int sys_nerr;
+
+void syserr(const char *fmt, ...)  
+{
+  va_list fmt_args;
+
+  fprintf(stderr, "ERROR: ");
+
+  va_start(fmt_args, fmt);
+  vfprintf(stderr, fmt, fmt_args);
+  va_end (fmt_args);
+  fprintf(stderr," (%d; %s)\n", errno, strerror(errno));
+  exit(1);
+}
+
+void fatal(const char *fmt, ...)
+{
+  va_list fmt_args;
+
+  fprintf(stderr, "ERROR: ");
+
+  va_start(fmt_args, fmt);
+  vfprintf(stderr, fmt, fmt_args);
+  va_end (fmt_args);
+
+  fprintf(stderr,"\n");
+  exit(1);
+}
diff --git a/err.h b/err.h
@@ -0,0 +1,11 @@
+#ifndef _ERR_
+#define _ERR_
+
+/* wypisuje informacje o blednym zakonczeniu funkcji systemowej 
+i konczy dzialanie */
+extern void syserr(const char *fmt, ...);
+
+/* wypisuje informacje o bledzie i konczy dzialanie */
+extern void fatal(const char *fmt, ...);
+
+#endif
diff --git a/klient.c b/klient.c
@@ -1,6 +1,14 @@
 //Maciej Andrearczyk, 333856
 #include "stdio.h"
 #include "stdlib.h"
+#include "err.h"
+#include "mesg.h"
+#include <unistd.h>
+#include <string.h>
+#include <sys/types.h>
+#include <sys/ipc.h>
+#include <sys/msg.h>
+#include <sys/stat.h>
 
 /*
  * Rodzaj zasobu.
@@ -17,10 +25,41 @@ int n;
  */
 int s;
 
+/*
+ * Id kolejki to wysylania komunikatow.
+ */
+int snd_qid;
+
+/*
+ * Id kolejki to odbierania komunikatow.
+ */
+int rcv_qid;
+
+/*
+ * Wiadomość z żądaniem.
+ */ 
+Msg req;
+
 int main(int argc, char* argv[]) 
 {
 	k = atoi(argv[1]);
 	n = atoi(argv[2]);
 	s = atoi(argv[3]);
 
+	req.msg_type = 1L;
+
+	printf("MOJ PID %d\n", getpid());
+	sprintf(req.data, "%d %d %d", n, k, getpid());
+
+	if ( (snd_qid = msgget(CLI_TO_SER, 0)) == -1)
+		syserr("Error in msgget\n");
+	
+	if ( (rcv_qid = msgget(SER_TO_CLI, 0)) == -1)
+		syserr("Error in msgget\n");
+
+	if ( msgsnd(snd_qid, (char *) &req, strlen(req.data), 0) != 0 )
+		syserr("Error in msgsnd");
+
+	printf("KONIEC\n");
+	exit(0);
 }
diff --git a/mesg.h b/mesg.h
@@ -0,0 +1,9 @@
+#define MAX_DATA_SIZE 1000
+
+typedef struct {
+	long msg_type;
+	char data[MAX_DATA_SIZE];
+} Msg;
+
+#define CLI_TO_SER 100
+#define SER_TO_CLI 101
diff --git a/serwer.c b/serwer.c
@@ -1,6 +1,13 @@
 //Maciej Andrearczyk, 333856
 #include "stdio.h"
 #include "stdlib.h"
+#include "signal.h"
+#include "err.h"
+#include "mesg.h"
+#include <sys/types.h>
+#include <sys/ipc.h>
+#include <sys/msg.h>
+#include <sys/stat.h>
 
 /*
  * Ilość rodzajów zasobów.
@@ -12,9 +19,39 @@ int K;
  */
 int N;
 
+/*
+ *TODO
+ */
+int msg_qid;
+Msg msg;
+
+
+/*
+ * Metoda zwalniająca zasoby systemowe.
+ */
+void free_sysres()
+{
+	printf("\nZWALNIAM ZASOBY!\n");
+	if (msgctl(msg_qid, IPC_RMID, 0) == -1)
+		syserr("Error in msgctl\n");
+	exit(0);
+}
+
 int main(int argc, char* argv[])
 {
 	K = atoi(argv[1]);
 	N = atoi(argv[2]);
 
+	////
+	if ( (msg_qid = msgget(1234L, IPC_CREAT | IPC_EXCL)) == -1)
+		syserr("Error in msgget\n");
+	////
+	int size_rcv;
+	while((size_rcv = msgrcv(msg_qid, &msg, MAX_DATA_SIZE, 1L, 0))) {
+		printf("ALE %s\n", msg.data);
+		if  ( signal(SIGINT, free_sysres) == SIG_ERR)
+			syserr("Error in signal\n");
+	}
+
+	exit(0);
 }
