version 1.37, 2013/11/22 13:49:14
|
version 1.38.10.12, 2013/12/12 09:04:21
|
Line 115 typedef struct {
|
Line 115 typedef struct {
|
TAILQ_HEAD(, tagCliSock) sock_cli; |
TAILQ_HEAD(, tagCliSock) sock_cli; |
} sock_t; |
} 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; |
|
unsigned int *prog_used; |
|
} prog_t; |
|
|
|
|
// io_GetErrno() Get error code of last operation |
// io_GetErrno() Get error code of last operation |
int io_GetErrno(); |
int io_GetErrno(); |
// io_GetError() Get error text of last operation |
// io_GetError() Get error text of last operation |
Line 123 const char *io_GetError();
|
Line 134 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_progGrow() - Execute to number of programs in pool |
|
* |
|
* @prg = program pool |
|
* @toNum = execute to number of programs (0 max) |
|
* return: 0 error or nothing to do, |
|
* >0 executed programs and abs(<0) executed programs with logged error |
|
*/ |
|
int io_progGrow(prog_t * __restrict prg, unsigned int toNum); |
|
/* |
|
* 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, unsigned int toNum); |
|
/* |
|
* io_progCloseAt() - Close program at pool of certain position |
|
* |
|
* @prg = program pool |
|
* @idx = index at pool |
|
* return: 0 error or !=0 closed program |
|
*/ |
|
int io_progCloseAt(prog_t * __restrict prg, unsigned int idx); |
|
/* |
|
* 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); |
|
|
|
/* |
|
* io_progCheck() - Check exit status of program pool |
|
* |
|
* @prg = program pool |
|
* @re = resurrect program |
|
* return: -1 error or >-1 exited programs |
|
*/ |
|
int io_progCheck(prog_t * __restrict prg, int re); |
|
|
|
/* |
|
* io_progAttach() - Attach to open program |
|
* |
|
* @prg = program pool |
|
* @newOne = Execute new one program after attach |
|
* return: NULL error or !=NULL attached program handle |
|
*/ |
|
#ifdef POPEN_STREAM |
|
FILE *io_progAttach(prog_t * __restrict prg, int newOne); |
|
#else |
|
int io_progAttach(prog_t * __restrict prg, int newOne); |
|
#endif |
|
/* |
|
* io_progDetach() - Detch from open program |
|
* |
|
* @prg= program pool |
|
* @pfd = attached program handle |
|
* return: none |
|
*/ |
|
#ifdef POPEN_STREAM |
|
void io_progDetach(prog_t * __restrict prg, FILE *pfd); |
|
#else |
|
void io_progDetach(prog_t * __restrict prg, int pfd); |
|
#endif |
|
|
|
|
|
/* |
* ioInitSocket() - Init socket and allocate resources |
* ioInitSocket() - Init socket and allocate resources |
* |
* |
* @role = Socket role |
* @role = Socket role |
Line 163 int ioUpSocket(sock_t * __restrict s, void *arg, int t
|
Line 268 int ioUpSocket(sock_t * __restrict s, void *arg, int t
|
* ioUpdTimerSocket() - Update timeout of socket |
* ioUpdTimerSocket() - Update timeout of socket |
* |
* |
* @c = Client socket |
* @c = Client socket |
* @arg = Optional data argument |
|
* return: none |
* return: none |
*/ |
*/ |
void ioUpdTimerSocket(sock_cli_t * __restrict c, void *arg); | void ioUpdTimerSocket(sock_cli_t * __restrict c); |
/* |
/* |
* ioLoopSocket() - Start socket scheduler |
* ioLoopSocket() - Start socket scheduler |
* |
* |
Line 184 int ioLoopSocket(sock_t * __restrict s, sched_task_fun
|
Line 288 int ioLoopSocket(sock_t * __restrict s, sched_task_fun
|
*/ |
*/ |
int ioBridgeProg2Socket(sock_t * __restrict s, const char *prgname); |
int ioBridgeProg2Socket(sock_t * __restrict s, const char *prgname); |
|
|
|
|
/* |
/* |
* ioPromptRead() - Read data from input h[0] with prompt to output h[1] |
* ioPromptRead() - Read data from input h[0] with prompt to output h[1] |
* |
* |
Line 508 int io_dumbFile(const char *csFile, int mode, off_t si
|
Line 613 int io_dumbFile(const char *csFile, int mode, off_t si
|
* return: -1 error or 0 ok |
* return: -1 error or 0 ok |
*/ |
*/ |
int io_get1stiface(char *szIface, int iflen); |
int io_get1stiface(char *szIface, int iflen); |
|
/* |
|
* io_getmaciface() - Get MAC address from interface name |
|
* |
|
* @csIface = interface name |
|
* @ea = ethernet address |
|
* return: -1 error, 0 ok or 1 not found |
|
*/ |
|
int io_getmaciface(const char *csIface, ether_addr_t * __restrict ea); |
/* |
/* |
* io_etherOpen() - Open BPF interface to device |
* io_etherOpen() - Open BPF interface to device |
* |
* |