51 : buffer_m0_(configs[0].channel_id,
52 new BufferType<M0>(configs[0].queue_size)),
53 buffer_m1_(configs[1].channel_id,
54 new BufferType<M1>(configs[1].queue_size)),
55 buffer_m2_(configs[2].channel_id,
56 new BufferType<M2>(configs[2].queue_size)),
57 buffer_m3_(configs[3].channel_id,
58 new BufferType<M3>(configs[3].queue_size)) {
59 DataDispatcher<M0>::Instance()->AddBuffer(buffer_m0_);
60 DataDispatcher<M1>::Instance()->AddBuffer(buffer_m1_);
61 DataDispatcher<M2>::Instance()->AddBuffer(buffer_m2_);
62 DataDispatcher<M3>::Instance()->AddBuffer(buffer_m3_);
64 data_fusion_ = new fusion::AllLatest<M0, M1, M2, M3>(
65 buffer_m0_, buffer_m1_, buffer_m2_, buffer_m3_);
66 }
uint64_t channel_id() const
void AddNotifier(uint64_t channel_id, const std::shared_ptr< Notifier > ¬ifier)
std::shared_ptr< Notifier > notifier_
DataNotifier * data_notifier_