文件结构
- 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中再进行追加操作那么就会形成死循环。