import 15.2.0 Octopus source

[ceph.git] / ceph / src / crimson / osd / chained_dispatchers.h

// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:nil -*- 
// vim: ts=8 sw=2 smarttab

#pragma once

#include <deque>
#include "crimson/net/Dispatcher.h"

// in existing Messenger, dispatchers are put into a chain as described by
// chain-of-responsibility pattern. we could do the same to stop processing
// the message once any of the dispatchers claims this message, and prevent
// other dispatchers from reading it. but this change is more involved as
// it requires changing the ms_ methods to return a bool. so as an intermediate 
// solution, we are using an observer dispatcher to notify all the interested
// or unintersted parties.
class ChainedDispatchers : public crimson::net::Dispatcher {
  std::deque<Dispatcher*> dispatchers;
public:
  void push_front(Dispatcher* dispatcher) {
    dispatchers.push_front(dispatcher);
  }
  void push_back(Dispatcher* dispatcher) {
    dispatchers.push_back(dispatcher);
  }
  seastar::future<> ms_dispatch(crimson::net::Connection* conn, MessageRef m) override;
  seastar::future<> ms_handle_accept(crimson::net::ConnectionRef conn) override;
  seastar::future<> ms_handle_connect(crimson::net::ConnectionRef conn) override;
  seastar::future<> ms_handle_reset(crimson::net::ConnectionRef conn) override;
  seastar::future<> ms_handle_remote_reset(crimson::net::ConnectionRef conn) override;
};