redis源码阅读之ae_kqueue

栏目: 数据库 · 发布时间: 6年前

内容简介：kqueue是FreeBSD当中提供的io多路复用机制，由于上一篇在介绍epoll()的时候被告知有敏感词，不让发，那kqueue()的具体介绍也就只能往后延一下了，这里着重介绍redis是如何包装的其一般的api调用如下：关键api如下：

kqueue是FreeBSD当中提供的io多路复用机制，由于上一篇在介绍epoll()的时候被告知有敏感词，不让发，那kqueue()的具体介绍也就只能往后延一下了，这里着重介绍 redis 是如何包装的

点击( 此处 )折叠或打开

typedef struct aeApiState {
int kqfd ;
struct kevent * events ;
} aeApiState ;

其一般的api调用如下：

点击( 此处 )折叠或打开

static int aeApiCreate ( aeEventLoop * eventLoop ) {
aeApiState * state = zmalloc ( sizeof ( aeApiState ) ) ;
if ( ! state ) return - 1 ;
state - > events = zmalloc ( sizeof ( struct kevent ) * eventLoop - > setsize ) ;
if ( ! state - > events ) {
zfree ( state ) ;
return - 1 ;
}
state - > kqfd = kqueue ( ) ;
if ( state - > kqfd = = - 1 ) {
zfree ( state - > events ) ;
zfree ( state ) ;
return - 1 ;
}
eventLoop - > apidata = state ;
return 0 ;
}
static int aeApiResize ( aeEventLoop * eventLoop , int setsize ) {
aeApiState * state = eventLoop - > apidata ;
state - > events = zrealloc ( state - > events , sizeof ( struct kevent ) * setsize ) ;
return 0 ;
}
static void aeApiFree ( aeEventLoop * eventLoop ) {
aeApiState * state = eventLoop - > apidata ;
close ( state - > kqfd ) ;
zfree ( state - > events ) ;
zfree ( state ) ;
}
static int aeApiAddEvent ( aeEventLoop * eventLoop , int fd , int mask ) {
aeApiState * state = eventLoop - > apidata ;
struct kevent ke ;
if ( mask & AE_READABLE ) {
EV_SET ( & ke , fd , EVFILT_READ , EV_ADD , 0 , 0 , NULL ) ;
if ( kevent ( state - > kqfd , & ke , 1 , NULL , 0 , NULL ) = = - 1 ) return - 1 ;
}
if ( mask & AE_WRITABLE ) {
EV_SET ( & ke , fd , EVFILT_WRITE , EV_ADD , 0 , 0 , NULL ) ;
if ( kevent ( state - > kqfd , & ke , 1 , NULL , 0 , NULL ) = = - 1 ) return - 1 ;
}
return 0 ;
}
static void aeApiDelEvent ( aeEventLoop * eventLoop , int fd , int mask ) {
aeApiState * state = eventLoop - > apidata ;
struct kevent ke ;
if ( mask & AE_READABLE ) {
EV_SET ( & ke , fd , EVFILT_READ , EV_DELETE , 0 , 0 , NULL ) ;
kevent ( state - > kqfd , & ke , 1 , NULL , 0 , NULL ) ;
}
if ( mask & AE_WRITABLE ) {
EV_SET ( & ke , fd , EVFILT_WRITE , EV_DELETE , 0 , 0 , NULL ) ;
kevent ( state - > kqfd , & ke , 1 , NULL , 0 , NULL ) ;
}
}
static char * aeApiName ( void ) {
return "kqueue" ;
}

关键api如下：

点击( 此处 )折叠或打开

static int aeApiPoll ( aeEventLoop * eventLoop , struct timeval * tvp ) {
aeApiState * state = eventLoop - > apidata ;
int retval , numevents = 0 ;
if ( tvp ! = NULL ) {
struct timespec timeout ;
timeout . tv_sec = tvp - > tv_sec ;
timeout . tv_nsec = tvp - > tv_usec * 1000 ;
retval = kevent ( state - > kqfd , NULL , 0 , state - > events , eventLoop - > setsize ,
& timeout ) ;
} else {
retval = kevent ( state - > kqfd , NULL , 0 , state - > events , eventLoop - > setsize ,
NULL ) ;
}
if ( retval > 0 ) {
int j ;
numevents = retval ;
for ( j = 0 ; j < numevents ; j + + ) {
int mask = 0 ;
struct kevent * e = state - > events + j ;
if ( e - > filter = = EVFILT_READ ) mask | = AE_READABLE ;
if ( e - > filter = = EVFILT_WRITE ) mask | = AE_WRITABLE ;
eventLoop - > fired [ j ] . fd = e - > ident ;
eventLoop - > fired [ j ] . mask = mask ;
}
}
return numevents ;
}

还请各位看官老爷多提宝贵意见~

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。

码农书籍

JAVA核心技术（卷1）

Cay S. Horstmann、Gary Cornell / 杜永萍、邝劲筠、叶乃文 / 机械工业出版社 / 2008-6 / 98.00元

《JAVA核心技术(卷1):基础知识(原书第8版)》是《Java核心技术》的最新版，《Java核心技术》出版以来一直畅销不衰，深受读者青睐，每个新版本都尽可能快地跟上Java开发工具箱发展的步伐，而且每一版都重新改写了的部分内容，以便适应Java的最新特性。本版也不例外，它反遇了Java SE6的新特性。全书共14章，包括Java基本的程序结构、对象与类、继承、接口与内部类、图形程序设计、事件处理......一起来看看《JAVA核心技术（卷1）》这本书的介绍吧!

码农工具

redis源码阅读之ae_kqueue

JAVA核心技术（卷1）

图片转BASE64编码

Base64 编码/解码

html转js在线工具