libaitio/src/exec.c - diff

Return to exec.c CVS log

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

version 1.1.2.19, 2013/12/12 21:59:01	version 1.1.2.20, 2013/12/12 23:06:45
Line 384 io_progCheck(prog_t * __restrict prg, int re)	Line 384 io_progCheck(prog_t * __restrict prg, int re)
#else	#else
(p = pio_pgetpid((int) array(prg->prog_fds, i, intptr_t))))	(p = pio_pgetpid((int) array(prg->prog_fds, i, intptr_t))))
#endif	#endif
if (waitpid(p->pid, &p->stat, WNOHANG) > 0) {	if (waitpid(p->pid, &p->stat, WNOHANG)) {
clrbit(prg->prog_used, i);	clrbit(prg->prog_used, i);
#ifdef POPEN_STREAM	#ifdef POPEN_STREAM
e_pclose(array(prg->prog_fds, i, FILE*));	e_pclose(array(prg->prog_fds, i, FILE*));
Line 445 io_progAttach(prog_t * __restrict prg, int newOne)	Line 445 io_progAttach(prog_t * __restrict prg, int newOne)
}	}
pthread_mutex_unlock(&prg->prog_mtx);	pthread_mutex_unlock(&prg->prog_mtx);

/* not found free program */	/* execute new one program */
if (!f && (i = io_progOpen2(prg)) > 0) {	if (newOne) {
	if (f)
	io_progOpen(prg, 1);
	else if ((i = io_progOpen2(prg)) > -1)
	/* not found free program */
#ifdef POPEN_STREAM	#ifdef POPEN_STREAM
f = array(prg->prog_fds, i, FILE*);	f = array(prg->prog_fds, i, FILE*);
#else	#else
f = array(prg->prog_fds, i, intptr_t);	f = array(prg->prog_fds, i, intptr_t);
#endif	#endif
}	}

/* execute new one program */
if (newOne && f)
io_progOpen(prg, 1);

return f;	return f;
}	}