ceph messager 分析

Messenger

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
// file: msg/Messenger.h
class Messenger{
private:
list<Dispatcher*> dispatchers;
list<Dispatcher*> fast_dispatchers;

protected:
entity_inst_t my_inst;
int default_send_priority; //默认发送优先级
/// set to true once the Messenger has started, and set to false on shutdown
bool started;
uint32_t magic;
int socket_priority;

public:
CephContext *cct;
}