Add wtTransportProvider_ in HTTPTransaction

Summary: Adding `WebTransportImpl::TransportProvider` to HTTPTransaction.

Reviewed By: afrind

Differential Revision: D74437629

fbshipit-source-id: a16ac8a08cbd6ceedc285b09b80c2b936028c169

Author: Joanna Jo

proxygen/lib/http/session/HTTPTransaction.cpp

@@ -86,6 +86,7 @@ HTTPTransaction::HTTPTransaction(
       id_(id),
       seqNo_(seqNo),
       transport_(transport),
+      wtTransportProvider_(&transport),
       stats_(stats),
       recvWindow_(receiveInitialWindowSize),
       sendWindow_(sendInitialWindowSize),
@@ -1720,7 +1721,7 @@ bool HTTPTransaction::sendDatagram(std::unique_ptr<folly::IOBuf> datagram) {
     return false;
   }
 
-  auto sent = transport_.sendDatagram(std::move(datagram));
+  auto sent = wtTransportProvider_->sendDatagram(std::move(datagram));
 
   if (sent && transportCallback_) {
     transportCallback_->datagramBytesGenerated(size);
@@ -2078,8 +2079,10 @@ void HTTPTransaction::onDatagram(
 WebTransportImpl::BidiStreamHandle HTTPTransaction::onWebTransportBidiStream(
     HTTPCodec::StreamID id) {
   if (!handler_) {
-    transport_.resetWebTransportEgress(id, WebTransport::kInternalError);
-    transport_.stopReadingWebTransportIngress(id, WebTransport::kInternalError);
+    wtTransportProvider_->resetWebTransportEgress(id,
+                                                  WebTransport::kInternalError);
+    wtTransportProvider_->stopReadingWebTransportIngress(
+        id, WebTransport::kInternalError);
     return {nullptr, nullptr};
   }
   refreshTimeout();
@@ -2094,7 +2097,8 @@ WebTransportImpl::StreamReadHandle* HTTPTransaction::onWebTransportUniStream(
     HTTPCodec::StreamID id) {
   if (!handler_) {
     LOG(ERROR) << "Handler not set";
-    transport_.stopReadingWebTransportIngress(id, WebTransport::kInternalError);
+    wtTransportProvider_->stopReadingWebTransportIngress(
+        id, WebTransport::kInternalError);
     return nullptr;
   }
   refreshTimeout();

proxygen/lib/http/session/HTTPTransaction.h

@@ -1742,6 +1742,10 @@ class HTTPTransaction
     return webTransportImpl_.get();
   }
 
+  void setWTTransportProvider(WebTransportImpl::TransportProvider* tp) {
+    wtTransportProvider_ = tp;
+  }
+
   static void setEgressBufferLimit(uint64_t limit) {
     egressBufferLimit_ = limit;
   }
@@ -1979,6 +1983,7 @@ class HTTPTransaction
   uint32_t maxDeferredIngress_{0};
   Handler* handler_{nullptr};
   Transport& transport_;
+  WebTransportImpl::TransportProvider* wtTransportProvider_;
 
   HTTPSessionStats* stats_{nullptr};