Lines Matching refs:Http2Session
67 auto http2session = static_cast<Http2Session *>(w->data);
92 auto http2session = static_cast<Http2Session *>(w->data);
112 auto http2session = static_cast<Http2Session *>(conn->data);
132 auto http2session = static_cast<Http2Session *>(conn->data);
147 auto http2session = static_cast<Http2Session *>(conn->data);
160 auto http2session = static_cast<Http2Session *>(w->data);
176 auto http2session = static_cast<Http2Session *>(w->data);
181 Http2Session::Http2Session(struct ev_loop *loop, SSL_CTX *ssl_ctx,
204 read_ = write_ = &Http2Session::noop;
206 on_read_ = &Http2Session::read_noop;
207 on_write_ = &Http2Session::write_noop;
229 Http2Session::~Http2Session() {
234 int Http2Session::disconnect(bool hard) {
257 read_ = write_ = &Http2Session::noop;
259 on_read_ = &Http2Session::read_noop;
260 on_write_ = &Http2Session::write_noop;
279 // Http2DownstreamConnection to another Http2Session.
306 int Http2Session::resolve_name() {
371 int Http2Session::initiate_connection() {
432 write_ = &Http2Session::connected;
434 on_read_ = &Http2Session::downstream_read_proxy;
435 on_write_ = &Http2Session::downstream_connect_proxy;
615 on_read_ = &Http2Session::read_noop;
616 on_write_ = &Http2Session::write_noop;
621 write_ = &Http2Session::connected;
640 auto http2session = static_cast<Http2Session *>(htp->data);
663 int Http2Session::downstream_read_proxy(const uint8_t *data, size_t datalen) {
690 int Http2Session::downstream_connect_proxy() {
716 on_write_ = &Http2Session::write_noop;
722 void Http2Session::add_downstream_connection(Http2DownstreamConnection *dconn) {
727 void Http2Session::remove_downstream_connection(
748 void Http2Session::remove_stream_data(StreamData *sd) {
756 int Http2Session::submit_request(Http2DownstreamConnection *dconn,
778 int Http2Session::submit_rst_stream(int32_t stream_id, uint32_t error_code) {
794 nghttp2_session *Http2Session::get_session() const { return session_; }
796 int Http2Session::resume_data(Http2DownstreamConnection *dconn) {
813 void call_downstream_readcb(Http2Session *http2session,
828 auto http2session = static_cast<Http2Session *>(user_data);
889 void Http2Session::start_settings_timer() {
896 void Http2Session::stop_settings_timer() {
904 auto http2session = static_cast<Http2Session *>(user_data);
1014 auto http2session = static_cast<Http2Session *>(user_data);
1049 auto http2session = static_cast<Http2Session *>(user_data);
1095 int on_response_headers(Http2Session *http2session, Downstream *downstream,
1225 auto http2session = static_cast<Http2Session *>(user_data);
1408 auto http2session = static_cast<Http2Session *>(user_data);
1470 auto http2session = static_cast<Http2Session *>(user_data);
1517 auto http2session = static_cast<Http2Session *>(user_data);
1569 auto http2session = static_cast<Http2Session *>(user_data);
1663 int Http2Session::connection_made() {
1668 on_write_ = &Http2Session::downstream_write;
1669 on_read_ = &Http2Session::downstream_read;
1754 int Http2Session::do_read() { return read_(*this); }
1755 int Http2Session::do_write() { return write_(*this); }
1757 int Http2Session::on_read(const uint8_t *data, size_t datalen) {
1761 int Http2Session::on_write() { return on_write_(*this); }
1763 int Http2Session::downstream_read(const uint8_t *data, size_t datalen) {
1785 int Http2Session::downstream_write() {
1815 void Http2Session::signal_write() {
1837 struct ev_loop *Http2Session::get_loop() const {
1841 ev_io *Http2Session::get_wev() { return &conn_.wev; }
1843 Http2SessionState Http2Session::get_state() const { return state_; }
1845 void Http2Session::set_state(Http2SessionState state) { state_ = state; }
1847 int Http2Session::terminate_session(uint32_t error_code) {
1856 SSL *Http2Session::get_ssl() const { return conn_.tls.ssl; }
1858 int Http2Session::consume(int32_t stream_id, size_t len) {
1877 bool Http2Session::can_push_request(const Downstream *downstream) const {
1884 void Http2Session::start_checking_connection() {
1902 void Http2Session::reset_connection_check_timer(ev_tstamp t) {
1907 void Http2Session::reset_connection_check_timer_if_not_checking() {
1915 void Http2Session::connection_alive() {
1931 void Http2Session::submit_pending_requests() {
1961 void Http2Session::set_connection_check_state(ConnectionCheck state) {
1965 ConnectionCheck Http2Session::get_connection_check_state() const {
1969 int Http2Session::noop() { return 0; }
1971 int Http2Session::read_noop(const uint8_t *data, size_t datalen) { return 0; }
1973 int Http2Session::write_noop() { return 0; }
1975 int Http2Session::connected() {
1998 read_ = &Http2Session::read_clear;
1999 write_ = &Http2Session::write_clear;
2006 read_ = &Http2Session::tls_handshake;
2007 write_ = &Http2Session::tls_handshake;
2020 int Http2Session::read_clear() {
2042 int Http2Session::write_clear() {
2061 write_ = &Http2Session::write_void;
2083 int Http2Session::tls_handshake() {
2111 read_ = &Http2Session::read_tls;
2112 write_ = &Http2Session::write_tls;
2122 int Http2Session::read_tls() {
2146 int Http2Session::write_tls() {
2171 write_ = &Http2Session::write_void;
2195 int Http2Session::write_void() {
2200 bool Http2Session::should_hard_fail() const {
2214 DownstreamAddr *Http2Session::get_addr() const { return addr_; }
2216 int Http2Session::handle_downstream_push_promise(Downstream *downstream,
2255 int Http2Session::handle_downstream_push_promise_complete(
2312 size_t Http2Session::get_num_dconns() const { return dconns_.size(); }
2314 bool Http2Session::max_concurrency_reached(size_t extra) const {
2328 Http2Session::get_downstream_addr_group() const {
2332 void Http2Session::add_to_extra_freelist() {
2347 void Http2Session::remove_from_freelist() {
2366 void Http2Session::exclude_from_scheduling() {
2371 DefaultMemchunks *Http2Session::get_request_buf() { return &wb_; }
2373 void Http2Session::on_timeout() {
2391 void Http2Session::check_retire() {
2409 const Address *Http2Session::get_raddr() const { return raddr_; }
2411 void Http2Session::on_settings_received(const nghttp2_frame *frame) {
2431 bool Http2Session::get_allow_connect_proto() const {