按照lighttpd的方式封装了一下epoll,打算以后就直接这么用了,虽然简陋了点,不过很容易修改
event.h头文件
#include <sys/epoll.h>
#define BV(x) (1 << x)
#define FDEVENT_IN BV(0)
#define FDEVENT_PRI BV(1)
#define FDEVENT_OUT BV(2)
#define FDEVENT_ERR BV(3)
#define FDEVENT_HUP BV(4)
#define FDEVENT_NVAL BV(5)
typedef void (*fdevent_handler)(int fd,void *ctx, int revents);
typedef struct _fdnode{
fdevent_handler handler;
int fd;
void *ctx;
int status;
}fdnode;
typedef struct fdevents{
fdnode **fdarray;
size_t maxfds;
int epoll_fd;
struct epoll_event *epoll_events;
}fdevents;
fdevents *fdevent_init(size_t maxfds);
void fdevent_free(fdevents *ev);
int fdevent_register(fdevents *ev,int fd,fdevent_handler handler,void *ctx);
int fdevent_unregister(fdevents *ev,int fd);
int fdevent_event_add(fdevents *ev,int fd,int events);
int fdevent_event_del(fdevents *ev,int fd);
int fdevent_poll(fdevents *ev, int timeout_ms);
event.c实现
#include<stdio.h>
#include<unistd.h>
#include<sys/types.h>
#include<stdlib.h>
#include<sys/socket.h>
#include<errno.h>
#include<fcntl.h>
#include<netinet/in.h>
#include<sys/resource.h>
#include "event.h"
//foward declaration
static fdnode *fdnode_init();
static void fdnode_free(fdnode *fdn);
fdevents *fdevent_init(size_t maxfds){
fdevents *ev;
ev = calloc(1,sizeof(*ev));
ev->fdarray = calloc(maxfds , sizeof(*ev->fdarray));
ev->maxfds = maxfds;
ev->epoll_fd=epoll_create(maxfds);
if(-1==ev->epoll_fd){
fprintf(stderr,"epoll create failed,%s\n",strerror(errno));
return NULL;
}
ev->epoll_events=malloc(maxfds * sizeof(*ev->epoll_events));
return ev;
}
void fdevent_free(fdevents *ev){
size_t i;
if(!ev) return ;
close(ev->epoll_fd);
free(ev->epoll_events);
for(i=0;i<ev->maxfds;i++){
if(ev->fdarray[i]) free(ev->fdarray[i]);
}
free(ev->fdarray);
free(ev);
}
int fdevent_register(fdevents *ev,int fd,fdevent_handler handler,void *ctx){
fdnode *fdn;
fdn=fdnode_init();
fdn->handler=handler;
fdn->fd=fd;
fdn->ctx=ctx;
ev->fdarray[fd]=fdn;
return 0;
}
int fdevent_unregister(fdevents *ev,int fd){
if(!ev) return 0;
fdnode *fdn=ev->fdarray[fd];
fdnode_free(fdn);
ev->fdarray[fd]=NULL;
return 0;
}
int fdevent_event_add(fdevents *ev,int fd,int events){
struct epoll_event ep;
int add=0;
fdnode *fdn=ev->fdarray[fd];
add = (fdn->status == -1 ? 1 : 0);
memset(&ep,0,sizeof(ep));
ep.events = 0;
if(events & FDEVENT_IN) ep.events |=EPOLLIN;
if(events & FDEVENT_OUT) ep.events |=EPOLLOUT;
ep.data.ptr=NULL;
ep.data.fd=fd;
if(0 != epoll_ctl(ev->epoll_fd,add ? EPOLL_CTL_ADD : EPOLL_CTL_MOD,fd,&ep)){
fprintf(stderr,"epoll_ctl failed %s\n",strerror(errno));
return -1;
}
if(add){
fdn->status=1;
}
return 0;
}
int fdevent_event_del(fdevents *ev,int fd){
struct epoll_event ep;
fdnode *fdn=ev->fdarray[fd];
if(-1==fdn->status){
return 0;
}
memset(&ep,0,sizeof(ep));
ep.data.ptr=NULL;
ep.data.fd=fd;
if(0 != epoll_ctl(ev->epoll_fd,EPOLL_CTL_DEL,fd,&ep)){
fprintf(stderr,"epoll del failed %s\n",strerror(errno));
return -1;
}
fdn->status=-1;
return 0;
}
int fdevent_poll(fdevents *ev, int timeout_ms){
int n,i;
for(;;){
n=0;
if((n=epoll_wait(ev->epoll_fd,ev->epoll_events,ev->maxfds,timeout_ms))>0){
for(i=0;i<n;i++){
fdevent_handler handler;
void *context;
int events = 0, e,fd;
fdnode *fdn;
e=ev->epoll_events[i].events;
if (e & EPOLLIN) events |= FDEVENT_IN;
if (e & EPOLLOUT) events |= FDEVENT_OUT;
fd=ev->epoll_events[i].data.fd;
fdn = ev->fdarray[fd];
context = fdn->ctx;
fdn->handler(fd,context,events);
}
}
}
}
static fdnode *fdnode_init(){
fdnode *fdn;
fdn=calloc(1,sizeof(*fdn));
fdn->fd=-1;
fdn->status=-1;
return fdn;
}
static void fdnode_free(fdnode *fdn){
free(fdn);
}
简单调用流程就是下面这几个接口
fdevents *fdevent_init(size_t maxfds);
int fdevent_register(fdevents *ev,int fd,fdevent_handler handler,void *ctx);
int fdevent_event_add(fdevents *ev,int fd,int events);
int fdevent_poll(fdevents *ev, int timeout_ms);
分享到:
相关推荐
在本部分我们实现一个较为好用实用的Epoll并发类, 由于实现代码与使用方式较简单, 因此就不在此赘述了, 下面我还使用了该类实现了一个基于Epoll的echo-server, 以演示该类的用法; 由于此处仅为Epoll类库的第一个...
封装了epoll功能,很简单的使用epoll,只需要指定epoll服务监听端口,就可以运行epoll服务。可以指定收到数据的回调函数,可以指定有连接的回调函数,可以指定网络关闭的回调函数。自己编写调试epoll模型可能要几天...
简单封装epoll,并附带demo和完整的源代码
iocp-epoll的几个例子,提供参考。 其中,iocp包含了几种使用方式,同步异步处理方式, epoll为linux下面使用,编译时可以使用下面简单命令, g++ -p -g -o hhh ***.cpp -l pthread
epoll的接口非常简单,一共就三个函数: 1. int epoll_create(int size); 2. int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event) 3. int epoll_wait(int epfd, struct epoll_event * events, int...
前言 但golang有gc,而且基本可以认为是抢占式调度,golang的性能与c ++部分还是差很多!我心目中的c ++协程库应该是...使用boost.Coroutine2对epoll系统调用的简单封装 使用说明 1.下载升压 到官网下载最新的发行版
使用c++实现linux 的epoll tcp协议, 自己封装的c++ 还有一个c的没有上传 有需要的话 call我
更重要的是它应该还要处理很多上层特有服务,例如:客户端的权限、还有上面提到的信息格式封装、简单的数据读取,断连重连,半包读写,心跳等等,这些Netty框架都提供了响应的支持。 4、JAVA NIO框架存在一个poll/...
17socket编程(十二) select限制 poll 18socket编程(十三) epoll使用 epoll与select、poll区别 epoll LT/ET模式 19socket编程(十四) UDP特点 UDP客户/服务基本模型 UDP回射客户/服务器 UDP注意点 20socket编程...
使用epoll+线程池+异步网络IO模式开发,并发性能优越。 代码经过大量的稳定性、性能测试,可满足商用服务器项目。 支持linux、macos、ios、android、windows平台 特性: 网络库 tcp/udp客户端,接口简单易用并且是...
多路分离复用:是对Epoll和IO的使用封装,使得使用者可以完全与Epoll的细节隔开,专心于IO的处理 线程池:提供一种执行任务的服务,用户只需按照任务接口实现自己任务然后将它放到线程池即可执行任务 内存管理:实现...
Server类中包括了有一个重要的类叫做Eventlooper这个类就是对epoll的封装,要用epoll_ctl注册到epoll上的fd又被封装为Channel类,当有数据到来需要操作时,channel中的几个函数指针就指向了需要回调的函数, 这里...
CVM是一个基于Linux的小型网络类库,她主要提供多路分离复用、线程池、内存管理和数据访问功能,多路分离复用:是对Epoll和IO的使用封装,使得使用者可以完全与Epoll的细节隔开,专心于IO的处理 线程池:提供一种...
redis封装了一个小型网络库供自己使用,这个网络库只有几百行代码,却基本实现了一个高效的异步网络事件框架,而且与其他redis模块相对独立,故我将其独立出来,方便以后复用。 与著名的libevent相比,它代码精简,...
代码我用c++简单的封装了一下,重点是数据包的定义,以及发送数据和接收数据时包的处理代码(protocol.h,server_recv(),send_to_serv()) 发送时数据包是由包头+数据 组成的:其中包头内容分为包类型+包长度。 接收...
使用epoll+线程池+异步网络IO模式开发,并发性能优越。代码经过大量的稳定性、性能测试,可满足商用服务器项目。支持linux、macos、ios、android、windows平台了解更多:特性网络库tcp/udp客户端,接口简单易用并且是...
Linux网络编程(总共41集) 讲解Linux网络编程知识,分以下四个篇章。 Linux网络编程之TCP/IP基础篇 Linux网络编程之socket编程篇 ...41一个简单的线程池实现 线程池性能分析 线程池实现 网络编程, Linux
Linux网络编程(总共41集) 讲解Linux网络编程知识,分以下四个篇章。 Linux网络编程之TCP/IP基础篇 Linux网络编程之socket编程篇 Linux网络编程之进程间通信篇 ...41一个简单的线程池实现 线程池性能分析 线程池实现
Linux网络编程(总共41集) 讲解Linux网络编程知识,分以下四个篇章。 Linux网络编程之TCP/IP基础篇 Linux网络编程之socket编程篇 ...41一个简单的线程池实现 线程池性能分析 线程池实现 网络编程, Linux
Linux网络编程(总共41集) 讲解Linux网络编程知识,分以下四个篇章。 Linux网络编程之TCP/IP基础篇 Linux网络编程之socket编程篇 ...41一个简单的线程池实现 线程池性能分析 线程池实现 网络编程, Linux, 密码