chromium/net/third_party/quiche/src/quiche/http2/adapter/oghttp2_adapter.cc

#include "quiche/http2/adapter/oghttp2_adapter.h"

#include <memory>
#include <string>
#include <utility>

#include "absl/memory/memory.h"
#include "absl/strings/str_cat.h"
#include "quiche/http2/adapter/http2_util.h"
#include "quiche/common/platform/api/quiche_bug_tracker.h"
#include "quiche/spdy/core/spdy_protocol.h"

namespace http2 {
namespace adapter {

namespace {

SpdyGoAwayIR;
SpdyPingIR;
SpdyPriorityIR;
SpdyWindowUpdateIR;

}  // namespace

/* static */
std::unique_ptr<OgHttp2Adapter> OgHttp2Adapter::Create(
    Http2VisitorInterface& visitor, Options options) { … }

OgHttp2Adapter::~OgHttp2Adapter() { … }

bool OgHttp2Adapter::IsServerSession() const { … }

int64_t OgHttp2Adapter::ProcessBytes(absl::string_view bytes) { … }

void OgHttp2Adapter::SubmitSettings(absl::Span<const Http2Setting> settings) { … }

void OgHttp2Adapter::SubmitPriorityForStream(Http2StreamId stream_id,
                                             Http2StreamId parent_stream_id,
                                             int weight, bool exclusive) { … }

void OgHttp2Adapter::SubmitPing(Http2PingId ping_id) { … }

void OgHttp2Adapter::SubmitShutdownNotice() { … }

void OgHttp2Adapter::SubmitGoAway(Http2StreamId last_accepted_stream_id,
                                  Http2ErrorCode error_code,
                                  absl::string_view opaque_data) { … }
void OgHttp2Adapter::SubmitWindowUpdate(Http2StreamId stream_id,
                                        int window_increment) { … }

void OgHttp2Adapter::SubmitMetadata(Http2StreamId stream_id,
                                    size_t /* max_frame_size */,
                                    std::unique_ptr<MetadataSource> source) { … }

void OgHttp2Adapter::SubmitMetadata(Http2StreamId stream_id,
                                    size_t /* num_frames */) { … }

int OgHttp2Adapter::Send() { … }

int OgHttp2Adapter::GetSendWindowSize() const { … }

int OgHttp2Adapter::GetStreamSendWindowSize(Http2StreamId stream_id) const { … }

int OgHttp2Adapter::GetStreamReceiveWindowLimit(Http2StreamId stream_id) const { … }

int OgHttp2Adapter::GetStreamReceiveWindowSize(Http2StreamId stream_id) const { … }

int OgHttp2Adapter::GetReceiveWindowSize() const { … }

int OgHttp2Adapter::GetHpackEncoderDynamicTableSize() const { … }

int OgHttp2Adapter::GetHpackEncoderDynamicTableCapacity() const { … }

int OgHttp2Adapter::GetHpackDecoderDynamicTableSize() const { … }

int OgHttp2Adapter::GetHpackDecoderSizeLimit() const { … }

Http2StreamId OgHttp2Adapter::GetHighestReceivedStreamId() const { … }

void OgHttp2Adapter::MarkDataConsumedForStream(Http2StreamId stream_id,
                                               size_t num_bytes) { … }

void OgHttp2Adapter::SubmitRst(Http2StreamId stream_id,
                               Http2ErrorCode error_code) { … }

int32_t OgHttp2Adapter::SubmitRequest(
    absl::Span<const Header> headers,
    std::unique_ptr<DataFrameSource> data_source, bool end_stream,
    void* user_data) { … }

int OgHttp2Adapter::SubmitResponse(Http2StreamId stream_id,
                                   absl::Span<const Header> headers,
                                   std::unique_ptr<DataFrameSource> data_source,
                                   bool end_stream) { … }

int OgHttp2Adapter::SubmitTrailer(Http2StreamId stream_id,
                                  absl::Span<const Header> trailers) { … }

void OgHttp2Adapter::SetStreamUserData(Http2StreamId stream_id,
                                       void* user_data) { … }

void* OgHttp2Adapter::GetStreamUserData(Http2StreamId stream_id) { … }

bool OgHttp2Adapter::ResumeStream(Http2StreamId stream_id) { … }

OgHttp2Adapter::OgHttp2Adapter(Http2VisitorInterface& visitor, Options options)
    : … { … }

}  // namespace adapter
}  // namespace http2