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 HQSession::sendPushPriority

Browse Source 
Summary: removes `HQSession` logic to send push priorities, continued efforts to remove all things http push related in proxygen/lib

Reviewed By: jbeshay, Carl-Elkhoury

Differential Revision: D124186600

fbshipit-source-id: fdeb6adf10332ea2ff408291d7c2e50b974e8ab3
This commit is contained in:
Hani Damlaj
2026-10-18 10:36:38 -07:00
committed by meta-codesync[bot]
parent 7904e9d25e
commit db2f820ec4
2 changed files with 0 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
proxygen/lib/http/session/HQSession.cpp
View File

@@ -688,33 +688,6 @@ size_t HQSession::sendPriority(HTTPCodec::StreamID id, HTTPPriority priority) {
return ret;
}
size_t HQSession::sendPushPriority(hq::PushId pushId, HTTPPriority priority) {
auto iter = pushIdToStreamId_.find(pushId);
if (iter == pushIdToStreamId_.end()) {
return 0;
}
auto streamId = iter->second;
auto stream = findPushStream(streamId);
if (!stream) {
LOG(ERROR) << "Cannot find push streamId=" << streamId
<< " with pushId=" << pushId << " presented in id map";
return 0;
}
if (enableEgressPrioritization_) {
stream->setPriority(*sock_, streamId, priority);
}
auto controlStream = findControlStream(UnidirectionalStreamType::CONTROL);
if (!controlStream) {
return 0;
}
auto g = folly::makeGuard(controlStream->setActiveCodec(__func__));
auto ret = controlStream->codecFilterChain.generatePushPriority(
controlStream->writeBuf_, pushId, priority);
scheduleWrite();
return ret;
}
size_t HQSession::HQStreamTransportBase::changePriority(
HTTPTransaction* txn, HTTPPriority httpPriority) noexcept {
CHECK_EQ(txn, &txn_);

1
proxygen/lib/http/session/HQSession.h
View File

@@ -407,7 +407,6 @@ class HQSession
}
size_t sendPriority(HTTPCodec::StreamID id, HTTPPriority pri);
size_t sendPushPriority(hq::PushId pushId, HTTPPriority pri);
/**
* Get session-level transport info.