blob: 1f32cfc6ddd1b830fc63d4cf73e6733606f1d99c [file] [log] [blame]
#ifndef QUICHE_HTTP2_ADAPTER_OGHTTP2_ADAPTER_H_
#define QUICHE_HTTP2_ADAPTER_OGHTTP2_ADAPTER_H_
#include <memory>
#include "http2/adapter/http2_adapter.h"
#include "http2/adapter/http2_session.h"
namespace http2 {
namespace adapter {
class OgHttp2Adapter : public Http2Adapter {
public:
struct Options {
Perspective context;
};
static std::unique_ptr<OgHttp2Adapter> Create(Http2VisitorInterface& visitor,
Options options);
~OgHttp2Adapter();
// From Http2Adapter.
ssize_t ProcessBytes(absl::string_view bytes) override;
void SubmitSettings(absl::Span<const Http2Setting> settings) override;
void SubmitPriorityForStream(Http2StreamId stream_id,
Http2StreamId parent_stream_id,
int weight,
bool exclusive) override;
void SubmitPing(Http2PingId ping_id) override;
void SubmitGoAway(Http2StreamId last_accepted_stream_id,
Http2ErrorCode error_code,
absl::string_view opaque_data) override;
void SubmitWindowUpdate(Http2StreamId stream_id,
int window_increment) override;
void SubmitMetadata(Http2StreamId stream_id, bool fin) override;
std::string GetBytesToWrite(absl::optional<size_t> max_bytes) override;
int GetPeerConnectionWindow() const override;
void MarkDataConsumedForStream(Http2StreamId stream_id,
size_t num_bytes) override;
const Http2Session& session() const;
private:
OgHttp2Adapter(Http2VisitorInterface& visitor, Options options);
class OgHttp2Session;
std::unique_ptr<OgHttp2Session> session_;
};
} // namespace adapter
} // namespace http2
#endif // QUICHE_HTTP2_ADAPTER_OGHTTP2_ADAPTER_H_