Index: net/http2/decoder/payload_decoders/goaway_payload_decoder.cc |
diff --git a/net/http2/decoder/payload_decoders/goaway_payload_decoder.cc b/net/http2/decoder/payload_decoders/goaway_payload_decoder.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..f5b597f0e5a847316d97fa0763a19b7c2b6f5c5a |
--- /dev/null |
+++ b/net/http2/decoder/payload_decoders/goaway_payload_decoder.cc |
@@ -0,0 +1,118 @@ |
+// Copyright 2016 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+ |
+#include "net/http2/decoder/payload_decoders/goaway_payload_decoder.h" |
+ |
+#include <stddef.h> |
+ |
+#include "base/logging.h" |
+#include "base/macros.h" |
+#include "net/http2/decoder/decode_buffer.h" |
+#include "net/http2/decoder/http2_frame_decoder_listener.h" |
+#include "net/http2/http2_constants.h" |
+#include "net/http2/http2_structures.h" |
+#include "net/http2/tools/http2_bug_tracker.h" |
+ |
+namespace net { |
+ |
+std::ostream& operator<<(std::ostream& out, |
+ GoAwayPayloadDecoder::PayloadState v) { |
+ switch (v) { |
+ case GoAwayPayloadDecoder::PayloadState::kStartDecodingFixedFields: |
+ return out << "kStartDecodingFixedFields"; |
+ case GoAwayPayloadDecoder::PayloadState::kHandleFixedFieldsStatus: |
+ return out << "kHandleFixedFieldsStatus"; |
+ case GoAwayPayloadDecoder::PayloadState::kReadOpaqueData: |
+ return out << "kReadOpaqueData"; |
+ case GoAwayPayloadDecoder::PayloadState::kResumeDecodingFixedFields: |
+ return out << "kResumeDecodingFixedFields"; |
+ } |
+ |
+ NOTREACHED(); |
+ return out; |
+} |
+ |
+DecodeStatus GoAwayPayloadDecoder::StartDecodingPayload( |
+ FrameDecoderState* state, |
+ DecodeBuffer* db) { |
+ DVLOG(2) << "GoAwayPayloadDecoder::StartDecodingPayload: " |
+ << state->frame_header(); |
+ DCHECK_EQ(Http2FrameType::GOAWAY, state->frame_header().type); |
+ DCHECK_LE(db->Remaining(), state->frame_header().payload_length); |
+ DCHECK_EQ(0, state->frame_header().flags); |
+ |
+ state->InitializeRemainders(); |
+ payload_state_ = PayloadState::kStartDecodingFixedFields; |
+ return ResumeDecodingPayload(state, db); |
+} |
+ |
+DecodeStatus GoAwayPayloadDecoder::ResumeDecodingPayload( |
+ FrameDecoderState* state, |
+ DecodeBuffer* db) { |
+ DVLOG(2) << "GoAwayPayloadDecoder::ResumeDecodingPayload: remaining_payload=" |
+ << state->remaining_payload() |
+ << ", db->Remaining=" << db->Remaining(); |
+ |
+ const Http2FrameHeader& frame_header = state->frame_header(); |
+ DCHECK_EQ(Http2FrameType::GOAWAY, frame_header.type); |
+ DCHECK_LE(db->Remaining(), frame_header.payload_length); |
+ DCHECK_NE(PayloadState::kHandleFixedFieldsStatus, payload_state_); |
+ |
+ // |status| has to be initialized to some value to avoid compiler error in |
+ // case PayloadState::kHandleFixedFieldsStatus below, but value does not |
+ // matter, see DCHECK_NE above. |
+ DecodeStatus status = DecodeStatus::kDecodeError; |
+ size_t avail; |
+ while (true) { |
+ DVLOG(2) << "GoAwayPayloadDecoder::ResumeDecodingPayload payload_state_=" |
+ << payload_state_; |
+ switch (payload_state_) { |
+ case PayloadState::kStartDecodingFixedFields: |
+ status = state->StartDecodingStructureInPayload(&goaway_fields_, db); |
+ // FALLTHROUGH_INTENDED |
+ |
+ case PayloadState::kHandleFixedFieldsStatus: |
+ if (status == DecodeStatus::kDecodeDone) { |
+ state->listener()->OnGoAwayStart(frame_header, goaway_fields_); |
+ } else { |
+ // Not done decoding the structure. Either we've got more payload |
+ // to decode, or we've run out because the payload is too short, |
+ // in which case OnFrameSizeError will have already been called. |
+ DCHECK((status == DecodeStatus::kDecodeInProgress && |
+ state->remaining_payload() > 0) || |
+ (status == DecodeStatus::kDecodeError && |
+ state->remaining_payload() == 0)) |
+ << "\n status=" << status |
+ << "; remaining_payload=" << state->remaining_payload(); |
+ payload_state_ = PayloadState::kResumeDecodingFixedFields; |
+ return status; |
+ } |
+ // FALLTHROUGH_INTENDED |
+ |
+ case PayloadState::kReadOpaqueData: |
+ // The opaque data is all the remains to be decoded, so anything left |
+ // in the decode buffer is opaque data. |
+ avail = db->Remaining(); |
+ if (avail > 0) { |
+ state->listener()->OnGoAwayOpaqueData(db->cursor(), avail); |
+ db->AdvanceCursor(avail); |
+ state->ConsumePayload(avail); |
+ } |
+ if (state->remaining_payload() > 0) { |
+ payload_state_ = PayloadState::kReadOpaqueData; |
+ return DecodeStatus::kDecodeInProgress; |
+ } |
+ state->listener()->OnGoAwayEnd(); |
+ return DecodeStatus::kDecodeDone; |
+ |
+ case PayloadState::kResumeDecodingFixedFields: |
+ status = state->ResumeDecodingStructureInPayload(&goaway_fields_, db); |
+ payload_state_ = PayloadState::kHandleFixedFieldsStatus; |
+ continue; |
+ } |
+ HTTP2_BUG << "PayloadState: " << payload_state_; |
+ } |
+} |
+ |
+} // namespace net |