diff --git a/proxygen/lib/http/session/HQUpstreamSession.cpp b/proxygen/lib/http/session/HQUpstreamSession.cpp index 15a95acab..6d73ea68e 100644 --- a/proxygen/lib/http/session/HQUpstreamSession.cpp +++ b/proxygen/lib/http/session/HQUpstreamSession.cpp @@ -164,27 +164,6 @@ void HQUpstreamSession::detachThreadLocals(bool) { } } -HQUpstreamSession::HQIngressPushStream* FOLLY_NULLABLE -HQUpstreamSession::findIngressPushStream(quic::StreamId streamId) { - auto res = streamIdToPushId_.find(streamId); - if (res == streamIdToPushId_.end()) { - return nullptr; - } else { - return findIngressPushStreamByPushId(res->second); - } -} - -HQUpstreamSession::HQIngressPushStream* FOLLY_NULLABLE -HQUpstreamSession::findIngressPushStreamByPushId(hq::PushId pushId) { - VLOG(4) << __func__ << " looking up ingress push stream by pushID=" << pushId; - auto it = ingressPushStreams_.find(pushId); - if (it == ingressPushStreams_.end()) { - return nullptr; - } else { - return &it->second; - } -} - uint32_t HQUpstreamSession::numberOfIngressPushStreams() const { return ingressPushStreams_.size(); } diff --git a/proxygen/lib/http/session/HQUpstreamSession.h b/proxygen/lib/http/session/HQUpstreamSession.h index 4c7ce0e62..43eff5f5d 100644 --- a/proxygen/lib/http/session/HQUpstreamSession.h +++ b/proxygen/lib/http/session/HQUpstreamSession.h @@ -197,10 +197,6 @@ class HQUpstreamSession : public HQSession { #pragma warning(pop) #endif - // Find an ingress push stream - HQIngressPushStream* findIngressPushStream(quic::StreamId); - HQIngressPushStream* findIngressPushStreamByPushId(hq::PushId); - uint32_t numberOfIngressPushStreams() const; void dispatchPushStream(quic::StreamId /* pushStreamId */,