Dotaz: C - SIGUSR1 pomocí kill a sigaction

[BamBam]

Vytvářím program , který vytvoří dva procesy, které propojuji rourou. První potomek přesměruje svůj výstup do roury a bude do něj zapisovat dvojice náhodných čísel oddělené mezerou. Mezi zápisy čísel mám prodlevu 1 sekundu. Druhý potomek přesměruje výstup roury na svůj standardní vstup, přesměruje svůj výstup do souboru s názvem out.txt.

Chci udělat, aby rodičovský proces počkal 5 sekund a poté poslal signál SIGUSR1 prvnímu procesu (generátoru čísel) pomocí kill, což způsobí korektní ukončení obou procesů. Počká na ukončení procesů a poté se ukončí.

Ale nevím jakým způsobem v prvním procesu ošetřit signál SIGUSR1 pomocí sigaction, tak aby po přijmutí signálu, vypsal něco na svůj chybový výstup a ukončil se.

#define NAZEV "out.txt"

int main() { FILE *soubor; soubor = fopen(NAZEV, "a+");

int roura[2]; pipe(roura);

pid_t pid1; int retcode; pid1=fork(); if(pid1 == 0) // potomek1 { close(roura[0]); printf("Potomek1...\n"); dup2(roura[1], STDOUT_FILENO); // presmerovani výstupu do roury

int i = 0; while(i < 6) { i++; int a = rand(); int b = rand(); sleep(1); printf("%d %d\n", a, b); } close(roura[1]); exit(45);

} else if (pid1 < 0) { printf("Fork selhal\n"); exit(2); } else { pid_t pid2; pid2 = fork(); if (pid2 == 0) //potomek 2 { close(roura[1]);

/*presmerovani výstup roury na svůj standardní vstup */ dup2(roura[0], STDIN_FILENO);

printf("Potomek2...\n"); int i = 0; while(i < 5) { i++; int c; int d; scanf("%d %d", &c, &d); printf("%d %d\n", c, d); fprintf(soubor,"%d %d\n", c, d); }

printf("Potomek2 skoncil\n"); exit(0); } else if (pid2 < 0) { printf("Fork selhal\n"); exit(2); }else { sleep(5]; kill(pid1, SIGUSR1); wait(&pid1); //ceka na potomka1 wait(&pid2); //ceka na potomka2 printf("Rodic konci\n"); exit(0); } } exit(0); }

---

---

Odpovědi

[BamBam]

#define NAZEV "out.txt"

int main()
{
FILE *soubor;
soubor = fopen(NAZEV, "a+");
int roura[2];
pipe(roura);
pid_t pid1;
int retcode;
pid1=fork();
if(pid1 == 0) // potomek1
{
close(roura[0]);
printf("Potomek1...\n");
dup2(roura[1], STDOUT_FILENO); // presmerovani výstupu do roury
int i = 0;
while(i < 6)
{
i++;
int a = 2 + i;
int b = 4 + i;
sleep(1);
printf("%d %d\n", a, b);
}
close(roura[1]);
exit(45);
} else if (pid1 < 0)
{
printf("Fork selhal\n");
exit(2);
} else
{
pid_t pid2;
pid2 = fork();
if (pid2 == 0) //potomek 2
{
close(roura[1]);
dup2(roura[0], STDIN_FILENO); //presmerovani výstup roury na svůj standardní vstup
printf("Potomek2...\n");
int i = 0;
while(i < 5)
{
i++;
int c;
int d;
scanf("%d %d", &c, &d);
printf("%d %d\n", c, d);
fprintf(soubor,"%d %d\n", c, d);
}
printf("Potomek2 skoncil\n");
exit(0);
} else if (pid2 < 0)
{
printf("Fork selhal\n");
exit(2);
}else
{ wait(&pid1); //ceka na potomka1
wait(&pid2); //ceka na potomka2 
printf("Rodic konci\n");
exit(0);
}
}
exit(0);
}

[Sten]

Váš kód v sigaction někam poznamená, že přišel signál. Ten proces bude v tu dobu nejspíš viset na sleep, který příchozí signál přeruší s EINTR, ale nemusí, takže je vhodné to otestovat i před tím sleepem. Stačí se pak podívat, jestli byl poznamenán příchod signálu, a pokud ano, tak proces ukončit. Pokud nepotřebujete po přerušení uklidit, tak ukončit proces jde i ze sigaction pomocí _exit().

Mimochodem pokud potřebujete zastavit zapisující proces ze čtecího, stačí ve čtecím procesu tu rouru zavřít. Zapisovací proces pak při pokusu o zápis dostane SIGPIPE.