X-Git-Url: https://git.dlugolecki.net.pl/?a=blobdiff_plain;f=src%2Fprocess3.c;h=1357c91b5ab5bedd439948ac3a8c9780abe128e6;hb=2a3a69b2ecc61d45586cb8f15435255d998573ac;hp=6453a8fe2bbac70f8cf1b41e1d947aacdf198d00;hpb=36fddb02ae4b75d5671cb859be2706e640311737;p=wsti_so.git diff --git a/src/process3.c b/src/process3.c index 6453a8f..1357c91 100644 --- a/src/process3.c +++ b/src/process3.c @@ -35,7 +35,8 @@ key_t shmkey = 18912; int shmid; /** - * Message shared by processes. Contains array of process IDs + * Structure holding array of process IDs. + * Message is shared by processes. Contains array of process IDs */ struct message { pid_t pids[3]; @@ -44,11 +45,24 @@ struct message { struct message * processes = NULL; /** - * Message queue variables + * Message Queue variables + */ + +/** + * Unique key of message queue. */ key_t qkey = 12356; + +/** + * Queue descriptor. + */ int qid; +/** + * Structure holding queue message data. + * Parameter mtype describes process to whom message is sent. + * Parameter signo is a signal to raise after getting message. + */ struct queue_message { long mtype; int signo[1]; @@ -98,7 +112,10 @@ void sig_handler(int signo) } else if (signo == SIGTSTP) { fprintf(stderr, "[%s] > Signalling other processes..\n", "process3"); + processes->pids[2] = 0; notify_other_processes(signo); +// sleep(1); + processes->pids[2] = getpid(); fprintf(stderr, "[%s] > Closing pipe\n", "process3"); close(read_descriptor); @@ -106,7 +123,10 @@ void sig_handler(int signo) } else if (signo == SIGCONT) { fprintf(stderr, "[%s] > Signalling other processes..\n", "process3"); + processes->pids[2] = 0; notify_other_processes(signo); +// sleep(1); + processes->pids[2] = getpid(); fprintf(stderr, "[%s] > Opening pipe\n", "process3"); read_descriptor = open(read_pipe, O_RDONLY);