mirror of
https://github.com/facebook/proxygen.git
synced 2026-10-24 01:33:54 +03:00
remove HQUpstreamSession::tryBindIngressStreamToTxn
Summary: removes `HQUpstreamSession` logic to bind ingress push streams to transactions, continued efforts to remove all things http push related in proxygen/lib Reviewed By: jbeshay, Carl-Elkhoury Differential Revision: D124382298 fbshipit-source-id: f57b916ab691afc0bda49ebd1180bdcafed7ddd4
This commit is contained in:
committed by
meta-codesync[bot]
parent
9c563c478b
commit
7094da18fb
@@ -164,37 +164,6 @@ void HQUpstreamSession::detachThreadLocals(bool) {
|
||||
}
|
||||
}
|
||||
|
||||
bool HQUpstreamSession::tryBindIngressStreamToTxn(
|
||||
quic::StreamId streamId,
|
||||
hq::PushId pushId,
|
||||
HQIngressPushStream* pushStream) {
|
||||
// lookup pending nascent stream id
|
||||
CHECK(pushStream);
|
||||
|
||||
VLOG(4) << __func__ << " attempting to bind streamID=" << streamId
|
||||
<< " to pushID=" << pushId;
|
||||
pushStream->bindTo(streamId);
|
||||
|
||||
#if defined(DEBUG) && DEBUG
|
||||
// Check postconditions - the ingress push stream
|
||||
// should own both the push id and the stream id.
|
||||
// No nascent stream should own the stream id
|
||||
auto streamById = findIngressPushStream(streamId);
|
||||
auto streamByPushId = findIngressPushStreamByPushId(pushId);
|
||||
|
||||
DCHECK_EQ(streamId, pushStream->getIngressStreamId());
|
||||
DCHECK(streamById) << "Ingress stream must be bound to the streamID="
|
||||
<< streamId;
|
||||
DCHECK(streamByPushId) << "Ingress stream must be found by the pushID="
|
||||
<< pushId;
|
||||
DCHECK_EQ(streamById, streamByPushId) << "Must be same stream";
|
||||
#endif
|
||||
|
||||
VLOG(4) << __func__ << " successfully bound streamID=" << streamId
|
||||
<< " to pushID=" << pushId;
|
||||
return true;
|
||||
}
|
||||
|
||||
HQUpstreamSession::HQIngressPushStream* FOLLY_NULLABLE
|
||||
HQUpstreamSession::findIngressPushStream(quic::StreamId streamId) {
|
||||
auto res = streamIdToPushId_.find(streamId);
|
||||
|
||||
@@ -210,15 +210,6 @@ class HQUpstreamSession : public HQSession {
|
||||
|
||||
uint32_t numberOfIngressPushStreams() const;
|
||||
|
||||
/**
|
||||
* Attempt to bind an ingress push stream object (which has the txn)
|
||||
* to a nascent stream (which has the transport/codec).
|
||||
* returns true if binding was successful
|
||||
*/
|
||||
bool tryBindIngressStreamToTxn(quic::StreamId streamID,
|
||||
hq::PushId pushId,
|
||||
HQIngressPushStream* pushStream = nullptr);
|
||||
|
||||
bool erasePushStream(quic::StreamId streamId) override;
|
||||
|
||||
void eraseUnboundStream(HQStreamTransportBase*) override;
|
||||
|
||||
Reference in New Issue
Block a user