Administrace komentářů

static void sigchld_hdl(int sig)
{
	running_children--;
	printf("sigchld_hdl\n"); fflush(stdout);
	/* Wait for all dead processes.
	* We use a non-blocking call to be sure this signal handler will not
	* block if a child was cleaned up in another part of the program. */
	while (waitpid(-1, NULL, WNOHANG) > 0)
	{
	}
	if(running_children == 0) // toto je vlastne na upratanie po detoch, ked uz vsetky su skoncene
	{
		printf("--QUITING\n"); fflush(stdout);
		
		fclose(fp);

		if (msgctl(msqid, IPC_RMID, NULL) == -1)
			PANIC("msgctl");
		
		exit(EXIT_SUCCESS);
	}
}


potom v main()
	struct sigaction act;
 
	memset (&act, 0, sizeof(act));
	act.sa_handler = sigchld_hdl;
 
	if (sigaction(SIGCHLD, &act, 0)) {
		perror ("sigaction");
		return 1;
	}

	for(p = 0; p < n; p++)
	{
		pid[p] = fork();
		switch(pid[p])
		{
			case -1:
				/* fork error */
				PANIC("fork");
				break;

			case 0:
				child = true;
				break;

			default:
				child = false;
				running_children++;
				printf("adding child: %ld\n", running_children); fflush(stdout);
				break;
		}
		if(child) break;
	}

	if(child)
	{
		printf("(%d) cakam...\n", getpid()); fflush(stdout);
		msg_rcv(READY_TO_START);
		printf("(%d) child\n", getpid()); fflush(stdout);
		exit(EXIT_SUCCESS);
// 		sleep(1);
	}

	if(parent)
	{
		for(p = 0; p < n; p++)
		{
			printf("parent\n"); fflush(stdout);
			waitpid(pid[p], NULL, WNOHANG);//WNOHANG
			msg_snd(READY_TO_START, READY_TO_START_TRUE);
		}
		
		while (running_children>0) {
			sleep(1);
			printf("sleeping, running children: %ld\n", running_children); fflush(stdout);
		}
	}

$ ./philosophers 5
(26467) >> sending message(1): 1
(26467) >> sending message(2): 0
adding child: 1
(26468) cakam...
adding child: 2
(26469) cakam...
adding child: 3
(26470) cakam...
adding child: 4
(26471) cakam...
adding child: 5
parent
(26467) >> sending message(3): 0
parent
(26468) >> receiving message(3): 0
(26468) child
(26469) >> receiving message(3): 0
(26469) child
sigchld_hdl
(26467) >> sending message(3): 0
parent
(26467) >> sending message(3): 0
parent
(26470) >> receiving message(3): 0
(26470) child
(26471) >> receiving message(3): 0
(26471) child
(26472) cakam...
sigchld_hdl
(26467) >> sending message(3): 0
parent
(26467) >> sending message(3): 0
(26472) >> receiving message(3): 0
(26472) child
sigchld_hdl
sleeping, running children: 2
sleeping, running children: 2
sleeping, running children: 2
sleeping, running children: 2
sleeping, running children: 2
sleeping, running children: 2
sleeping, running children: 2
sleeping, running children: 2
sleeping, running children: 2
^C