libaitio/src/exec.c - diff

Return to exec.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitio / src

version 1.1.2.14, 2013/12/08 20:43:22	version 1.1.2.15, 2013/12/08 20:57:32
Line 217 io_progOpen(prog_t * __restrict prg, u_int execNum)	Line 217 io_progOpen(prog_t * __restrict prg, u_int execNum)
break;	break;
} else	} else
array_Set(prg->prog_fds, i, f);	array_Set(prg->prog_fds, i, f);
	clrbit(prg->prog_used, i);
prg->prog_cnum++;	prg->prog_cnum++;
ret++;	ret++;
}	}
Line 301 io_progVacuum(prog_t * __restrict prg, u_int toNum)	Line 302 io_progVacuum(prog_t * __restrict prg, u_int toNum)
* io_progCheck() - Check exit status of program pool	* io_progCheck() - Check exit status of program pool
*	*
* @prg = program pool	* @prg = program pool
	* @re = resurrect program
* return: -1 error or >-1 exited programs	* return: -1 error or >-1 exited programs
*/	*/
int	int
io_progCheck(prog_t * __restrict prg)	io_progCheck(prog_t * __restrict prg, int re)
{	{
int ret = 0;	int ret = 0;
struct tagPIOPID *p;	struct tagPIOPID *p;
Line 323 io_progCheck(prog_t * __restrict prg)	Line 325 io_progCheck(prog_t * __restrict prg)
#endif	#endif
if (waitpid(p->pid, &p->stat, WNOHANG) > 0) {	if (waitpid(p->pid, &p->stat, WNOHANG) > 0) {
clrbit(prg->prog_used, i);	clrbit(prg->prog_used, i);
	#ifdef POPEN_STREAM
	e_pclose(array(prg->prog_fds, i, FILE*));
	#else
	e_pclose((int) array(prg->prog_fds, i, intptr_t));
	#endif
	array_Del(prg->prog_fds, i, 0);
	prg->prog_cnum--;
ret++;	ret++;
}	}
pthread_mutex_unlock(&prg->prog_mtx);	pthread_mutex_unlock(&prg->prog_mtx);

	/* resurrect */
	if (re && ret > 0)
	io_progOpen(prg, ret);

return ret;	return ret;
}	}