diff --git a/proxy/http2/Http2Stream.cc b/proxy/http2/Http2Stream.cc index 420a59e4be3..4d54a042ec9 100644 --- a/proxy/http2/Http2Stream.cc +++ b/proxy/http2/Http2Stream.cc @@ -165,8 +165,6 @@ Http2Stream::main_event_handler(int event, void *edata) read_event = nullptr; } else if (e == write_event) { write_event = nullptr; - } else if (e == buffer_full_write_event) { - buffer_full_write_event = nullptr; } switch (event) { @@ -875,11 +873,6 @@ Http2Stream::clear_io_events() write_event = nullptr; } - if (buffer_full_write_event) { - buffer_full_write_event->cancel(); - buffer_full_write_event = nullptr; - } - if (this->_read_vio_event) { this->_read_vio_event->cancel(); this->_read_vio_event = nullptr; diff --git a/proxy/http2/Http2Stream.h b/proxy/http2/Http2Stream.h index 99271494127..fe4720d934d 100644 --- a/proxy/http2/Http2Stream.h +++ b/proxy/http2/Http2Stream.h @@ -138,9 +138,7 @@ class Http2Stream : public ProxyTransaction bool recv_end_stream = false; bool send_end_stream = false; - bool sent_request_header = false; bool response_header_done = false; - bool request_sent = false; bool is_first_transaction_flag = false; HTTPHdr response_header; @@ -210,13 +208,11 @@ class Http2Stream : public ProxyTransaction std::vector _recent_rwnd_increment = {SIZE_MAX, SIZE_MAX, SIZE_MAX, SIZE_MAX, SIZE_MAX}; int _recent_rwnd_increment_index = 0; - Event *cross_thread_event = nullptr; - Event *buffer_full_write_event = nullptr; - - Event *read_event = nullptr; - Event *write_event = nullptr; - Event *_read_vio_event = nullptr; - Event *_write_vio_event = nullptr; + Event *cross_thread_event = nullptr; + Event *read_event = nullptr; + Event *write_event = nullptr; + Event *_read_vio_event = nullptr; + Event *_write_vio_event = nullptr; }; extern ClassAllocator http2StreamAllocator;