ceph之AsyncMessenger类图
2022-01-08 00:10:53 0 举报
ceph通信模块AsyncMessenger类图
作者其他创作
大纲/内容
XioMessenger
int start();int bind();void ready();int accept_conn();int send_message();ConnectionRef get_connection();
RDMAStack
void spawn_worker();
KqueueDriver
SelectDriver
RDMAWorker
int listen();int connect();
EventDriver
DPDKStack
PosixWorker
PosixNetworkStack
1:N
Messenger
list<Dispatcher*> dispatchers;list <Dispatcher*> fast_dispatchers;
Messenger *create();void add_dispatcher_head(Dispatcher *d);void add_dispatcher_tail(Dispatcher *d);
AsyncMessenger
NetworkStack *stack;std::vector<Processor*> processors;DispatchQueue dispatch_queue;
Processor
Worker *worker;ServerSocket listen_socket;EventCallbackRef listen_handler;
void start()；int bind();void accept();
SimpleMessenger
EventCenter
int notify_receive_fd;int notify_send_fd;EventDriver *driver;deque<EventCallbackRef> external_events;vector<FileEvent> file_events;
int init();void set_owner();void wakeup();int process_time_events();
1:1
NetworkStack
vector<Worker*> workers;
NetworkStack* create();Worker* create_worker();void start();
EpollDriver
DPDKDriver
DPDKWorker
Worker
EventCenter center;
收藏
0 条评论
回复 删除
下一页
