ARP-assignment/src/L.c at main · andreabradpitto/ARP-assignment · GitHub

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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
// 2019 ARP assignment V2.0
// Andrea Pitto - S3942710
// 10 - 07 - 2020

// This process is the one responsible of logging. It registers every command issued by the user
// and every token processed by P (received/sent). When prompted, it opens the current log file
// via the user's preferred application

#include "def.h"

int main(int argc, char *argv[])
{
    close(atoi(argv[0]));
    close(atoi(argv[1]));
    close(atoi(argv[2]));
    close(atoi(argv[3]));
    close(atoi(argv[5]));

    pid_t Lpid = getpid();
    printf("L: my PID is %d\n", Lpid);
    pid_t Parpid = getppid(); // get process ID of parent (i.e. main)

    char *fancy_time;
    char *logpath = "log.txt"; // specify log file path
    setenv("log_file", logpath, 1);
    // Open the log file file in write mode (overwrite log file if already existing, create new one otherwise)
    FILE *log_file = fopen(logpath, "w+");
    long int time_var = 0;

    struct log_message log_msg;

    while (1)
    {
        // If main is dead, end the process
        if (getppid() != Parpid)
        {
            close(atoi(argv[4]));
            unsetenv("log_file");
            return 0;
        }

        // read() is a blocking function by default (i.e. when, like here, O_NONBLOCK is not set):
        // wait here until some data is available
        read(atoi(argv[4]), &log_msg, sizeof(struct log_message));

        switch (log_msg.status)
        {
        case 0: // logging acknowledgment of pause signal
            fancy_time = ctime(&log_msg.timestamp.tv_sec);
            fancy_time[strcspn(fancy_time, "\n")] = 0; // remove newline from ctime() output
            time_var = log_msg.timestamp.tv_sec * 1000000 + log_msg.timestamp.tv_usec;
            log_file = fopen(logpath, "a");
            fprintf(log_file, "%li %s %s %s\n", time_var, "|", fancy_time, "| from S | pause | undefined");
            fclose(log_file);
            break;
        case 1: // logging acknowledgment of resume/continue signal
            fancy_time = ctime(&log_msg.timestamp.tv_sec);
            fancy_time[strcspn(fancy_time, "\n")] = 0; // remove newline from ctime() output
            time_var = log_msg.timestamp.tv_sec * 1000000 + log_msg.timestamp.tv_usec;
            log_file = fopen(logpath, "a");
            fprintf(log_file, "%li %s %s %s\n", time_var, "|", fancy_time, "| from S | start | undefined");
            fclose(log_file);
            break;
        case 8: // logging acknowledgment of token value received by P
            fancy_time = ctime(&log_msg.timestamp.tv_sec);
            fancy_time[strcspn(fancy_time, "\n")] = 0; // remove newline from ctime() output
            time_var = log_msg.timestamp.tv_sec * 1000000 + log_msg.timestamp.tv_usec;
            log_file = fopen(logpath, "a");
            fprintf(log_file, "%li %s %s %s %9f\n", time_var, "|", fancy_time, "| from G | value |", log_msg.value);
            fclose(log_file);
            break;
        case 9: // logging acknowledgment of token value sent by P
            fancy_time = ctime(&log_msg.timestamp.tv_sec);
            fancy_time[strcspn(fancy_time, "\n")] = 0; // remove newline from ctime() output
            time_var = log_msg.timestamp.tv_sec * 1000000 + log_msg.timestamp.tv_usec;
            log_file = fopen(logpath, "a");
            fprintf(log_file, "%li %s %s %s %9f\n", time_var, "|", fancy_time, "| from P | value |", log_msg.value);
            fclose(log_file);
            break;
        case 3: // open log file request received
            fancy_time = ctime(&log_msg.timestamp.tv_sec);
            fancy_time[strcspn(fancy_time, "\n")] = 0; // remove newline from ctime() output
            time_var = log_msg.timestamp.tv_sec * 1000000 + log_msg.timestamp.tv_usec;
            log_file = fopen(logpath, "a");
            fprintf(log_file, "%li %s %s %s\n", time_var, "|", fancy_time, "| from S | logrq | undefined");
            fclose(log_file);
            int exit_status = system("xdg-open $log_file");
            break;
        }
    }
}