Aufgabe 3: statistic implementiert, Wertebereich der Zufallszahlen verkleinert.

2 files changed, 80 insertions, 4 deletions

diff --git a/aufgabe3/conv.c b/aufgabe3/conv.c
index 6f4890c..28c5d91 100644
--- a/aufgabe3/conv.c
+++ b/aufgabe3/conv.c
@@ -6,6 +6,7 @@
 #include <stdio.h>
 #include <unistd.h>
 #include <string.h>
+#include <limits.h>
 
 #include "queue.h"
 
@@ -37,7 +38,11 @@ void conv() {
     }
 
     for (;;) {
-        random_number = rand();
+        /* Generierung der Zufallszahl, um Fehler im
+         * statistic Prozess zu vermeiden mit geringerem
+         * Wertebereich [0, SHRT_MAX] (quasi als short).
+         */
+        random_number = rand()%SHRT_MAX;
 
         /* Zufallszahl ins Hexadezimalformat konvertieren. */
         sprintf(message, "%x", random_number);
@@ -46,7 +51,7 @@ void conv() {
          * in die Queue zum statistic Prozess schreiben.
          */
         if ((mq_send(log, message, MQ_MSG_SIZE_SEND, 0) == -1) ||
-            mq_send(statistic, message, MQ_MSG_SIZE_SEND, 0) == -1){
+            mq_send(statistic, message, MQ_MSG_SIZE_SEND, 0) == -1) {
             perror("conv() mq_send");
             exit(EXIT_FAILURE);
         }
diff --git a/aufgabe3/statistic.c b/aufgabe3/statistic.c
index b83776a..ef4e1bc 100644
--- a/aufgabe3/statistic.c
+++ b/aufgabe3/statistic.c
@@ -1,18 +1,89 @@
 /*
  * vim:ts=4:sw=4:expandtab
- * 
+ *
  */
 #include <stdlib.h>
 #include <stdio.h>
 #include <unistd.h>
 
+#include "queue.h"
+
+#define VALUES_STORED 20
+
+char *message;
+
 void statistic() {
-    printf("statistic started\n");
+    int random_number = 0, values[VALUES_STORED];
+    int i = 0, mi=0; /* Indexe für das Array und die Mittelwertsberechnung */
+    int mittelwert = 0;
+    mqd_t statistic, monitor;
+
+    /*
+     * Message Queue zur Kommunikation mit dem conv Prozess öffnen.
+     */
+    if ((statistic = mq_open(MQ_TO_STATISTIC, O_RDONLY)) == -1) {
+        perror("statistic() mq_open(MQ_TO_STATISTIC)");
+        exit(EXIT_FAILURE);
+    }
+
+    /*
+     * Message Queue zur Kommunikation mit dem monitor Prozess öffnen.
+     */
+    if ((monitor = mq_open(MQ_TO_MONITOR, O_WRONLY)) == -1) {
+        perror("statistic() mq_open(MQ_TO_MONITOR)");
+        exit(EXIT_FAILURE);
+    }
+
+    /*
+     * Speicher für Nachricht allokieren.
+     */
+    if ((message = calloc(1, MQ_MSG_SIZE_RCV)) == NULL) {
+        perror("statistic()");
+        exit(EXIT_FAILURE);
+    }
+
     for (;;) {
+        /* Nachricht empfangen */
+        if (mq_receive(statistic, message, MQ_MSG_SIZE_RCV, NULL) == -1) {
+            perror("statistic() mq_receive");
+            exit(EXIT_FAILURE);
+        }
+
+        /* Zahl aus dem String zurück zur Dezimalzahl konvertieren */
+        sscanf(message, "%x", &random_number);
+
+        /*
+         * Berechnung des Mittelwertes der letzten VALUES_STORED Werten.
+         * Bis das Array erstmals gefüllt ist, wird
+         * der Wert nur näherungsweise berechnet.
+         */
+        values[i] = random_number;
+
+        /* Werte in mittelwert aufsummieren, unsichere Methode,
+         * Pufferüberlauf bei zu vielen Werten.
+         */
+        for (mi=0; mi<VALUES_STORED; mi++) {
+            mittelwert += values[mi];
+        }
+        mittelwert /= VALUES_STORED;
+
+        /* Berechneten Wert ins Hexadezimalformat konvertieren. */
+        sprintf(message, "%x", mittelwert);
+
+        /* Nachricht sowohl in die Queue zum monitor Prozess schreiben.
+         */
+        if ((mq_send(monitor, message, MQ_MSG_SIZE_SEND, 0)) == -1) {
+            perror("statistic() mq_send(MQ_TO_MONITOR)");
+            exit(EXIT_FAILURE);
+        }
+        i = (i+1)%VALUES_STORED;
     }
 }
 
 void statistic_cleanup() {
     printf("statistic cleanup\n");
+    free(message);
+    mq_unlink(MQ_TO_STATISTIC);
+    mq_unlink(MQ_TO_MONITOR);
     _exit(EXIT_SUCCESS);
 }