| Index: net/http2/hpack/decoder/hpack_entry_decoder.h
 | 
| diff --git a/net/http2/hpack/decoder/hpack_entry_decoder.h b/net/http2/hpack/decoder/hpack_entry_decoder.h
 | 
| new file mode 100644
 | 
| index 0000000000000000000000000000000000000000..9b5f696f83e397a0cc0df814a24cb62784265216
 | 
| --- /dev/null
 | 
| +++ b/net/http2/hpack/decoder/hpack_entry_decoder.h
 | 
| @@ -0,0 +1,117 @@
 | 
| +// 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.
 | 
| +
 | 
| +#ifndef NET_HTTP2_HPACK_DECODER_HPACK_ENTRY_DECODER_H_
 | 
| +#define NET_HTTP2_HPACK_DECODER_HPACK_ENTRY_DECODER_H_
 | 
| +
 | 
| +// HpackEntryDecoder decodes a single HPACK entry (i.e. one header or one
 | 
| +// dynamic table size update), in a resumable fashion. The first call, Start(),
 | 
| +// must provide a non-empty decode buffer. Continue with calls to Resume() if
 | 
| +// Start, and any subsequent calls to Resume, returns kDecodeInProgress.
 | 
| +
 | 
| +#include <string>
 | 
| +
 | 
| +#include "base/logging.h"
 | 
| +#include "net/base/net_export.h"
 | 
| +#include "net/http2/decoder/decode_buffer.h"
 | 
| +#include "net/http2/decoder/decode_status.h"
 | 
| +#include "net/http2/hpack/decoder/hpack_entry_decoder_listener.h"
 | 
| +#include "net/http2/hpack/decoder/hpack_entry_type_decoder.h"
 | 
| +#include "net/http2/hpack/decoder/hpack_string_decoder.h"
 | 
| +#include "net/http2/hpack/http2_hpack_constants.h"
 | 
| +
 | 
| +namespace net {
 | 
| +
 | 
| +class NET_EXPORT_PRIVATE HpackEntryDecoder {
 | 
| + public:
 | 
| +  enum class EntryDecoderState {
 | 
| +    // Have started decoding the type/varint, but didn't finish on the previous
 | 
| +    // attempt.  Next state is kResumeDecodingType or kDecodedType.
 | 
| +    kResumeDecodingType,
 | 
| +
 | 
| +    // Have just finished decoding the type/varint. Final state if the type is
 | 
| +    // kIndexedHeader or kDynamicTableSizeUpdate. Otherwise, the next state is
 | 
| +    // kStartDecodingName (if the varint is 0), else kStartDecodingValue.
 | 
| +    kDecodedType,
 | 
| +
 | 
| +    // Ready to start decoding the literal name of a header entry. Next state
 | 
| +    // is kResumeDecodingName (if the name is split across decode buffers),
 | 
| +    // else kStartDecodingValue.
 | 
| +    kStartDecodingName,
 | 
| +
 | 
| +    // Resume decoding the literal name of a header that is split across decode
 | 
| +    // buffers.
 | 
| +    kResumeDecodingName,
 | 
| +
 | 
| +    // Ready to start decoding the literal value of a header entry. Final state
 | 
| +    // if the value string is entirely in the decode buffer, else the next state
 | 
| +    // is kResumeDecodingValue.
 | 
| +    kStartDecodingValue,
 | 
| +
 | 
| +    // Resume decoding the literal value of a header that is split across decode
 | 
| +    // buffers.
 | 
| +    kResumeDecodingValue,
 | 
| +  };
 | 
| +
 | 
| +  // Only call when the decode buffer has data (i.e. HpackBlockDecoder must
 | 
| +  // not call until there is data).
 | 
| +  DecodeStatus Start(DecodeBuffer* db, HpackEntryDecoderListener* listener) {
 | 
| +    DCHECK(db != nullptr);
 | 
| +    DCHECK(listener != nullptr);
 | 
| +    DCHECK(db->HasData());
 | 
| +    DecodeStatus status = entry_type_decoder_.Start(db);
 | 
| +    switch (status) {
 | 
| +      case DecodeStatus::kDecodeDone:
 | 
| +        // The type of the entry and its varint fit into the current decode
 | 
| +        // buffer.
 | 
| +        if (entry_type_decoder_.entry_type() ==
 | 
| +            HpackEntryType::kIndexedHeader) {
 | 
| +          // The entry consists solely of the entry type and varint. This
 | 
| +          // is by far the most common case in practice.
 | 
| +          listener->OnIndexedHeader(entry_type_decoder_.varint());
 | 
| +          return DecodeStatus::kDecodeDone;
 | 
| +        }
 | 
| +        state_ = EntryDecoderState::kDecodedType;
 | 
| +        return Resume(db, listener);
 | 
| +      case DecodeStatus::kDecodeInProgress:
 | 
| +        // Hit the end of the decode buffer before fully decoding the entry
 | 
| +        // type and varint.
 | 
| +        DCHECK_EQ(0u, db->Remaining());
 | 
| +        state_ = EntryDecoderState::kResumeDecodingType;
 | 
| +        return status;
 | 
| +      case DecodeStatus::kDecodeError:
 | 
| +        // The varint must have been invalid (too long).
 | 
| +        return status;
 | 
| +    }
 | 
| +
 | 
| +    NOTREACHED();
 | 
| +    return DecodeStatus::kDecodeError;
 | 
| +  }
 | 
| +
 | 
| +  // Only call Resume if the previous call (Start or Resume) returned
 | 
| +  // kDecodeInProgress; Resume is also called from Start when it has succeeded
 | 
| +  // in decoding the entry type and its varint.
 | 
| +  DecodeStatus Resume(DecodeBuffer* db, HpackEntryDecoderListener* listener);
 | 
| +
 | 
| +  std::string DebugString() const;
 | 
| +  void OutputDebugString(std::ostream& out) const;
 | 
| +
 | 
| + private:
 | 
| +  // Implements handling state kDecodedType.
 | 
| +  bool DispatchOnType(HpackEntryDecoderListener* listener);
 | 
| +
 | 
| +  HpackEntryTypeDecoder entry_type_decoder_;
 | 
| +  HpackStringDecoder string_decoder_;
 | 
| +  EntryDecoderState state_ = EntryDecoderState();
 | 
| +};
 | 
| +
 | 
| +NET_EXPORT_PRIVATE std::ostream& operator<<(std::ostream& out,
 | 
| +                                            const HpackEntryDecoder& v);
 | 
| +NET_EXPORT_PRIVATE std::ostream& operator<<(
 | 
| +    std::ostream& out,
 | 
| +    HpackEntryDecoder::EntryDecoderState state);
 | 
| +
 | 
| +}  // namespace net
 | 
| +
 | 
| +#endif  // NET_HTTP2_HPACK_DECODER_HPACK_ENTRY_DECODER_H_
 | 
| 
 |