X-Git-Url: https://git.dlugolecki.net.pl/?a=blobdiff_plain;f=src%2Fprocess3.c;h=b1b997212be53430306b69232a3c88bd7d2f3b14;hb=f0a7f7a71896b25cc524598e5472c821f987a71c;hp=b75f903af10e363d5c96d07000fa22609322f025;hpb=621bd5704dfeeccf51097ba255010bd37054972c;p=wsti_so.git diff --git a/src/process3.c b/src/process3.c index b75f903..b1b9972 100644 --- a/src/process3.c +++ b/src/process3.c @@ -9,12 +9,38 @@ /* Signals handling.. */ #include +#include + /** Named pipe used to communicate with process2 */ char * read_pipe = "/tmp/process2pipe"; /** Descriptor of input pipe */ int read_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. */ @@ -24,13 +50,18 @@ void sig_handler(int signo) if (signo == SIGUSR1) { } else if (signo == SIGTERM) { + int i = 0; fprintf(stderr, "[%s] > Releasing resources\n", "process3"); close(read_descriptor); + for (; i < 3; i++) { + fprintf(stderr, "[%s] Process %d, PID: %d\n", "process3", i, processes->pids[i]); + } exit(0); } else if (signo == SIGTSTP) { fprintf(stderr, "[%s] > Closing pipe\n", "process3"); close(read_descriptor); + raise (SIGSTOP); } else if (signo == SIGCONT) { fprintf(stderr, "[%s] > Opening pipe\n", "process3"); @@ -67,6 +98,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[2] = getpid(); + /* Reading from process2 */ read_descriptor = open(read_pipe, O_RDONLY);