--- libaitio/inc/aitio.h 2013/12/04 10:08:40 1.38.10.1 +++ libaitio/inc/aitio.h 2013/12/05 12:43:03 1.38.10.2 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitio.h,v 1.38.10.1 2013/12/04 10:08:40 misho Exp $ +* $Id: aitio.h,v 1.38.10.2 2013/12/05 12:43:03 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -115,7 +115,17 @@ typedef struct { TAILQ_HEAD(, tagCliSock) sock_cli; } sock_t; +typedef struct { + unsigned int prog_inin; /* init progs */ + unsigned int prog_maxn; /* max progs */ + unsigned int prog_cnum; /* current progs */ + char prog_name[PATH_MAX]; + pthread_mutex_t prog_mtx; + array_t *prog_fds; +} prog_t; + + // io_GetErrno() Get error code of last operation int io_GetErrno(); // io_GetError() Get error text of last operation @@ -123,6 +133,49 @@ const char *io_GetError(); /* + * io_progInit() - Init program pool + * + * @progName = program name for execution + * @initNum = initial started programs + * @maxNum = maximum started programs + * return: NULL error or !=NULL allocated pool (must destroied with io_progDestroy()) + */ +prog_t *io_progInit(const char *progName, + unsigned int initNum, unsigned int maxNum); +/* + * io_progOpen() - Execute number of program(s) + * + * @prg = program pool + * @execNum = execute program(s) (0 max) + * return: 0 error, >0 executed programs and abs(<0) executed programs with logged error + */ +int io_progOpen(prog_t * __restrict prg, unsigned int execNum); +/* + * io_progVacuum() - Vacuum pool to running number of programs + * + * @prg = program pool + * @toNum = vacuum to number of programs (0 to init number) + * return: 0 error or >0 closed programs + */ +int io_progVacuum(prog_t * __restrict prg, u_int toNum); +/* + * io_progClose() - Close all programs in pool + * + * @prg = program pool + * @closeNum = close program(s) (0 all) + * return: 0 error, >0 closed programs + */ +int io_progClose(prog_t * __restrict prg, unsigned int closeNum); +/* + * io_progDestroy() - Destroy entire program pool + * + * @pprg = program pool + * return: none + */ +void io_progDestroy(prog_t ** __restrict pprg); + + +/* * ioInitSocket() - Init socket and allocate resources * * @role = Socket role @@ -182,6 +235,7 @@ int ioLoopSocket(sock_t * __restrict s, sched_task_fun * return: 0 ok or !=0 error */ int ioBridgeProg2Socket(sock_t * __restrict s, const char *prgname); + /* * ioPromptRead() - Read data from input h[0] with prompt to output h[1]