process.c

#include "headers.h"
#include <signal.h>
#include <stdlib.h>
#include <unistd.h>
#include "ipc.h"
#include <sys/msg.h>
/* Modify this file as needed*/

int stopped = 0;
FILE *errorFile;
void open_logs();
void close_logs();
void sigStopHandler(int signum)
{
    stopped = 1;
}
void logError(const char *errorMsg)
{
    open_logs();
    fprintf(errorFile, "At time %d: %s\n", getClk(), errorMsg);
    close_logs();
}
void open_logs()
{
    errorFile = fopen("error.log", "a");
}
void close_logs()
{
    fclose(errorFile);
}
void sigContHandler(int signum)
{
    stopped = 0;
}

int main(int agrc, char *argv[])
{
    initClk();
    // key_t key = ftok(IPC_FILE, KEY);
    // int mqid = msgget(key, 0666);
    // TODO it needs to get the remaining time from somewhere
    // remainingtime = ??;
    if (agrc < 2)
    {
        fprintf(stderr, "Usage: process.out <remaining>\n");
        return 1;
    }
    int remainingtime = atoi(argv[1]); // sent by scheduler
    // connect signal with its func
    signal(SIGUSR1, sigContHandler);
    signal(SIGUSR2, sigStopHandler);
    while (remainingtime > 0)
    {
        sleep(1); // simulate 1 second CPU time
        if (stopped)
            continue;    // if stopped, skip decreasing remaining time
        remainingtime--; // decrease remaining time
    }
    logError("Process completed execution");

    // TerminationMsg msg;
    // msg.mtype = MSG_PROCESS_FINISHED;
    // msg.pid = getpid();
    // // msg.processID = atoi(argv[2]);

    // msgsnd(mqid, &msg, sizeof(TerminationMsg) - sizeof(long), 0);

    destroyClk(false);

    return 0;
}