ceph/src/crimson/osd/chained_dispatchers.cc

   1 #include "crimson/osd/chained_dispatchers.h"
   2 #include "crimson/net/Connection.h"
   3 #include "msg/Message.h"
   4
   5
   6 seastar::future<>
   7 ChainedDispatchers::ms_dispatch(crimson::net::Connection* conn,
   8                                 MessageRef m) {
   9   return seastar::do_for_each(dispatchers, [conn, m](Dispatcher* dispatcher) {
  10     return dispatcher->ms_dispatch(conn, m);
  11   });
  12 }
  13
  14 seastar::future<>
  15 ChainedDispatchers::ms_handle_accept(crimson::net::ConnectionRef conn) {
  16   return seastar::do_for_each(dispatchers, [conn](Dispatcher* dispatcher) {
  17     return dispatcher->ms_handle_accept(conn);
  18   });
  19 }
  20
  21 seastar::future<>
  22 ChainedDispatchers::ms_handle_connect(crimson::net::ConnectionRef conn) {
  23   return seastar::do_for_each(dispatchers, [conn](Dispatcher* dispatcher) {
  24     return dispatcher->ms_handle_connect(conn);
  25   });
  26 }
  27
  28 seastar::future<>
  29 ChainedDispatchers::ms_handle_reset(crimson::net::ConnectionRef conn) {
  30   return seastar::do_for_each(dispatchers, [conn](Dispatcher* dispatcher) {
  31     return dispatcher->ms_handle_reset(conn);
  32   });
  33 }
  34
  35 seastar::future<>
  36 ChainedDispatchers::ms_handle_remote_reset(crimson::net::ConnectionRef conn) {
  37   return seastar::do_for_each(dispatchers, [conn](Dispatcher* dispatcher) {
  38     return dispatcher->ms_handle_remote_reset(conn);
  39   });
  40 }