Lines Matching refs:dconn_
197 if (dconn_) {
198 const auto &group = dconn_->get_downstream_addr_group();
208 dconn_.reset();
231 dconn_ = std::move(dconn);
237 if (!dconn_) {
242 const auto &group = dconn_->get_downstream_addr_group();
249 dconn_->detach_downstream(this);
251 auto handler = dconn_->get_client_handler();
254 std::unique_ptr<DownstreamConnection>(dconn_.release()));
258 return dconn_.get();
263 if (!dconn_) {
267 const auto &group = dconn_->get_downstream_addr_group();
274 return std::unique_ptr<DownstreamConnection>(dconn_.release());
278 if (dconn_) {
279 dconn_->pause_read(reason);
284 if (dconn_) {
285 return dconn_->resume_read(reason, consumed);
292 if (dconn_) {
293 dconn_->force_resume_read();
611 if (dconn_) {
612 dconn_->on_upstream_change(upstream);
642 if (dconn_) {
656 if (!dconn_) {
657 DLOG(INFO, this) << "dconn_ is NULL";
660 return dconn_->push_request_headers();
666 if (!dconn_ && !request_header_sent_) {
674 if (!dconn_) {
675 DLOG(INFO, this) << "dconn_ is NULL";
678 if (dconn_->push_upload_data_chunk(data, datalen) != 0) {
688 if (!dconn_ && !request_header_sent_) {
692 if (!dconn_) {
693 DLOG(INFO, this) << "dconn_ is NULL";
696 return dconn_->end_upload_data();
732 if (!dconn_) {
733 DLOG(INFO, this) << "dconn_ is NULL";
736 return dconn_->on_read();
750 if (dconn_) {
1115 return dconn_ && response_state_ == DownstreamState::MSG_COMPLETE &&