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 ;
}

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

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

查看所有标签

猜你喜欢:

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

码农书籍

连线

加里·沃尔夫 / 黄锫坚 / 中国铁道出版社 / 2006-7 / 29.80元

简言之，是一个人和一本杂志的传奇…… 　　放在大环境中，是一个时代的跌宕起伏…… 　　一直大力地向所有人推荐这本书，只是因为，故事真的很精彩，是一个伟大而疯狂的时代所造就的一个不屈不挠的斗士——路易斯·罗塞托，还有这本举世皆知的杂志——《连线》。　　通过本书，中国读者会知道，新经济热潮的主角不仅是比尔·盖茨、杨致远等技术和商业能人，还有一大批新文化的传教士和吹鼓手，比如路易斯·......一起来看看《连线》这本书的介绍吧!

码农工具

redis源码阅读之ae_kqueue

连线

图片转BASE64编码

SHA 加密

RGB CMYK 转换工具