Searched refs:multisink_ (Results 1 – 4 of 4) sorted by relevance
30 MultiSinkTest() : multisink_(buffer_) {} in MultiSinkTest()52 MultiSink multisink_; member in pw::multisink::MultiSinkTest56 EXPECT_EQ(OkStatus(), multisink_.AttachDrain(drains_[0])); in TEST_F()57 EXPECT_EQ(OkStatus(), multisink_.HandleEntry(kMessage)); in TEST_F()63 EXPECT_EQ(OkStatus(), multisink_.HandleEntry(kMessage)); in TEST_F()64 multisink_.HandleDropped(); in TEST_F()65 EXPECT_EQ(OkStatus(), multisink_.HandleEntry(kMessage)); in TEST_F()70 multisink_.HandleDropped(); in TEST_F()78 EXPECT_EQ(OkStatus(), multisink_.AttachDrain(drains_[0])); in TEST_F()79 EXPECT_EQ(OkStatus(), multisink_.AttachDrain(drains_[1])); in TEST_F()[all …]
32 if (drain.multisink_ == nullptr) { in GetEntry()41 sequence_id_out = drain.multisink_->sequence_id_ - 1; in GetEntry()49 PW_DCHECK(drain.multisink_ == nullptr); in AttachDrain()50 drain.multisink_ = this; in AttachDrain()56 PW_DCHECK(drain.multisink_ == this); in DetachDrain()57 drain.multisink_ = nullptr; in DetachDrain()
24 MultiSinkAdapter(multisink::MultiSink& multisink) : multisink_(multisink) {} in MultiSinkAdapter()30 multisink_.HandleEntry(entry); in HandleEntry()37 multisink_.HandleDropped(drop_count); in HandleDropped()41 multisink::MultiSink& multisink_;
27 constexpr Drain() : last_handled_sequence_id_(0), multisink_(nullptr) {} in Drain()61 MultiSink* multisink_; variable