SIPExpressRouter: io_wait.h File Reference

do{\
                        if (unlikely(idx==-1)){ \
                                /* fix idx if -1 and needed */ \
                                for (idx=0; (idx<h->fd_no) && \
                                                        (h->fd_array[idx].fd!=fd); idx++); \
                        } \
                        if (likely(idx<h->fd_no)){ \
                                h->fd_array[idx].events=(ev); \
                        } \
        }while(0)

do{ \
                h->fd_array[h->fd_no].fd=fd; \
                h->fd_array[h->fd_no].events=(ev); /* useless for select */ \
                h->fd_array[h->fd_no].revents=0;     /* useless for select */ \
        }while(0)

do{\
                        if (unlikely(idx==-1)){ \
                                /* fix idx if -1 and needed */ \
                                for (idx=0; (idx<h->fd_no) && \
                                                        (h->fd_array[idx].fd!=fd); idx++); \
                        } \
                        if (likely(idx<h->fd_no)){ \
                                memmove(&h->fd_array[idx], &h->fd_array[idx+1], \
                                        (h->fd_no-(idx+1))*sizeof(*(h->fd_array))); \
                                if ((idx<=h->crt_fd_array_idx) && (h->crt_fd_array_idx>=0)) \
                                        h->crt_fd_array_idx--; \
                        } \
        }while(0)

do{ \
                        flags=fcntl(fd, F_GETFL); \
                        if (flags==-1){ \
                                LOG(L_ERR, "ERROR: io_watch_add: fnctl: GETFL failed:" \
                                                " %s [%d]\n", strerror(errno), errno); \
                                goto error; \
                        } \
                        if (fcntl(fd, F_SETFL, flags|(f))==-1){ \
                                LOG(L_ERR, "ERROR: io_watch_add: fnctl: SETFL" \
                                                        " failed: %s [%d]\n", strerror(errno), errno); \
                                goto error; \
                        } \
        }while(0)

do{ \
                (pfm)->type=0 /*F_NONE */; \
                (pfm)->fd=-1; \
        }while(0)


Data Structures
struct	fd_map
struct	io_wait_handler
Defines
#define	_GNU_SOURCE
#define	get_fd_map(h, fd) (&(h)->fd_hash[(fd)])
#define	unhash_fd_map(pfm)
#define	fd_array_setup(ev)
#define	set_fd_flags(f)
#define	IO_FD_CLOSING 16
#define	fix_fd_array
#define	fd_array_chg(ev)
Typedefs
typedef int	fd_type
typedef io_wait_handler	io_wait_h
Functions
fd_map *	hash_fd_map (io_wait_h h, int fd, short events, fd_type type, void data)
int	handle_io (struct fd_map *fm, short events, int idx)
int	io_watch_add (io_wait_h h, int fd, short events, fd_type type, void data)
int	io_watch_del (io_wait_h *h, int fd, int idx, int flags)
int	io_watch_chg (io_wait_h *h, int fd, short events, int idx)
int	io_wait_loop_poll (io_wait_h *h, int t, int repeat)
int	init_io_wait (io_wait_h *h, int max_fd, enum poll_types poll_method)
void	destroy_io_wait (io_wait_h *h)
Variables
int	_os_ver

io_wait.h File Reference

Data Structures

Defines

Typedefs

Functions

Variables

Define Documentation

Typedef Documentation

Function Documentation

Variable Documentation