aboutsummaryrefslogtreecommitdiff
path: root/aufgabe2/log.c
blob: 14684cec6d125a99f53db28f046a6a4d25fe85a1 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
/*
 * vim:ts=4:sw=4:expandtab
 *
 */
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>

#include "queue.h"

FILE *pipe_conv;
FILE *logfile;
char *message;

void log() {
    printf("log started\n");

    /* Die Pipe zum lesen öffnen */
    if ((pipe_conv = fdopen(queue[D_CONV_TO_LOG][READ], "r")) == NULL) {
        perror("log.c fdopen()");
        exit(EXIT_FAILURE);
    }

    /* Logdatei öffnen */
    if ((logfile = fopen("logfile.txt", "w")) == NULL) {
        perror("log.c fopen()");
        exit(EXIT_FAILURE);
    }

    /* Speicher für Nachricht reservieren */
    if ((message = calloc(1, sizeof(char)*SIZE_HEX+1)) == NULL) {
        perror("log.c calloc()");
        exit(EXIT_FAILURE);
    }

    /* Nachricht aus der Pipe lesen, als Endian abhängiger
     * HEX-Wert in die Log Datei schreiben. Für portable
     * Rückkonvertierung ins Dezimalsystem siehe Aufgabe 3,
     * oder bei Aufgabe 2 in statistic.c und monitor.c
     */
    while (fgets(message, SIZE_HEX+1, pipe_conv)) {
        fputs(message, logfile);
    }
}

void log_cleanup() {
    printf("log cleanup\n");
    fclose(logfile);
    fclose(pipe_conv);
    free(message);
    close(queue[D_CONV_TO_LOG][READ]);
    _exit(EXIT_SUCCESS);
}