MCPcopy Create free account
hub / github.com/ceph/ceph / stop

Method stop

src/msg/async/AsyncMessenger.cc:243–255  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

241}
242
243void Processor::stop()
244{
245 ldout(msgr->cct,10) << __func__ << dendl;
246
247 worker->center.submit_to(worker->center.get_id(), [this]() {
248 for (auto& listen_socket : listen_sockets) {
249 if (listen_socket) {
250 worker->center.delete_file_event(listen_socket.fd(), EVENT_READABLE);
251 listen_socket.abort_accept();
252 }
253 }
254 }, false);
255}
256
257
258struct StackSingleton {

Callers 5

~StackSingletonMethod · 0.45
shutdownMethod · 0.45
rebindMethod · 0.45
shutdown_connectionsMethod · 0.45
mark_down_addrsMethod · 0.45

Calls 5

submit_toMethod · 0.80
delete_file_eventMethod · 0.80
get_idMethod · 0.45
fdMethod · 0.45
abort_acceptMethod · 0.45

Tested by

no test coverage detected