X-Git-Url: https://git.dlugolecki.net.pl/?a=blobdiff_plain;ds=sidebyside;f=src%2Fprocess1.c;h=b28563f4102faf831cf12deecd2ff440eb3b0216;hb=f0a7f7a71896b25cc524598e5472c821f987a71c;hp=9fdee30b55edb5020a3eb2c05201fa24154f44ca;hpb=717e5b533ec94ef8f9a703bd4f019a2f45e138df;p=wsti_so.git diff --git a/src/process1.c b/src/process1.c index 9fdee30..b28563f 100644 --- a/src/process1.c +++ b/src/process1.c @@ -8,6 +8,9 @@ /* Signals handling.. */ #include +#include + + /** If buffer is too small to hold entire string, it is incremented by this value */ #define BUFFER_STEP 16 @@ -20,6 +23,29 @@ char * write_pipe = "/tmp/process1pipe"; /** File descriptor of pipe */ int file_descriptor; + +/** + * Shared memory variables + */ +/** + * Memory key for processes. Must be same between all processes to properly + * communicate. + */ +key_t shmkey = 18912; +/** + * Id of the shared memory + */ +int shmid; + +/** + * Message shared by processes. Contains array of process IDs + */ +struct message { + pid_t pids[3]; +}; + +struct message * processes = NULL; + /** * Handler for signals. */ @@ -29,6 +55,7 @@ void sig_handler(int signo) if (signo == SIGUSR1) { } else if (signo == SIGTERM) { + int i = 0; fprintf(stderr, "[%s] > Releasing resources\n", "process1"); close(write_pipe); unlink(write_pipe); @@ -37,6 +64,9 @@ void sig_handler(int signo) free(buffer); buffer = NULL; } + for (; i < 3; i++) { + fprintf(stderr, "[%s] Process %d, PID: %d\n", "process3", i, processes->pids[i]); + } exit(0); } else if (signo == SIGTSTP) { @@ -88,6 +118,15 @@ int main(void) { fprintf(stderr, "can't catch SIGCONT\n"); } + /* + * Register memory to share with other processes, and pass current + * process id to the array. + */ + shmid = shmget(shmkey, sizeof(struct message), IPC_CREAT | 0666); + + processes = (struct message *)shmat(shmid, NULL, 0); + processes->pids[0] = getpid(); + mkfifo(write_pipe, 0666); file_descriptor = open(write_pipe, O_WRONLY);