Searched refs:read_cb_ (Results 1 – 9 of 9) sorted by relevance
66 if (read_cb_ == nullptr) { in PushInput()73 grpc_core::ExecCtx::Run(DEBUG_LOCATION, read_cb_, absl::OkStatus()); in PushInput()74 read_cb_ = nullptr; in PushInput()78 grpc_closure* read_cb_ = nullptr; member in PhonyEndpoint84 GPR_ASSERT(read_cb_ == nullptr); in QueueRead()91 read_cb_ = cb; in QueueRead()117 static_cast<PhonyEndpoint*>(ep)->read_cb_, why); in shutdown()
146 read_cb_(read_cb), in SincResampler()262 read_cb_->Run(request_frames_, r0_); in Resample()328 read_cb_->Run(request_frames_, r0_); in Resample()
139 SincResamplerCallback* read_cb_; variable
570 absl::AnyInvocable<void(absl::Status)> cb = std::move(read_cb_); in HandleRead()571 read_cb_ = nullptr; in HandleRead()582 GPR_ASSERT(read_cb_ == nullptr); in Read()593 read_cb_ = std::move(on_read); in Read()601 read_cb_ = std::move(on_read); in Read()612 read_cb_ = std::move(on_read); in Read()
563 absl::AnyInvocable<void(absl::Status)> read_cb_ ABSL_GUARDED_BY(read_mu_);
581 cb = std::move(read_cb_); in HandleRead()582 read_cb_ = nullptr; in HandleRead()599 GPR_ASSERT(read_cb_ == nullptr); in Read()610 read_cb_ = std::move(on_read); in Read()618 read_cb_ = std::move(on_read); in Read()629 read_cb_ = std::move(on_read); in Read()
565 absl::AnyInvocable<void(absl::Status)> read_cb_ ABSL_GUARDED_BY(read_mu_);
580 if (read_cb_) { in Read()588 read_cb_ = std::move(callback); in Read()632 if (!read_cb_) { in TryRead()649 read_cb_( in TryRead()
212 read_cb_; variable