lib/proxygen
1
0
Fork 0
mirror of https://github.com/facebook/proxygen.git synced 2026-10-24 01:33:54 +03:00
Code Activity

remove HQUpstreamSession ingress push lookups

Browse Source 
Summary: removes `HQUpstreamSession::findIngressPushStream` and `findIngressPushStreamByPushId`, continued efforts to remove all things http push related in proxygen/lib

Reviewed By: Carl-Elkhoury, jbeshay

Differential Revision: D124407785

fbshipit-source-id: 31f78a971edb8784ff27f1e1bf738c900af33a30
This commit is contained in:
Hani Damlaj
2026-10-18 10:36:38 -07:00
committed by meta-codesync[bot]
parent ded8b91f5d
commit 790dd05a05
2 changed files with 0 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
proxygen/lib/http/session/HQUpstreamSession.cpp
View File

@@ -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();
}

4
proxygen/lib/http/session/HQUpstreamSession.h
View File

@@ -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 */,