libevent原始碼分析--evbuffer緩衝

阿新 • • 發佈：2019-01-11

實際運作

這裡我將結合具體的程式碼分析libevent是如何操作上面那個佇列式的evbuffer的，先看一些輔助函式：

void evbuffer_drain(struct evbuffer *buf, size_t len)

在這個函式中，最後一個部分是呼叫了evbuffer中的回撥，如果這個buffer已經被修改，那麼直接呼叫這個buffer中的回撥！

該函式主要操作一些指標，當每次從evbuffer裡讀取資料時，libevent便會將buffer指標後移，同時增大misalign，減小off，
而該函式正是做這件事的。說白了，該函式就是用於調整緩衝佇列的前向指標。

int evbuffer_expand(struct evbuffer *buf, size_t datlen)

    該函式用於擴充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、...)。

瞭解了以上兩個函式，看其他函式就比較簡單了。可以看看具體的讀資料和寫資料：

int evbuffer_add(struct evbuffer *buf, constvoid*data, size_t datlen)

該函式用於新增一段使用者資料到evbuffer中。很簡單，就是先判斷是否有足夠的空閒記憶體，如果沒有則呼叫evbuffer_expand
擴充之，然後直接memcpy，更新off指標。

int evbuffer_remove(struct evbuffer *buf, void*data, size_t datlen)

該函式用於將evbuffer中的資料複製給使用者空間(讀資料)。簡單地將資料memcpy，然後呼叫evbuffer_drain移動相關指標。

struct evbuffer* evbuffer_new(void) 動態分配一個struct evbuffer結構，需要呼叫evbuffer_free釋放記憶體。

void evbuffer_free(struct evbuffer *buffer) 釋放buffer所佔用的記憶體。

int evbuffer_add_buffer(struct evbuffer *outbuf, struct evbuffer *inbuf)

移動資料從一個evbuffer到另一個evbuffer。

實際上還是呼叫了evbuffer_add新增資料到outbuf中。但會清除inbuf中的資料。

返回值：成功返回0，失敗返回-1。

int evbuffer_add_printf( struct evbuffer *, constchar* fmt,

) 新增一個格式化的字串到evbuffer尾部。

u_char *evbuffer_find(struct evbuffer *buffer, const u_char *what, size_t len)

查詢緩衝區中是否存在指定的字串what。

注意這裡使用的是u_char型別，說明有可能查詢的資料不是以’\0’結尾

如果存在返回指向字串what的指標，沒有則返回NULL。

int evbuffer_read(struct evbuffer *buf, int fd, int howmuch) 呼叫read/recv函式，從檔案描述符fd上讀取資料到evbuffer中。如果緩衝區不夠，呼叫evbuffer_expand擴充緩衝區。
int evbuffer_write(struct evbuffer *buffer, int fd) 把緩衝區中的資料，呼叫send/write函式寫入檔案描述符fd上，如果send/write函式寫入的位元組數大於0，則呼叫evbuffer_drain刪除已寫的資料。
char*evbuffer_readline(struct evbuffer *buffer)

讀取資料以"\r\n","\n\r", "\r" 或者 "\n"結尾。

返回動態分配記憶體，需要呼叫者自己使用free來釋放記憶體。返回一個以“\0”結尾的字串。

void evbuffer_setcb(struct evbuffer *buffer,
void (*cb)(struct evbuffer *, size_t, size_t, void*),
void*cbarg) 設定回撥函式。當緩衝區中發生變化時，呼叫設定的回撥函式。

Evbuffer提供的API已經全部介紹完畢，接下來我們通過一個例項進一步學習如何使用evbuffer, 想要使用evbuffer，系統裡必須已經安裝了libevent。

例子程式碼如下：evbuffer-test.c

#include <stdio.h>#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");
   return0;
}

libevent原始碼分析--evbuffer緩衝

libevent原始碼分析--evbuffer緩衝

Libevent原始碼分析-----evbuffer結構與基本操作

Libevent原始碼分析-----更多evbuffer操作函式

Libevent原始碼分析（五）--- evbuffer的基本操作

MySQL 原始碼分析 Innodb緩衝池刷髒的多執行緒實現

libevent原始碼分析－－鎖和多執行緒

libevent原始碼分析

libevent原始碼分析（五）

libevent原始碼分析（六）

Libevent原始碼分析-----event-config.h指明所在系統的環境

Libevent原始碼分析-----記憶體分配

Libevent原始碼分析-----event_io_map雜湊表

Libevent原始碼分析-----event_signal_map

Libevent原始碼分析-----配置event_base

Libevent原始碼分析-----跨平臺Reactor介面的實現

Libevent原始碼分析-----Libevent工作流程探究

Libevent原始碼分析-----訊號event的處理

Libevent原始碼分析-----與event相關的一些函式和操作

Libevent原始碼分析-----超時event的處理

Libevent原始碼分析-----通用型別和函式

libevent原始碼分析--evbuffer緩衝

相關推薦