Lines Matching refs:Downstream
114 std::make_unique<Downstream>(this, handler_->get_mcpool(), 0);
651 ULOG(INFO, this) << "Downstream request buf is full";
755 ULOG(INFO, this) << "Downstream request buffer is full";
827 int HttpsUpstream::resume_read(IOCtrlReason reason, Downstream *downstream,
865 return downstream_error(dconn, Downstream::EVENT_ERROR);
893 return downstream_error(dconn, Downstream::EVENT_ERROR);
949 if (events & Downstream::EVENT_ERROR) {
960 if (events & Downstream::EVENT_TIMEOUT) {
977 int HttpsUpstream::send_reply(Downstream *downstream, const uint8_t *body,
1056 std::make_unique<Downstream>(this, handler_->get_mcpool(), 1));
1095 void HttpsUpstream::attach_downstream(std::unique_ptr<Downstream> downstream) {
1108 Downstream *HttpsUpstream::get_downstream() const { return downstream_.get(); }
1110 std::unique_ptr<Downstream> HttpsUpstream::pop_downstream() {
1111 return std::unique_ptr<Downstream>(downstream_.release());
1114 int HttpsUpstream::on_downstream_header_complete(Downstream *downstream) {
1342 int HttpsUpstream::on_downstream_body(Downstream *downstream,
1363 int HttpsUpstream::on_downstream_body_complete(Downstream *downstream) {
1396 int HttpsUpstream::on_downstream_abort_request(Downstream *downstream,
1404 Downstream *downstream) {
1410 int HttpsUpstream::redirect_to_https(Downstream *downstream) {
1466 int HttpsUpstream::on_downstream_reset(Downstream *downstream, bool no_retry) {
1532 int HttpsUpstream::initiate_push(Downstream *downstream, const StringRef &uri) {
1566 Downstream *
1567 HttpsUpstream::on_downstream_push_promise(Downstream *downstream,
1573 Downstream *downstream, Downstream *promised_downstream) {
1580 Downstream *promised_downstream) {}