#include "squid.h"
#include "acl/FilledChecklist.h"
#include "base/AsyncCallbacks.h"
#include "base/CbcPointer.h"
#include "base/JobWait.h"
#include "base/Raw.h"
#include "CachePeer.h"
#include "cbdata.h"
#include "client_side.h"
#include "client_side_request.h"
#include "clients/HttpTunneler.h"
#include "comm.h"
#include "comm/Connection.h"
#include "comm/ConnOpener.h"
#include "comm/Read.h"
#include "comm/Write.h"
#include "errorpage.h"
#include "fd.h"
#include "fde.h"
#include "FwdState.h"
#include "globals.h"
#include "HappyConnOpener.h"
#include "http.h"
#include "http/StatusCode.h"
#include "http/Stream.h"
#include "HttpRequest.h"
#include "icmp/net_db.h"
#include "ip/QosConfig.h"
#include "LogTags.h"
#include "MemBuf.h"
#include "neighbors.h"
#include "PeerSelectState.h"
#include "ResolvedPeers.h"
#include "sbuf/SBuf.h"
#include "security/BlindPeerConnector.h"
#include "SquidConfig.h"
#include "StatCounters.h"
#include "ssl/bio.h"
#include "ssl/ServerBump.h"
#include "tools.h"
#include "tunnel.h"
#include "DelayId.h"
#include <climits>
#include <cerrno>

Include dependency graph for tunnel.cc:

Classes
class	TunnelStateData

class	TunnelStateData::Connection

Functions
static std::ostream &	operator<< (std::ostream &os, const TunnelStateData::Connection &c)

static void	tunnelServerClosed (const CommCloseCbParams &params)
	TunnelStateData::serverClosed() wrapper.

static void	tunnelClientClosed (const CommCloseCbParams &params)
	TunnelStateData::clientClosed() wrapper.

static auto &	guaranteedRequest (const ClientHttpRequest *const cr)
	safely extracts HttpRequest from a never-nil ClientHttpRequest pointer

static void	tunnelTimeout (const CommTimeoutCbParams &io)

static void	tunnelDelayedClientRead (void *data)

static void	tunnelDelayedServerRead (void *data)

static void	tunnelStartShoveling (TunnelStateData *tunnelState)

static void	tunnelConnectedWriteDone (const Comm::ConnectionPointer &conn, char , size_t len, Comm::Flag flag, int, void data)

static void	tunnelErrorComplete (int fd, void *data, size_t)

void	tunnelStart (ClientHttpRequest *http)

void	switchToTunnel (HttpRequest *request, const Comm::ConnectionPointer &clientConn, const Comm::ConnectionPointer &srvConn, const SBuf &preReadServerData)

Variables
static ERCB	tunnelErrorComplete

static CLCB	tunnelServerClosed

static CLCB	tunnelClientClosed

static CTCB	tunnelTimeout

static EVH	tunnelDelayedClientRead

static EVH	tunnelDelayedServerRead

Function Documentation

◆ guaranteedRequest()

static auto & guaranteedRequest ( const ClientHttpRequest *const cr )

static

Definition at line 431 of file tunnel.cc.

References Assure, and ClientHttpRequest::request.

◆ operator<<()

static std::ostream & operator<<	(	std::ostream &	os,
		const TunnelStateData::Connection &	c
	)

static

Definition at line 310 of file tunnel.cc.

References TunnelStateData::Connection::conn, TunnelStateData::Connection::delayedLoops, TunnelStateData::Connection::dirty, Comm::Connection::id, TunnelStateData::Connection::len, TunnelStateData::Connection::readPending, TunnelStateData::Connection::receivedEof, TunnelStateData::Connection::side, and TunnelStateData::Connection::writer.

◆ switchToTunnel()

void switchToTunnel	(	HttpRequest *	request,
		const Comm::ConnectionPointer &	clientConn,
		const Comm::ConnectionPointer &	srvConn,
		const SBuf &	preReadServerData
	)

Sets up a TCP tunnel through Squid and starts shoveling traffic.

Parameters

request	the request that initiated/caused this tunnel
clientConn	the already accepted client-to-Squid TCP connection
srvConn	the already established Squid-to-server TCP connection
preReadServerData	server-sent bytes to be forwarded to the client

Definition at line 1615 of file tunnel.cc.

References StatCounters::all, HttpRequest::clientConnectionManager, TunnelStateData::commitToServer(), debugs, DelayId::DelayClient(), Comm::Connection::fd, CbcPointer< Cbc >::get(), TunnelStateData::getHost(), Comm::Connection::getPeer(), HttpRequest::hier, Http::Message::http_ver, Comm::IsConnOpen(), HttpRequest::method, Must, CachePeer::no_delay, CachePeer::options, StatCounters::other, HttpRequest::prepForDirect(), HttpRequest::prepForPeering(), TunnelStateData::preReadServerData, TunnelStateData::request, StatCounters::requests, HierarchyLogEntry::resetPeerNotes(), StatCounters::server, TunnelStateData::server, TunnelStateData::Connection::setDelayId(), statCounter, and tunnelStartShoveling().