Line data Source code
1 : #include "source/extensions/transport_sockets/common/passthrough.h" 2 : 3 : #include "envoy/network/connection.h" 4 : #include "envoy/network/transport_socket.h" 5 : 6 : #include "source/common/buffer/buffer_impl.h" 7 : 8 : namespace Envoy { 9 : namespace Extensions { 10 : namespace TransportSockets { 11 : 12 : PassthroughSocket::PassthroughSocket(Network::TransportSocketPtr&& transport_socket) 13 0 : : transport_socket_(std::move(transport_socket)) {} 14 : 15 0 : void PassthroughSocket::setTransportSocketCallbacks(Network::TransportSocketCallbacks& callbacks) { 16 0 : transport_socket_->setTransportSocketCallbacks(callbacks); 17 0 : } 18 : 19 0 : std::string PassthroughSocket::protocol() const { return transport_socket_->protocol(); } 20 : 21 0 : absl::string_view PassthroughSocket::failureReason() const { 22 0 : return transport_socket_->failureReason(); 23 0 : } 24 : 25 0 : bool PassthroughSocket::canFlushClose() { return transport_socket_->canFlushClose(); } 26 : 27 0 : Api::SysCallIntResult PassthroughSocket::connect(Network::ConnectionSocket& socket) { 28 0 : return transport_socket_->connect(socket); 29 0 : } 30 : 31 0 : void PassthroughSocket::closeSocket(Network::ConnectionEvent event) { 32 0 : transport_socket_->closeSocket(event); 33 0 : } 34 : 35 0 : Network::IoResult PassthroughSocket::doRead(Buffer::Instance& buffer) { 36 0 : return transport_socket_->doRead(buffer); 37 0 : } 38 : 39 0 : Network::IoResult PassthroughSocket::doWrite(Buffer::Instance& buffer, bool end_stream) { 40 0 : return transport_socket_->doWrite(buffer, end_stream); 41 0 : } 42 : 43 0 : void PassthroughSocket::onConnected() { transport_socket_->onConnected(); } 44 : 45 0 : Ssl::ConnectionInfoConstSharedPtr PassthroughSocket::ssl() const { 46 0 : return transport_socket_->ssl(); 47 0 : } 48 : 49 : void PassthroughSocket::configureInitialCongestionWindow(uint64_t bandwidth_bits_per_sec, 50 0 : std::chrono::microseconds rtt) { 51 0 : return transport_socket_->configureInitialCongestionWindow(bandwidth_bits_per_sec, rtt); 52 0 : } 53 : 54 : } // namespace TransportSockets 55 : } // namespace Extensions 56 : } // namespace Envoy