diff --git a/proxygen/lib/http/codec/ControlMessageRateLimitFilter.h b/proxygen/lib/http/codec/ControlMessageRateLimitFilter.h index aa6da9c714..9c04179eac 100644 --- a/proxygen/lib/http/codec/ControlMessageRateLimitFilter.h +++ b/proxygen/lib/http/codec/ControlMessageRateLimitFilter.h @@ -26,13 +26,6 @@ class ControlMessageRateLimitFilter : public RateLimitFilter { timeoutDuration_ = kDefaultTimeoutDuration; } - void onAbort(HTTPCodec::StreamID streamID, ErrorCode code) override { - if (!incrementNumEventsInCurrentInterval()) { - callback_->onAbort(streamID, code); - } else { - sendErrorCallback(http2::FrameType::RST_STREAM); - } - } void onPingRequest(uint64_t data) override { if (!incrementNumEventsInCurrentInterval()) { callback_->onPingRequest(data); diff --git a/proxygen/lib/http/session/HTTPSession.cpp b/proxygen/lib/http/session/HTTPSession.cpp index 1106623d9b..5362a18cf8 100644 --- a/proxygen/lib/http/session/HTTPSession.cpp +++ b/proxygen/lib/http/session/HTTPSession.cpp @@ -21,6 +21,7 @@ #include #include #include +#include #include #include #include @@ -228,6 +229,7 @@ void HTTPSession::setupCodec() { addRateLimitFilter(RateLimitFilter::Type::HEADERS); addRateLimitFilter(RateLimitFilter::Type::DIRECT_ERROR_HANDLING); addRateLimitFilter(RateLimitFilter::Type::MISC_CONTROL_MSGS); + addRateLimitFilter(RateLimitFilter::Type::RSTS); } codec_.setCallback(this);