diff options
| -rw-r--r-- | aufgabe3/Makefile | 2 | ||||
| -rw-r--r-- | aufgabe3/conv.c | 40 | ||||
| -rw-r--r-- | aufgabe3/queue.h | 7 |
3 files changed, 44 insertions, 5 deletions
diff --git a/aufgabe3/Makefile b/aufgabe3/Makefile index d08af51..c8a143b 100644 --- a/aufgabe3/Makefile +++ b/aufgabe3/Makefile @@ -4,7 +4,7 @@ all: gcc -Wall -c -o statistic.o statistic.c gcc -Wall -c -o monitor.o monitor.c gcc -Wall -c -o main.o main.c - gcc -o pk main.o conv.o log.o statistic.o monitor.o + gcc -o pk main.o conv.o log.o statistic.o monitor.o -lrt clean: rm -f *.o diff --git a/aufgabe3/conv.c b/aufgabe3/conv.c index 35b7d33..9ca90f8 100644 --- a/aufgabe3/conv.c +++ b/aufgabe3/conv.c @@ -5,20 +5,56 @@ #include <stdlib.h> #include <stdio.h> #include <unistd.h> +#include <string.h> #include "queue.h" void conv() { int random_number = 0; + mqd_t log; + mqd_t statistic; + size_t message_size = sizeof(int)*2+1; + char *msg_one, *msg_two; - sprintf(stderr, "conv() was started"); + /* + * Message Queues zur Kommunikation mit dem log + * und dem statstic Prozess öffnen. + */ + log = mq_open(MQ_TO_LOG, O_WRONLY); + statistic = mq_open(MQ_TO_STATISTIC, O_WRONLY); + if ((log == -1) || (statistic == -1)) { + perror("conv() mq_open"); + exit(EXIT_FAILURE); + } for (;;) { - rand(); + random_number = rand(); + + msg_one = calloc(1, message_size); + msg_two = calloc(1, message_size); + + /* Message im Hexadezimalformat generieren. */ + sprintf(msg_one, "%x", random_number); + sprintf(msg_two, "%x", random_number); + + printf("conv:\t%s\t\t%s\n", msg_one, msg_two); +// fgetc(stdin); + + /* Message sowohl in die Queue zum log Prozess als auch + * in die Queue zum statistic Prozess schreiben. + */ + if ((mq_send(log, msg_one, strlen(msg_one)+1, 0) == -1) || + mq_send(statistic, msg_two, strlen(msg_two)+1, 0) == -1){ + perror("conv() mq_send"); + exit(EXIT_FAILURE); + } + } } void conv_cleanup() { printf("conv cleanup\n"); + mq_unlink(MQ_TO_LOG); + mq_unlink(MQ_TO_STATISTIC); _exit(EXIT_SUCCESS); } diff --git a/aufgabe3/queue.h b/aufgabe3/queue.h index 67a6110..01aaa9a 100644 --- a/aufgabe3/queue.h +++ b/aufgabe3/queue.h @@ -1,13 +1,16 @@ #ifndef _QUEUE_H #define _QUEUE_H +#include <errno.h> #include <sys/stat.h> #include <mqueue.h> /* - * Definition des Namens der verwendeten Message Queue. + * Definition der Namen der verwendeten Message Queues. * Erspart bei einer Änderung das editieren an mehreren * Stellen im Sourcecode. */ -#define MQ_NAME "/mq_bts_pk" +#define MQ_TO_LOG "/mq_bts_pk_log" +#define MQ_TO_STATISTIC "/mq_bts_pk_statistic" +#define MQ_TO_MONITOR "/mq_bts_pk_monitor" #endif |