文件结构
- bufferevent.h 里面包含了其bufferevent操作的函数
- bufferevent_struct.h 里面包含了bufferevent结构体的定义
bufferevent
struct bufferevent {
struct event_base *ev_base;
const struct bufferevent_ops *be_ops;
struct event ev_read;
struct event ev_write;
struct evbuffer *input;
struct evbuffer *output;
struct event_watermark wm_read;
struct event_watermark wm_write;
bufferevent_data_cb readcb;
bufferevent_data_cb writecb;
bufferevent_event_cb errorcb;
void *cbarg;
struct timeval timeout_read;
struct timeval timeout_write;
short enabled;
};
所谓的自动read/write操作就是当底层event事件触发后,bufferevent 帮我们把数据从evbuffer中进行搬移,然后根据相应的低水位线的设置去调用我们自己设置的callback函数。
eventbuffer_read
每次数据到tcp Recv缓冲区后就会触发 ev_read的读时间,然后调用内部的回调函数从tcp Recv缓冲区中最多读EVBUFFER_MAX_READ(4096)个字节到应用层,这个时候判断如果读的数据高于 read-low-water 了,再去调用我们自己设置的 readcb函数。
这也叫意味着如果tcp Recv缓冲区没有数据了,那么将不再触发底层ev_read的回调函数,随之也不再触发我们自己设置的readcb函数了。
总结eventbuffer_read的调用路径: ev_read –> readcb –> bufferevent_read
eventbuffer_write
每次我们调用eventbuffer_write的时候,数据就会被添加到bufferevent的输出缓冲区内,这个时候evbuffer被添加了数据,output_evbuffer的callback函数(bufferevent_socket_outbuf_cb)就会被调用,这个函数给ev_write添加EV_WRITE到event_base中,socket的tcp send缓冲区内如果还有空余地方该socket的就会写就绪,这个时候ev_write的回调函数被调用,数据被send出去,发送完毕后判断如果写缓冲区空了,调用我们自己设置的writecb。
总结eventbuffer_write调用路径: eventbuffer_write –> evbuffer_add ->bufferevent_socket_outbuf_cb –> ev_write –> writecb
其中在ev_write中默认如果没有对bufferevent进行限制,每次最多write MAX_TO_WRITE_EVER 16384 个数据。
所以默认如果我们在自己的writecb中向output缓冲区每次写入少于16384个数据的时候就会造成死循环。请看上面的调用链,一次性write完缓冲区的数据后,发现缓冲区大小小于等于 low-write-water 调用我们的 writecb ,我们的writecb中再进行追加操作那么就会形成死循环。