| Index: net/http2/hpack/decoder/hpack_block_decoder.cc
 | 
| diff --git a/net/http2/hpack/decoder/hpack_block_decoder.cc b/net/http2/hpack/decoder/hpack_block_decoder.cc
 | 
| new file mode 100644
 | 
| index 0000000000000000000000000000000000000000..29b68691b1bbf940fa35021be8ef54bae8b80cbf
 | 
| --- /dev/null
 | 
| +++ b/net/http2/hpack/decoder/hpack_block_decoder.cc
 | 
| @@ -0,0 +1,65 @@
 | 
| +// 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/hpack/decoder/hpack_block_decoder.h"
 | 
| +
 | 
| +#include <stdint.h>
 | 
| +
 | 
| +#include <sstream>
 | 
| +#include <string>
 | 
| +
 | 
| +#include "base/logging.h"
 | 
| +
 | 
| +namespace net {
 | 
| +
 | 
| +DecodeStatus HpackBlockDecoder::Decode(DecodeBuffer* db) {
 | 
| +  if (!before_entry_) {
 | 
| +    DVLOG(2) << "HpackBlockDecoder::Decode resume entry, db->Remaining="
 | 
| +             << db->Remaining();
 | 
| +    DecodeStatus status = entry_decoder_.Resume(db, listener_);
 | 
| +    switch (status) {
 | 
| +      case DecodeStatus::kDecodeDone:
 | 
| +        before_entry_ = true;
 | 
| +        break;
 | 
| +      case DecodeStatus::kDecodeInProgress:
 | 
| +        DCHECK_EQ(0u, db->Remaining());
 | 
| +        return DecodeStatus::kDecodeInProgress;
 | 
| +      case DecodeStatus::kDecodeError:
 | 
| +        return DecodeStatus::kDecodeError;
 | 
| +    }
 | 
| +  }
 | 
| +  DCHECK(before_entry_);
 | 
| +  while (db->HasData()) {
 | 
| +    DVLOG(2) << "HpackBlockDecoder::Decode start entry, db->Remaining="
 | 
| +             << db->Remaining();
 | 
| +    DecodeStatus status = entry_decoder_.Start(db, listener_);
 | 
| +    switch (status) {
 | 
| +      case DecodeStatus::kDecodeDone:
 | 
| +        continue;
 | 
| +      case DecodeStatus::kDecodeInProgress:
 | 
| +        DCHECK_EQ(0u, db->Remaining());
 | 
| +        before_entry_ = false;
 | 
| +        return DecodeStatus::kDecodeInProgress;
 | 
| +      case DecodeStatus::kDecodeError:
 | 
| +        return DecodeStatus::kDecodeError;
 | 
| +    }
 | 
| +    DCHECK(false);
 | 
| +  }
 | 
| +  DCHECK(before_entry_);
 | 
| +  return DecodeStatus::kDecodeDone;
 | 
| +}
 | 
| +
 | 
| +std::string HpackBlockDecoder::DebugString() const {
 | 
| +  std::stringstream ss;
 | 
| +  ss << "HpackBlockDecoder(" << entry_decoder_.DebugString() << ", listener@"
 | 
| +     << std::hex << reinterpret_cast<intptr_t>(listener_)
 | 
| +     << (before_entry_ ? ", between entries)" : ", in an entry)");
 | 
| +  return ss.str();
 | 
| +}
 | 
| +
 | 
| +std::ostream& operator<<(std::ostream& out, const HpackBlockDecoder& v) {
 | 
| +  return out << v.DebugString();
 | 
| +}
 | 
| +
 | 
| +}  // namespace net
 | 
| 
 |