version 1.1.1.1, 2010/02/23 22:54:52
|
version 1.38.10.15, 2013/12/12 15:23:44
|
Line 1
|
Line 1
|
/************************************************************************* |
/************************************************************************* |
* (C) 2010 AITNET ltd - Sofia/Bulgaria - <misho@aitbg.com> | * (C) 2010 AITNET ltd - Sofia/Bulgaria - <misho@aitnet.org> |
* by Michael Pounov <misho@openbsd-bg.org> | * by Michael Pounov <misho@elwix.org> |
* |
* |
* $Author$ |
* $Author$ |
* $Id$ |
* $Id$ |
* |
* |
*************************************************************************/ | ************************************************************************** |
| The ELWIX and AITNET software is distributed under the following |
| terms: |
| |
| All of the documentation and software included in the ELWIX and AITNET |
| Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
| |
| Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012, 2013 |
| by Michael Pounov <misho@elwix.org>. All rights reserved. |
| |
| Redistribution and use in source and binary forms, with or without |
| modification, are permitted provided that the following conditions |
| are met: |
| 1. Redistributions of source code must retain the above copyright |
| notice, this list of conditions and the following disclaimer. |
| 2. Redistributions in binary form must reproduce the above copyright |
| notice, this list of conditions and the following disclaimer in the |
| documentation and/or other materials provided with the distribution. |
| 3. All advertising materials mentioning features or use of this software |
| must display the following acknowledgement: |
| This product includes software developed by Michael Pounov <misho@elwix.org> |
| ELWIX - Embedded LightWeight unIX and its contributors. |
| 4. Neither the name of AITNET nor the names of its contributors |
| may be used to endorse or promote products derived from this software |
| without specific prior written permission. |
| |
| THIS SOFTWARE IS PROVIDED BY AITNET AND CONTRIBUTORS ``AS IS'' AND |
| ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE |
| IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE |
| ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE |
| FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL |
| DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS |
| OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) |
| HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT |
| LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY |
| OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF |
| SUCH DAMAGE. |
| */ |
#ifndef __AITIO_H |
#ifndef __AITIO_H |
#define __AITIO_H |
#define __AITIO_H |
|
|
|
|
|
#define COMPAT_43TTY |
|
|
|
#include <assert.h> |
|
#include <syslog.h> |
|
#include <openssl/evp.h> |
|
#include <openssl/aes.h> |
|
#include <sys/tty.h> |
|
#include <sys/ioctl_compat.h> |
|
#include <sys/socket.h> |
|
#include <sys/un.h> |
|
#include <sys/uio.h> |
|
#include <net/if_dl.h> |
|
#include <net/bpf.h> |
|
#include <netinet/in.h> |
|
#include <elwix.h> |
|
#include <aitsched.h> |
|
|
|
|
|
#ifndef STRSIZ |
|
#define STRSIZ 256 |
|
#endif |
|
|
|
#define IO_SOCK_ROLE_CLIENT 0 |
|
#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 { |
|
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; |
|
|
|
typedef struct tagCliSock sock_cli_t; |
|
typedef void *(*sock_cb_t)(sock_cli_t*); |
|
struct tagCliSock { |
|
void *cli_parent; |
|
int cli_fd; |
|
int cli_pty; |
|
sockaddr_t cli_addr; |
|
char cli_name[64]; |
|
char cli_cmdline[PATH_MAX]; |
|
pid_t cli_pid; |
|
|
|
sched_task_func_t cli_func; |
|
|
|
ait_val_t cli_buf[2]; |
|
|
|
TAILQ_ENTRY(tagCliSock) cli_node; |
|
}; |
|
|
|
typedef struct { |
|
int sock_role; |
|
int sock_backq; |
|
int sock_type; |
|
int sock_proto; |
|
int sock_fd; |
|
struct timespec sock_timeout; |
|
sockaddr_t sock_addr; |
|
sockaddr_t sock_peer; |
|
|
|
ait_val_t sock_buf; |
|
prog_t *sock_prog; |
|
|
|
volatile intptr_t sock_kill; |
|
sched_root_task_t *sock_root; |
|
|
|
pthread_mutex_t sock_mtx; |
|
TAILQ_HEAD(, tagCliSock) sock_cli; |
|
} sock_t; |
|
|
|
|
// io_GetErrno() Get error code of last operation |
// io_GetErrno() Get error code of last operation |
inline int io_GetErrno(); | int io_GetErrno(); |
// io_GetError() Get error text of last operation |
// io_GetError() Get error text of last operation |
inline const char *io_GetError(); | const char *io_GetError(); |
|
|
|
|
/* |
/* |
* ioPromptRead() Read data from input h[0] with prompt to output h[1] | * 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 |
| * |
| * @role = Socket role |
| * @type = Socket type |
| * @proto = Socket protocol |
| * @addr = Bind to address |
| * @port = Bind to port |
| * @buflen = Socket buffer, optional if =0 == BUFSIZ |
| * return: NULL error or !=NULL created socket |
| */ |
| sock_t *ioInitSocket(int role, int type, int proto, |
| const char *addr, unsigned short port, size_t buflen); |
| /* |
| * ioCloseSocket() - Close socket and free resources |
| * |
| * @s = Socket |
| * return: none |
| */ |
| void ioCloseSocket(sock_t ** __restrict s); |
| #define ioKillSocket(x) (assert((x)), (x)->sock_kill = 1) |
| /* |
| * ioCloseClient() - Close client socket |
| * |
| * @c = Client socket |
| * return: 0 ok or !=0 error |
| */ |
| int ioCloseClient(sock_cli_t * __restrict c); |
| /* |
| * ioSetupProg2Socket() - Setup program pool to socket server |
| * |
| * @s = Socket |
| * @p = Program pool |
| * return: -1 error or 0 ok |
| */ |
| int ioSetupProg2Socket(sock_t * __restrict s, prog_t * __restrict p); |
| /* |
| * ioUpSocket() - Setup socket for use |
| * |
| * @s = Socket |
| * @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 |
| */ |
| 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); |
| /* |
| * ioBridgeProg2Socket() - Start socket scheduler and bridge program to socket |
| * |
| * @s = Socket |
| * @prgname = Program name |
| * 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] |
| * |
* @h = file handles h[0] = input, h[1] = output, if NULL use stdin, stdout |
* @h = file handles h[0] = input, h[1] = output, if NULL use stdin, stdout |
* @csPrompt = Prompt before input, may be NULL |
* @csPrompt = Prompt before input, may be NULL |
* @psData = Readed data |
* @psData = Readed data |
* @dataLen = Length of data |
* @dataLen = Length of data |
* return: 0 EOF; -1 error:: can`t read; >0 count of readed chars |
* return: 0 EOF; -1 error:: can`t read; >0 count of readed chars |
*/ |
*/ |
int ioPromptRead(int *h, const char *csPrompt, char * __restrict psData, int dataLen); | int ioPromptRead(int *h, const char *csPrompt, |
| char * __restrict psData, int dataLen); |
/* |
/* |
* ioPromptPassword() Read password from input h[0] with prompt to output h[1] | * ioPromptPassword() - Read password from input h[0] with prompt to output h[1] |
| * |
* @h = file handles h[0] = input, h[1] = output, if NULL use stdin, stdout |
* @h = file handles h[0] = input, h[1] = output, if NULL use stdin, stdout |
* @csPrompt = Prompt before input, may be NULL |
* @csPrompt = Prompt before input, may be NULL |
* @psPass = Readed password |
* @psPass = Readed password |
Line 34 int ioPromptRead(int *h, const char *csPrompt, char *
|
Line 319 int ioPromptRead(int *h, const char *csPrompt, char *
|
* @confirm = Confirm password, 0 - get password, !=0 Ask for confirmation |
* @confirm = Confirm password, 0 - get password, !=0 Ask for confirmation |
* return: 0 EOF; -1 error:: can`t read; >0 count of readed chars |
* return: 0 EOF; -1 error:: can`t read; >0 count of readed chars |
*/ |
*/ |
int ioPromptPassword(int *h, const char *csPrompt, char * __restrict psPass, int passLen, int confirm); | int ioPromptPassword(int *h, const char *csPrompt, |
| char * __restrict psPass, int passLen, int confirm); |
|
|
|
|
/* |
/* |
* ioRegexVerify() Function for verify data match in regex expression | * ioMkDir() - Function for racursive directory creation and validation |
* @csRegex = Regulare expression pattern | * |
* @csData = Data for check and verify | * @csDir = Full directory path |
* @startPos = Return start positions | * @mode = Mode for directory creation if missing dir |
* @endPos = Return end positions | * return: -1 error, 0 directory path exist, >0 created missing dirs |
* return: NULL not match or error; !=NULL begin of matched data | |
*/ |
*/ |
const char *ioRegexVerify(const char *csRegex, const char *csData, int *startPos, int *endPos); | int ioMkDir(const char *csDir, int mode); |
| |
/* |
/* |
* ioRegexGet() Function for get data match in regex expression | * ioWatchDirLoop() - Function for watching changes in directory and fire callback |
* @csRegex = Regulare expression pattern | * |
* @csData = Data from get | * @csDir = Full directory path |
* @psString = Returned string if match | * @callback = Callback if raise event! nOp -1 delete, 0 change/move, 1 create |
* @strLen = Length of string | * return: -1 error, !=-1 ok, number of total signaled events |
* return: 0 not match; >0 count of returned chars | |
*/ |
*/ |
int ioRegexGet(const char *csRegex, const char *csData, char * __restrict psString, int strLen); | int ioWatchDirLoop(const char *csDir, int (*callback)(const char *csName, int nOp)); |
| |
| |
| #ifdef AIO_OPS |
/* |
/* |
* ioRegexReplace() Function for replace data match in regex expression with newdata | * io_aiobulk() - AIO bulk R/W function |
* @csRegex = Regulare expression pattern | * |
* @csData = Source data | * @mode = Bulk wait mode |
* @csNew = Data for replace | * @acbs = List of aiocb structures |
* return: NULL not match or error; !=NULL allocated new string, must be free after use! | * @nacb = Number of aiocb in list |
| * @sig = Event for completed operations, may be =NULL |
| * return: -1 error or 0 ok |
| */ |
| int io_aiobulk(int mode, struct aiocb ** __restrict acbs, int nacb, |
| struct sigevent *sig); |
| #endif |
| /* |
| * io_rreadv() - Raw VFS bulk read function |
| * |
| * @fd = File handle |
| * @bufs = Read buffers |
| * @nbufs = Number of read buffers |
| * @offset = Read from position, if -1 read nbytes from current position |
| * @update = Update file handle position !0 |
| * return: -1 error or !=-1 readed bytes |
| */ |
| int io_rreadv(int fd, struct iovec * __restrict bufs, int nbufs, off_t offset, |
| int update); |
| /* |
| * io_rwritev() - Raw VFS bulk write function |
| * |
| * @fd = File handle |
| * @bufs = Write buffers |
| * @nbufs = Number of write buffers |
| * @offset = Write to position, if -1 write nbytes to current position |
| * @update = Update file handle position !0 |
| * return: -1 error or !=-1 written bytes |
| */ |
| int io_rwritev(int fd, struct iovec * __restrict bufs, int nbufs, off_t offset, |
| int update); |
| /* |
| * io_rread() - Raw VFS read function |
| * |
| * @fd = File handle |
| * @buf = Read buffer |
| * @nbytes = Read buffer size |
| * @offset = Read from position, if -1 read nbytes from current position |
| * @update = Update file handle position !0 |
| * return: -1 error or !=-1 readed bytes |
| */ |
| int io_rread(int fd, void * __restrict buf, size_t nbytes, off_t offset, |
| int update); |
| /* |
| * io_rwrite() - Raw VFS write function |
| * |
| * @fd = File handle |
| * @buf = Write buffer |
| * @nbytes = Write bytes from buffer |
| * @offset = Write at position, if -1 write nbytes from current position |
| * @update = Update file handle position !0 |
| * return: -1 error or !=-1 written bytes |
| */ |
| int io_rwrite(int fd, void * __restrict buf, size_t nbytes, off_t offset, |
| int update); |
| |
| /* Disk I/O helper macros */ |
| #define io_read(f, b, n) io_rread(f, b, n, -1, 1) |
| #define io_write(f, b, n) io_rwrite(f, b, n, -1, 1) |
| |
| |
| /* Crypto framework */ |
| |
| /* |
| * ioCipher() - Cipher wrapper for all supported crypto algorythms |
| * |
| * @pInput = input buffer |
| * @inLen = input buffer len |
| * @ppOutput = output allocated buffe, must be e_free after use |
| * @Cipher = cipher engine, like EVP_bf_cbc() or etc... |
| * @pKey = key |
| * @pIV = IV, salt (8 bytes) |
| * @nMode = Mode 0 - decrypting or 1 - encrypting |
| * return: 0 not present data or error!; >0 number of processed and returned bytes into ppOutput |
*/ |
*/ |
char *ioRegexReplace(const char *csRegex, const char *csData, const char *csNew); | int ioCipher(unsigned char *pInput, int inLen, unsigned char **ppOutput, const EVP_CIPHER *Cipher, |
| unsigned char *pKey, unsigned char *pIV, int nMode); |
| |
| /* |
| * io_Blowfish() - Blowfish cipher algorythm, work with ASCII hex strings |
| * |
| * @pInput = input buffer |
| * @inLen = input buffer len |
| * @ppOutput = output allocated buffe, must be e_free after use |
| * @pKey = key |
| * @pIV = IV, salt (8 bytes) |
| * @nMode = Mode 0 - decrypting or 1 - encrypting |
| * return: 0 not present data or error!; >0 number of processed and returned bytes into ppOutput |
| */ |
| int io_Blowfish(unsigned char *pInput, int inLen, unsigned char **ppOutput, |
| unsigned char *pKey, unsigned char *pIV, int nMode); |
| /* |
| * io_ctr_AES() - Encrypt/Decrypt stream cipher CTR_AES |
| * |
| * @pInput = Input buffer with ASCII |
| * @inLen = Input buffer data length |
| * @ppOutput = Output buffer with cipher data, must be e_free after use |
| * @pKey = Key |
| * @IV = IVector/Nonce/Counter, Warning: IV must be variable, because we write there!!! |
| * return: -1 error or >-1 how many cipher blocks proceeded |
| */ |
| int io_ctr_AES(unsigned char *pInput, int inLen, unsigned char **ppOutput, |
| unsigned char *pKey, unsigned char IV[AES_BLOCK_SIZE]); |
| |
| |
| /* |
| * ioAllocPTY() - Allocate new PTY and TTY |
| * |
| * @ptyfd = master fd, pty |
| * @ttyfd = slave fd, tty |
| * @name = tty device name if not null |
| * @namesiz = name length, must be above 63 bytes. |
| * @term = termios for terminal |
| * @winz = winsize for terminal |
| * return: -1 error or 0 ok |
| */ |
| int ioAllocPTY(int *ptyfd, int *ttyfd, char * __restrict name, int namesiz, |
| struct termios * __restrict term, struct winsize * __restrict winz); |
| /* |
| * ioFreePTY() - Release PTY and TTY device |
| * |
| * @ptyfd = master fd, pty (==-1 skip closing pty) |
| * @ttyname = tty filename |
| * return: none |
| */ |
| void ioFreePTY(int ptyfd, const char *ttyname); |
| /* |
| * ioChgWinPTY() - Change window size of PTY |
| * |
| * @ptyfd = master fd, pty |
| * @row = row |
| * @col = col |
| * @xpxl = x pixels |
| * @ypxl = y pixels |
| * return: -1 error or 0 ok |
| */ |
| int ioChgWinPTY(int ptyfd, unsigned short row, unsigned short col, |
| unsigned short xpxl, unsigned short ypxl); |
| /* |
| * ioSetOwnerTTY() - Set owner to TTY |
| * |
| * @ttyname = tty filename |
| * @UID = uid |
| * @GID = gid |
| * return: -1 error or 0 ok |
| */ |
| int ioSetOwnerTTY(const char *ttyname, uid_t UID, gid_t GID); |
| /* |
| * ioSetSidTTY() - Makes the process's controlling TTY and sets it to sane modes. |
| * |
| * @ttyfd = slave fd, tty |
| * @ttyname = tty filename |
| * return: -1 error or 0 ok |
| */ |
| int ioSetSidTTY(int *ttyfd, const char *ttyname); |
| /* |
| * ioSetRAWMode() - Enter into RAW mode |
| * |
| * @fd = tty fd |
| * @otio = saved old termios for later restore if !=NULL |
| * return: -1 error or 0 ok |
| */ |
| int ioSetRAWMode(int fd, struct termios *otio); |
| /* |
| * ioRestoreMode() - Restore termios to tty fd |
| * |
| * @fd = tty fd |
| * @tio = termios structure for restore |
| * return: -1 error or 0 ok |
| */ |
| int ioRestoreMode(int fd, struct termios tio); |
| /* |
| * ioForkPTY() - Fork new process with session leader and new TTY |
| * |
| * @ptyfd = master fd, pty |
| * @name = tty device name if not null |
| * @namesiz = name length, must be above 63 bytes. |
| * @term = termios for terminal |
| * @winz = winsize for terminal |
| * @otio = old termios structure for restore |
| * return: -1 error, 0 child process or >0 parent: pid of child |
| */ |
| pid_t ioForkPTY(int *ptyfd, char * __restrict name, int namesiz, struct termios * __restrict term, |
| struct winsize * __restrict winz, struct termios * __restrict otio); |
| |
| /* |
| * ioCreatePIDFile() - Create PID file |
| * |
| * @csName = PID filename |
| * @ifExists = !=0 if filename exists return error |
| * return: -1 error or 0 ok |
| */ |
| int ioCreatePIDFile(const char *csName, int ifExists); |
| |
| /* |
| * ioSendFile() - AITNET sendfile() userland implementation, not dependant from OS |
| * |
| * @s = socket |
| * @csFile = file for send |
| * @sendLen = bytes to send, if 0 send all data |
| * @offset = start file offset |
| * @sndbuf = SO_SNDBUF value, if 0 use default |
| * return: 0 error, >0 ok, sended bytes |
| */ |
| size_t ioSendFile(int s, const char *csFile, size_t sendLen, off_t offset, int sndbuf); |
| /* |
| * ioRecvFile() - Receive file from socket, fastest (zero-copy) way |
| * |
| * @s = socket |
| * @csFile = file for receive |
| * @recvLen = receive bytes |
| * @over = overwrite file if exists with mode like 0644 |
| * @rcvbuf = SO_RCVBUF value, if 0 use default |
| * return: 0 error, >0 ok, received bytes |
| */ |
| size_t ioRecvFile(int s, const char *csFile, size_t recvLen, int over, int rcvbuf); |
| |
| /* |
| * ioRealFileName() - Get real file name |
| * |
| * @fname = filename |
| * return: =NULL error or !=NULL real filename, should be free with e_free() |
| */ |
| char *ioRealFileName(const char *fname); |
| |
| /* Buffered file access over memory block */ |
| |
| /* |
| * io_fmemopen() - File buffered stream operations over memory block |
| * |
| * @base = Base address of memory block, if =NULL Infinit length(auto-grow) |
| * @basesize = Size of memory block |
| * return: NULL error or !=NULL Opened file resource |
| */ |
| FILE *io_fmemopen(void ** __restrict base, off_t basesize); |
| /* |
| * io_fmapopen() - File buffered stream operations over MMAP block |
| * |
| * @csFile = Filename for MMAP, if =NULL private MMAP block |
| * @mode = File open mode |
| * @perm = If file not exists will be created with this access permissions |
| * @prot = MMAP protection |
| * @flags = MMAP mode flags |
| * @offset = Map from file offset, if csFile==NULL then this is size of MMAP private block |
| * return: NULL error or !=NULL Opened file resource |
| */ |
| FILE *io_fmapopen(const char *csFile, int mode, int perm, int prot, int flags, off_t offset); |
| /* |
| * io_fd2buf() - Convert open file handle to buffered file I/O |
| * |
| * @fd = File handle |
| * @mode = Permissions for new buffered file I/O |
| * return: NULL error or open buffered file |
| */ |
| FILE *io_fd2buf(int fd, const char *mode); |
| /* |
| * io_dumbFile() - Create empry or dumb file with fixed size |
| * |
| * @csFile = Filename for create |
| * @mode = File access permissions |
| * @size = File size |
| * return: -1 error or open file handle |
| */ |
| int io_dumbFile(const char *csFile, int mode, off_t size); |
| |
| |
| /* |
| * io_get1stiface() - Get first interface of host |
| * |
| * @szIface = interface string buffer |
| * @iflen = size of interface buffer |
| * return: -1 error or 0 ok |
| */ |
| 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 |
| * |
| * @csIface = interface name |
| * @flags = open flags |
| * @whdr = with complete headers |
| * @wdlt = with data link type |
| * @buflen = buffer length |
| * @zcbuf = zero copy buffer, if BPF supports it and isn't NULL |
| * return: -1 error or >-1 bpf handle |
| */ |
| int io_etherOpen(const char *csIface, int flags, int whdr, int wdlt, |
| unsigned int *buflen, void **zcbuf); |
| /* |
| * io_etherClose() - Close BPF interface |
| * |
| * @eth = bpf handle |
| * @zcbuf = zero copy buffer, if BPF supports it and isn't NULL |
| * return: none |
| */ |
| 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 |
| * |
| * @eth = bpf handle |
| * @buf = buffer |
| * @buflen = buffer length |
| * return: -1 error or !=-1 written bytes |
| */ |
| ssize_t io_etherSend(int eth, const void *buf, size_t buflen); |
| /* |
| * io_etherRecv() - Receive packet from bpf |
| * |
| * @eth = bpf handle |
| * @buf = buffer |
| * @buflen = buffer length |
| * @zcbuf = zero copy buffer, if BPF supports it and isn't NULL |
| * return: -1 error or !=-1 readed bytes |
| */ |
| ssize_t io_etherRecv(int eth, void * __restrict buf, |
| size_t buflen, void * __restrict zcbuf); |
|
|
|
|
#endif |
#endif |