| 241 | } |
| 242 | |
| 243 | void 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 | |
| 258 | struct StackSingleton { |
no test coverage detected