version 1.34.2.2, 2013/08/27 00:07:51
|
version 1.36.2.2, 2013/11/21 14:43:53
|
Line 62 SUCH DAMAGE.
|
Line 62 SUCH DAMAGE.
|
#include <net/bpf.h> |
#include <net/bpf.h> |
#include <netinet/in.h> |
#include <netinet/in.h> |
#include <elwix.h> |
#include <elwix.h> |
|
#include <aitsched.h> |
|
|
|
|
#ifndef STRSIZ |
#ifndef STRSIZ |
Line 71 SUCH DAMAGE.
|
Line 72 SUCH DAMAGE.
|
#define IO_SOCK_ROLE_CLIENT 0 |
#define IO_SOCK_ROLE_CLIENT 0 |
#define IO_SOCK_ROLE_SERVER 1 |
#define IO_SOCK_ROLE_SERVER 1 |
|
|
|
#define IO_ETHER_FILTER_PROMISC 0 |
|
#define IO_ETHER_FILTER_NOTREAD -1 |
|
#define IO_ETHER_FILTER_READ 1 |
|
#define IO_ETHER_FILTER_WRITE 2 |
|
|
|
|
typedef struct tagCliSock sock_cli_t; |
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; |
int sock_type; |
int sock_type; |
int sock_proto; |
int sock_proto; |
int sock_fd; |
int sock_fd; |
|
struct timespec sock_timeout; |
sockaddr_t sock_addr; |
sockaddr_t sock_addr; |
sockaddr_t sock_peer; |
sockaddr_t sock_peer; |
|
|
ait_val_t sock_buf; |
ait_val_t sock_buf; |
|
|
|
volatile intptr_t sock_kill; |
|
sched_root_task_t *sock_root; |
|
|
pthread_mutex_t sock_mtx; |
pthread_mutex_t sock_mtx; |
TAILQ_HEAD(, tagCliSock) sock_cli; |
TAILQ_HEAD(, tagCliSock) sock_cli; |
} sock_t; |
} sock_t; |
Line 136 void ioCloseSocket(sock_t ** __restrict s);
|
Line 145 void ioCloseSocket(sock_t ** __restrict s);
|
* |
* |
* @s = Socket |
* @s = Socket |
* @arg = Server role = listen backlog queue and Client role = peer address |
* @arg = Server role = listen backlog queue and Client role = peer address |
|
* @timeout = Socket timeout in ms (default -1 infinit) |
* return: -1 error or 0 ok |
* return: -1 error or 0 ok |
*/ |
*/ |
int ioUpSocket(sock_t * __restrict s, void *arg); | 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 |
|
* |
|
* @s = Socket |
|
* @rcb = Read callback |
|
* return: -1 error or return result from scheduler |
|
*/ |
|
int ioLoopSocket(sock_t * __restrict s, sched_task_func_t rcb); |
|
/* |
* ioAcceptSocket() - Accept clients |
* ioAcceptSocket() - Accept clients |
* |
* |
* @s = Socket |
* @s = Socket |
Line 492 int io_etherOpen(const char *csIface, int flags, int w
|
Line 517 int io_etherOpen(const char *csIface, int flags, int w
|
* return: none |
* return: none |
*/ |
*/ |
void io_etherClose(int eth, void **zcbuf); |
void io_etherClose(int eth, void **zcbuf); |
|
|
|
/* |
|
* io_etherFilter() - BPF filter routine |
|
* |
|
* @eth = bpf handle |
|
* @io = filter direction |
|
* (IO_ETHER_FILTER_PROMISC|IO_ETHER_FILTER_NOTREAD|IO_ETHER_FILTER_READ|IO_ETHER_FILTER_WRITE) |
|
* @insn = BPF filter instruction array |
|
* @insnlen = Length of BPF filter instruction array |
|
* return: -1 error or 0 ok |
|
*/ |
|
int io_etherFilter(int eth, int io, struct bpf_insn * __restrict insn, size_t insnlen); |
|
|
/* |
/* |
* io_etherSend() - Send packet to bpf |
* io_etherSend() - Send packet to bpf |