| Index: net/tools/quic/quic_client_session.cc
|
| diff --git a/net/tools/quic/quic_client_session.cc b/net/tools/quic/quic_client_session.cc
|
| index a7408da68946cd7ca14608919414005dad5812aa..d1808d729767396370277f69f5a84898bbcf16c5 100644
|
| --- a/net/tools/quic/quic_client_session.cc
|
| +++ b/net/tools/quic/quic_client_session.cc
|
| @@ -8,7 +8,6 @@
|
| #include "net/quic/chromium/crypto/proof_verifier_chromium.h"
|
| #include "net/quic/core/crypto/crypto_protocol.h"
|
| #include "net/quic/core/quic_server_id.h"
|
| -#include "net/quic/core/spdy_utils.h"
|
| #include "net/quic/platform/api/quic_bug_tracker.h"
|
| #include "net/quic/platform/api/quic_logging.h"
|
| #include "net/quic/platform/api/quic_ptr_util.h"
|
| @@ -26,7 +25,8 @@
|
| QuicClientPushPromiseIndex* push_promise_index)
|
| : QuicClientSessionBase(connection, push_promise_index, config),
|
| server_id_(server_id),
|
| - crypto_config_(crypto_config) {}
|
| + crypto_config_(crypto_config),
|
| + respect_goaway_(true) {}
|
|
|
| QuicClientSession::~QuicClientSession() {}
|
|
|
| @@ -42,7 +42,6 @@
|
| const ProofVerifyDetails& /*verify_details*/) {}
|
|
|
| bool QuicClientSession::ShouldCreateOutgoingDynamicStream() {
|
| - DCHECK(!FLAGS_quic_reloadable_flag_quic_refactor_stream_creation);
|
| if (!crypto_stream_->encryption_established()) {
|
| QUIC_DLOG(INFO) << "Encryption not active so no outgoing stream created.";
|
| return false;
|
| @@ -52,7 +51,7 @@
|
| << "Already " << GetNumOpenOutgoingStreams() << " open.";
|
| return false;
|
| }
|
| - if (goaway_received() && respect_goaway()) {
|
| + if (goaway_received() && respect_goaway_) {
|
| QUIC_DLOG(INFO) << "Failed to create a new outgoing stream. "
|
| << "Already received goaway.";
|
| return false;
|
| @@ -98,12 +97,11 @@
|
| }
|
|
|
| bool QuicClientSession::ShouldCreateIncomingDynamicStream(QuicStreamId id) {
|
| - DCHECK(!FLAGS_quic_reloadable_flag_quic_refactor_stream_creation);
|
| if (!connection()->connected()) {
|
| QUIC_BUG << "ShouldCreateIncomingDynamicStream called when disconnected";
|
| return false;
|
| }
|
| - if (goaway_received() && respect_goaway()) {
|
| + if (goaway_received() && respect_goaway_) {
|
| QUIC_DLOG(INFO) << "Failed to create a new outgoing stream. "
|
| << "Already received goaway.";
|
| return false;
|
| @@ -140,25 +138,4 @@
|
| return true;
|
| }
|
|
|
| -QuicSpdyClientStream* QuicClientSession::MaybeCreateOutgoingDynamicStream(
|
| - SpdyPriority priority) {
|
| - return static_cast<QuicSpdyClientStream*>(
|
| - QuicSpdySession::MaybeCreateOutgoingDynamicStream(priority));
|
| -}
|
| -
|
| -QuicSpdyStream* QuicClientSession::MaybeCreateIncomingDynamicStream(
|
| - QuicStreamId id) {
|
| - QuicSpdyStream* stream =
|
| - QuicSpdySession::MaybeCreateIncomingDynamicStream(id);
|
| - if (stream) {
|
| - // Push streams start half-closed.
|
| - stream->CloseWriteSide();
|
| - }
|
| - return stream;
|
| -}
|
| -
|
| -std::unique_ptr<QuicStream> QuicClientSession::CreateStream(QuicStreamId id) {
|
| - return QuicMakeUnique<QuicSpdyClientStream>(id, this);
|
| -}
|
| -
|
| } // namespace net
|
|
|