Signed-off-by: Yingxin Cheng <yingxin.cheng@intel.com>
// wait for messenger shutdown
virtual seastar::future<> wait() = 0;
- virtual void add_dispatcher(Dispatcher&) = 0;
-
virtual void remove_dispatcher(Dispatcher&) = 0;
virtual bool dispatcher_chain_empty() const = 0;
uint32_t min_port, uint32_t max_port) override;
seastar::future<> start(ChainedDispatchersRef dispatchers) override;
- void add_dispatcher(Dispatcher& disp) {
- dispatchers->push_back(disp);
- }
ConnectionRef connect(const entity_addr_t& peer_addr,
const entity_name_t& peer_name) override;