From 7d28c089b45d465b18df1c5cda72abed3748118f Mon Sep 17 00:00:00 2001 From: Thorsten Töpper Date: Mon, 10 Jan 2011 20:02:33 +0100 Subject: Aufgabe 2: main.c, log.c und conv.c ausgebaut. MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * main.c: Öffnen der Pipes * conv.c: Pseudozufallszahlen, schreiben in die Pipes zum log und statistic Prozess * log.c: log() implementiert --- aufgabe2/conv.c | 33 +++++++++++++++++++++++++++++++-- 1 file changed, 31 insertions(+), 2 deletions(-) (limited to 'aufgabe2/conv.c') diff --git a/aufgabe2/conv.c b/aufgabe2/conv.c index efa8200..a28f120 100644 --- a/aufgabe2/conv.c +++ b/aufgabe2/conv.c @@ -1,18 +1,47 @@ /* * vim:ts=4:sw=4:expandtab - * + * */ #include #include #include +#include + +#include "queue.h" + +FILE *pipe_log; +FILE *pipe_stat; void conv() { - printf("conv started\n"); + int random_number = 0; + + /* Die beiden Pipes zum schreiben öffnen */ + if (((pipe_log = fdopen(queue[D_CONV_TO_LOG][WRITE], "w")) == NULL) || + ((pipe_stat = fdopen(queue[D_CONV_TO_STAT][WRITE], "w")) == NULL)) { + perror("conv.c fdopen()"); + exit(EXIT_FAILURE); + } + for (;;) { + /* Generierung der Zufallszahl, um Fehler im + * statistic Prozess zu vermeiden mit geringerem + * Wertebereich [0, SHRT_MAX] (quasi als short). + */ + random_number = rand()%SHRT_MAX; + + /* Nachricht sowohl in die Queue zum log Prozess als auch + * in die Queue zum statistic Prozess schreiben. + */ + fprintf(pipe_log, "%x\n", random_number); + fprintf(pipe_stat, "%x\n", random_number); } } void conv_cleanup() { printf("conv cleanup\n"); + fclose(pipe_log); + fclose(pipe_stat); + close(queue[D_CONV_TO_LOG][WRITE]); + close(queue[D_CONV_TO_STAT][WRITE]); _exit(EXIT_SUCCESS); } -- cgit v1.2.3-70-g09d2