Lines Matching refs:MSG_COMPLETE
190 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) {
315 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) {
445 downstream->set_request_state(DownstreamState::MSG_COMPLETE);
448 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) {
514 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) {
566 if (downstream->get_response_state() != DownstreamState::MSG_COMPLETE) {
571 downstream->set_request_state(DownstreamState::MSG_COMPLETE);
595 if (downstream->get_response_state() != DownstreamState::MSG_COMPLETE) {
600 downstream->set_request_state(DownstreamState::MSG_COMPLETE);
647 if (downstream->get_response_state() != DownstreamState::MSG_COMPLETE) {
767 promised_downstream->set_request_state(DownstreamState::MSG_COMPLETE);
1337 downstream->set_response_state(DownstreamState::MSG_COMPLETE);
1339 // For tunneled connection, MSG_COMPLETE signals
1345 DownstreamState::MSG_COMPLETE) {
1346 // If stream was not closed, then we set MSG_COMPLETE and let
1377 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) {
1406 downstream->set_response_state(DownstreamState::MSG_COMPLETE);
1473 downstream->get_response_state() == DownstreamState::MSG_COMPLETE) {
1570 downstream->set_response_state(DownstreamState::MSG_COMPLETE);
1590 downstream->set_response_state(DownstreamState::MSG_COMPLETE);
1688 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) {
1704 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) {
2074 if (downstream->get_response_state() == DownstreamState::MSG_COMPLETE) {