blob: c30408361ba9be1e47ff4a32eb5cfa032c530974 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
// -*- 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 ceph::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(ceph::net::ConnectionRef conn, MessageRef m) override;
seastar::future<> ms_handle_accept(ceph::net::ConnectionRef conn) override;
seastar::future<> ms_handle_connect(ceph::net::ConnectionRef conn) override;
seastar::future<> ms_handle_reset(ceph::net::ConnectionRef conn) override;
seastar::future<> ms_handle_remote_reset(ceph::net::ConnectionRef conn) override;
seastar::future<std::unique_ptr<AuthAuthorizer>>
ms_get_authorizer(peer_type_t peer_type) override;
};
|
