Memtiter-benchmark源码解析2--shared_connection

Posted 2022-12-30 lilele12211104

shard_connection.h

class shad_connection

private members

Line 161 行 bufferevent* m_bev；重要的bufferevent_event

important methods

setup_event

shard_connection.cpp

bufferevent_setcb 设置了 m_bev 的读事件的函数回调，没有设置写事件的函数回调

send_set_command

cmd_size = m_protocol->write_command_set(key, key_len, value, value_len,
expiry, offset);
m_protocol->write_command_set 方法见“Memtiter-benchmark源码解析3–protocol“

std::queue<request > m_pipeline;
int m_pending_resp;

338 发送完当前请求后，该请求进队

memtiter 收到response请求后

line 394 memtiter 收到一个response后，与该response对应的请求就是当前shared_connection 中std::queue<request > m_pipeline 排在队首的request所发送的.

m_conns_manager 有若干个子类。client是其中之一