libevent: evbuffer缓冲
转载地址:http://www.cppblog.com/mysileng/archive/2013/02/01/197671.html
前言
可以说对于任何网络库(模块)而言,一个缓冲模块都是必不可少的。缓冲模块主要用于缓冲从网络接收到的数据,以及
用户提交的数据(用于发送)。很多时候,我们还需要将网络模块层(非TCP层)的这些缓冲数据拷贝到用户层,而这些内存拷贝
都会消耗时间。
在这里,我简要分析下libevent的相关代码(event.h和buffer.c)。
结构
关于libevent的缓冲模块,主要就是围绕evbuffer结构体展开。先看下evbuffer的定义:
// 当前有效缓冲区的内存起始地址
u_char *buffer;
// 整个分配(realloc)用来缓冲的内存起始地址
u_char *orig_buffer;
// origin_buffer和buffer之间的字节数
size_t misalign;
// 整个分配用来缓冲的内存字节数
size_t totallen;
// 当前有效缓冲区的长度(字节数)
size_t off;
//回到函数,当缓冲区有变化的时候会被调用
void (*cb)(struct evbuffer *, size_t, size_t, void *);
//回调函数的参数
void *cbarg;
};
读出。evbuffer分别设置相关指针(一个指标)用于指示读出位置和写入位置。其大致结构如图:
区域的大小,misalign表示buffer相对于orig_buffer的偏移,off表示有效数据的长度。
实际运作
这里我将结合具体的代码分析libevent是如何操作上面那个队列式的evbuffer的,先看一些辅助函数:
该函数主要操作一些指标,当每次从evbuffer里读取数据时,libevent便会将buffer指针后移,同时增大misalign,减小off,
而该函数正是做这件事的。说白了,该函数就是用于调整缓冲队列的前向指标。
该函数用于扩充evbuffer的容量。每次向evbuffer写数据时,都是将数据写到buffer+off后,buffer到buffer+off之间已被
使用,保存的是有效数据,而orig_buffer和buffer之间则是因为读取数据移动指标而形成的无效区域。
evbuffer_expand的扩充策略在于,首先判断如果让出orig_buffer和buffer之间的空闲区域是否可以容纳添加的数据,如果
可以,则移动buffer和buffer+off之间的数据到orig_buffer和orig_buffer+off之间(有可能发生内存重叠,所以这里移动调用的
是memmove),然后把新的数据拷贝到orig_buffer+off之后;如果不可以容纳,那么重新分配更大的空间(realloc),同样会移动
数据。
扩充内存的策略为:确保新的内存区域最小尺寸为256,且以乘以2的方式逐步扩大(256、512、1024、...)。
了解了以上两个函数,看其他函数就比较简单了。可以看看具体的读数据和写数据:
该函数用于添加一段用户数据到evbuffer中。很简单,就是先判断是否有足够的空闲内存,如果没有则调用evbuffer_expand
扩充之,然后直接memcpy,更新off指标。
该函数用于将evbuffer中的数据复制给用户空间(读数据)。简单地将数据memcpy,然后调用evbuffer_drain移动相关指标。
移动数据从一个evbuffer到另一个evbuffer。
实际上还是调用了evbuffer_add添加数据到outbuf中。但会清除inbuf中的数据。
返回值:成功返回0, 失败返回-1。
查找缓冲区中是否存在指定的字符串what。
注意这里使用的是u_char类型,说明有可能查找的数据不是以’\0’结尾
如果存在返回指向字符串what的指针,没有则返回NULL。
读取数据以"\r\n","\n\r", "\r" 或者 "\n"结尾。
返回动态分配内存,需要调用者自己使用free来释放内存。返回一个以“\0”结尾的字符串。
void (*cb)(struct evbuffer *, size_t, size_t, void *),
void *cbarg)
Evbuffer提供的API已经全部介绍完毕,接下来我们通过一个实例进一步学习如何使用evbuffer, 想要使用evbuffer,系统里必须已经安装了libevent。
例子代码如下:evbuffer-test.c
#include <string.h>
#include <assert.h>
//引入libevent头文件
#include "event.h"
int main(int argc, char** argv)
{
struct evbuffer* buff = NULL;
char c, c2[3] = {0};
buff = evbuffer_new();
assert(buff != NULL);
evbuffer_add(buff, "1", 1);
evbuffer_add(buff, "2", 1);
evbuffer_add(buff, "3", 1);
evbuffer_add_printf(buff, "%d%d", 4, 5);
assert(buff->off == 5);
evbuffer_remove(buff, &c, sizeof(char));
assert(c == '1');
evbuffer_remove(buff, &c, sizeof(char));
assert(c == '2');
evbuffer_remove(buff, &c, sizeof(char));
assert(c == '3');
evbuffer_remove(buff, c2, 2);
assert(strcmp(c2, "45") == 0);
assert(buff->off == 0);
evbuffer_add(buff, "test\r\n", 6);
assert(buff->off == 6);
char* line = evbuffer_readline(buff);
assert(strcmp(line, "test") ==0);
assert(buff->off == 0);
free(line);
evbuffer_free(buff);
printf("ok\n");
return 0;
}
libevent: evbuffer缓冲相关推荐
- libevent evbuffer缓冲源码分析
参考文章:http://blog.sina.com.cn/s/blog_4ab24dd501013d0h.html struct evbuffer* evbuffer_new(void) 动态分配一个 ...
- ringbuff进阶 evbuffer
Libevent之evbuffer详解_有时需要偏执狂的博客-CSDN博客 日常小知识点之用户层网络缓冲区(固定内存,ringbuffer,chainbuffer)_yun6853992的博客-CSD ...
- Linux c 开发 - libevent
目录 一.event_base 1. 创建event_base 2. 查看IO模型 3. 销毁event_base 4. 事件循环 event loop 5. event_base的例子 二.even ...
- 使用 libevent 和 libev 提高网络应用性能
简介 许多服务器部署(尤其是 web 服务器部署)面对的最大问题之一是必须能够处理大量连接.无论是通过构建基于云的服务来处理网络通信流,还是把应用程序分布在 IBM Amazon EC 实例上,还是为 ...
- libevent多线程使用bufferevent的那些事
void do_accept(struct evconnlistener *listener, evutil_socket_t fd, struct sockaddr *sa, int socklen ...
- libevent中的bufferevent
bufferevent是libevent中处理网络事件很重要也是比较复杂的一个模块,其中包含一个读事件,一个写事件,两个缓冲区(读和写).读写水位.三个回调(读.写.出错)和函数指针组成的操作集.目前 ...
- libevent入门
花了两天的时间在libevent上,想总结下,就以写简单tutorial的方式吧,貌似没有一篇简单的说明,让人马上就能上手用的. 首先给出官方文档吧: http://libevent.org ,首页有 ...
- 高效并发处理之libevent
出处:http://www.oschina.net/question/12_15837 构建现代的服务器应用程序需要以某种方法同时接收数百.数千甚至数万个事件,无论它们是内部请求还是网络连接,都要有效 ...
- libevent(1)
很多时候,除了响应事件之外,应用还希望做一定的数据缓冲.比如说,写入数据的时候,通常的运行模式是: l 决定要向连接写入一些数据,把数据放入到缓冲区中 l 等待连接可以写入 l 写入尽量多的数据 l ...
最新文章
- 网管员应掌握好的学习方法
- php 根据ip 扫描端口,python实现指定ip端口扫描方式
- 【数据挖掘】贝叶斯信念网络 ( 马尔科夫假设 | 结构 | 有向无环图 | 参数 | 条件概率表 | 案例分析 )
- 在IIS上建立WAP网站的图文方法
- Facebook最伟大的技术成就有哪些
- 貂蝉被“送”给关羽过夜,第2天绝望自尽,他做了什么?
- HUST软工1506班第2周作业成绩公布
- CentOS7 安装MongoDB 3.0服务
- java中发红包案例之红包界面不出来的解决方案
- 【知识】人工智能数学基础知识
- Python3小程序:把连续的16进制UTF8编码转换为字符串
- python使用opencv会蓝屏_Opencv和DirectShow一起做蓝屏抠像
- unity, 取消ugui button响应键盘
- contos下安装JDK1.7 ,tomcat,nginx
- Failed to start SYSV: NGINX is an HTTP(S) server, HTTP(S) reverse proxy and IMAP/POP3 proxy server.
- 国密 java springboot 实现 maven依赖 SM2 SM3 SM4 介绍及示例代码 技术专家
- 三维地图下载,3D地图下载,谷歌地球三维地形图查看
- 排球分组循环交叉编排_同学!中国海洋大学第一届排球联赛等你来战!
- 微软2016校园招聘4月在线笔试 hihocoder 1288 Font Size (模拟)
- Elastic App Search:免费的产品,可提供出色的搜索体验
热门文章
- ENVI二次开发时的注意事项
- Java高全级别灰色_想问下用过JAVACV的大兄弟,为啥我这边抽取图片总是有灰色图片...
- dockerfile二进制mysql_Dockerfile源码分离部署LNMP(Centos7)
- 平安性格测试题及答案_性格趣味小测试题 有趣的心理测试题大全及答案
- 呆萌的图模型学习——基本概念(一)
- eazyui ajax传值,jquery easyui ajax data属性传值方式
- SQLSERVER查询存储过程内容
- c# 拼凑特定格式的报表打印
- LeetCode 38. Count and Say
- MSsql server里日期不能直接存入date字段,要转换一下