Lines Matching refs:ConsumerChannel
21 ConsumerChannel::ConsumerChannel(BufferHubService* service, int buffer_id,
31 ConsumerChannel::~ConsumerChannel() {
33 "ConsumerChannel::~ConsumerChannel: channel_id=%d buffer_id=%d",
43 BufferHubChannel::BufferInfo ConsumerChannel::GetBufferInfo() const {
53 std::shared_ptr<ProducerChannel> ConsumerChannel::GetProducer() const {
57 void ConsumerChannel::HandleImpulse(Message& message) {
58 ATRACE_NAME("ConsumerChannel::HandleImpulse");
66 bool ConsumerChannel::HandleMessage(Message& message) {
67 ATRACE_NAME("ConsumerChannel::HandleMessage");
85 *this, &ConsumerChannel::OnConsumerAcquire, message);
90 *this, &ConsumerChannel::OnConsumerRelease, message);
95 *this, &ConsumerChannel::OnConsumerSetIgnore, message);
103 Status<std::pair<BorrowedFence, ConsumerChannel::MetaData>>
104 ConsumerChannel::OnConsumerAcquire(Message& message,
106 ATRACE_NAME("ConsumerChannel::OnConsumerAcquire");
113 "ConsumerChannel::OnConsumerAcquire: Acquire when not posted: "
123 Status<void> ConsumerChannel::OnConsumerRelease(Message& message,
125 ATRACE_NAME("ConsumerChannel::OnConsumerRelease");
132 "ConsumerChannel::OnConsumerRelease: Release when not acquired: "
145 Status<void> ConsumerChannel::OnConsumerSetIgnore(Message&, bool ignored) {
146 ATRACE_NAME("ConsumerChannel::OnConsumerSetIgnore");
163 bool ConsumerChannel::OnProducerPosted() {
174 void ConsumerChannel::OnProducerClosed() {
