version 1.36.2.1, 2013/11/21 12:54:21
|
version 1.36.2.2, 2013/11/21 14:43:53
|
Line 82 typedef struct tagCliSock sock_cli_t;
|
Line 82 typedef struct tagCliSock sock_cli_t;
|
typedef void *(*sock_cb_t)(sock_cli_t*); |
typedef void *(*sock_cb_t)(sock_cli_t*); |
struct tagCliSock { |
struct tagCliSock { |
void *cli_parent; |
void *cli_parent; |
pthread_t cli_tid; |
|
int cli_fd; |
int cli_fd; |
int cli_pty; |
int cli_pty; |
sockaddr_t cli_addr; |
sockaddr_t cli_addr; |
char cli_name[64]; |
char cli_name[64]; |
|
|
sock_cb_t cli_func; | sched_task_func_t cli_func; |
void *cli_arg; | |
|
|
ait_val_t cli_buf; |
ait_val_t cli_buf; |
|
|
TAILQ_ENTRY(tagCliSock) cli_node; |
TAILQ_ENTRY(tagCliSock) cli_node; |
}; |
}; |
|
|
typedef struct { |
typedef struct { |
int sock_role; |
int sock_role; |
int sock_backq; |
int sock_backq; |
Line 151 void ioCloseSocket(sock_t ** __restrict s);
|
Line 150 void ioCloseSocket(sock_t ** __restrict s);
|
*/ |
*/ |
int ioUpSocket(sock_t * __restrict s, void *arg, int timeout); |
int ioUpSocket(sock_t * __restrict s, void *arg, int timeout); |
/* |
/* |
|
* ioUpdTimerSocket() - Update timeout of socket |
|
* |
|
* @c = Client socket |
|
* return: none |
|
*/ |
|
void ioUpdTimerSocket(sock_cli_t * __restrict c); |
|
/* |
* ioLoopSocket() - Start socket scheduler |
* ioLoopSocket() - Start socket scheduler |
* |
* |
* @s = Socket |
* @s = Socket |
|
* @rcb = Read callback |
* return: -1 error or return result from scheduler |
* return: -1 error or return result from scheduler |
*/ |
*/ |
int ioLoopSocket(sock_t * __restrict s); | int ioLoopSocket(sock_t * __restrict s, sched_task_func_t rcb); |
/* |
/* |
* ioAcceptSocket() - Accept clients |
* ioAcceptSocket() - Accept clients |
* |
* |