Squid Web Cache master
Loading...
Searching...
No Matches
Public Member Functions | Public Attributes | Private Attributes | List of all members
TunnelStateData::Connection Class Reference
Collaboration diagram for TunnelStateData::Connection:
[legend]

Public Member Functions

 Connection (const char *aSide)
 
 ~Connection ()
 
template<typename Method >
void initConnection (const Comm::ConnectionPointer &aConn, Method method, const char *name, TunnelStateData *tunnelState)
 initiates Comm::Connection ownership, including closure monitoring
 
void noteClosure ()
 reacts to the external closure of our connection
 
void noteEof ()
 reacts to a successful zero-size read(2)
 
int bytesWanted (int lower=0, int upper=INT_MAX) const
 
void bytesIn (int const &)
 
void setDelayId (DelayId const &)
 
void error (int const xerrno)
 
int debugLevelForError (int const xerrno) const
 
void dataSent (size_t amount)
 
void write (const char *b, int size, AsyncCall::Pointer &callback, FREE *free_func)
 writes 'b' buffer, setting the 'writer' member to 'callback'.
 

Public Attributes

int len
 
const char *const side
 
char * buf
 
AsyncCall::Pointer writer
 pending Comm::Write callback
 
uint64_t * size_ptr
 
Comm::ConnectionPointer conn
 The currently connected connection.
 
uint8_t delayedLoops
 how many times a read on this connection has been postponed.
 
bool dirty
 whether write() has been called (at least once)
 
bool receivedEof = false
 whether read() has returned zero bytes
 
TunnelStateData * readPending
 
EVH * readPendingFunc
 
DelayId delayId
 

Private Attributes

AsyncCall::Pointer closer
 the registered close handler for the connection
 

Detailed Description

Definition at line 130 of file tunnel.cc.

Constructor & Destructor Documentation

◆ Connection()

TunnelStateData::Connection::Connection ( const char *  aSide)
explicit

Definition at line 482 of file tunnel.cc.

◆ ~Connection()

TunnelStateData::Connection::~Connection ( )

Definition at line 494 of file tunnel.cc.

References eventDelete(), and safe_free.

Member Function Documentation

◆ bytesIn()

void TunnelStateData::Connection::bytesIn ( int const &  count)

Definition at line 572 of file tunnel.cc.

References debugs.

Referenced by TunnelStateData::copyClientBytes(), TunnelStateData::copyServerBytes(), TunnelStateData::readClient(), and TunnelStateData::readServer().

◆ bytesWanted()

int TunnelStateData::Connection::bytesWanted ( int  lower = 0,
int  upper = INT_MAX 
) const

Definition at line 561 of file tunnel.cc.

Referenced by TunnelStateData::copyRead().

◆ dataSent()

void TunnelStateData::Connection::dataSent ( size_t  amount)

Definition at line 834 of file tunnel.cc.

References assert, and debugs.

Referenced by TunnelStateData::writeClientDone(), and TunnelStateData::writeServerDone().

◆ debugLevelForError()

int TunnelStateData::Connection::debugLevelForError ( int const  xerrno) const

Definition at line 607 of file tunnel.cc.

References ignoreErrno().

◆ error()

void TunnelStateData::Connection::error ( int const  xerrno)

Definition at line 659 of file tunnel.cc.

References debugs, ignoreErrno(), and xstrerr().

Referenced by TunnelStateData::keepGoingAfterRead(), TunnelStateData::writeClientDone(), and TunnelStateData::writeServerDone().

◆ initConnection()

template<typename Method >
void TunnelStateData::Connection::initConnection ( const Comm::ConnectionPointer &  aConn,
Method  method,
const char *  name,
TunnelStateData *  tunnelState 
)

Definition at line 856 of file tunnel.cc.

References comm_add_close_handler(), commCbCall(), debugs, Comm::IsConnOpen(), and Must.

Referenced by TunnelStateData::TunnelStateData(), and TunnelStateData::commitToServer().

◆ noteClosure()

void TunnelStateData::Connection::noteClosure ( )

Definition at line 868 of file tunnel.cc.

References debugs.

Referenced by TunnelStateData::clientClosed(), and TunnelStateData::serverClosed().

◆ noteEof()

void TunnelStateData::Connection::noteEof ( )

Definition at line 877 of file tunnel.cc.

References debugs.

◆ setDelayId()

void TunnelStateData::Connection::setDelayId ( DelayId const &  newDelay)

Definition at line 1588 of file tunnel.cc.

Referenced by TunnelStateData::connectDone(), switchToTunnel(), and tunnelStart().

◆ write()

void TunnelStateData::Connection::write ( const char *  b,
int  size,
AsyncCall::Pointer &  callback,
FREE *  free_func 
)

Definition at line 847 of file tunnel.cc.

References size, and Comm::Write().

Referenced by TunnelStateData::copy(), and TunnelStateData::notePeerReadyToShovel().

Member Data Documentation

◆ buf

char* TunnelStateData::Connection::buf

Definition at line 166 of file tunnel.cc.

Referenced by TunnelStateData::copy(), TunnelStateData::copyClientBytes(), TunnelStateData::copyRead(), TunnelStateData::copyServerBytes(), and tunnelStartShoveling().

◆ closer

AsyncCall::Pointer TunnelStateData::Connection::closer
private

Definition at line 188 of file tunnel.cc.

◆ conn

Comm::ConnectionPointer TunnelStateData::Connection::conn

Definition at line 170 of file tunnel.cc.

Referenced by TunnelStateData::TunnelStateData(), TunnelStateData::closeConnections(), TunnelStateData::closePendingConnection(), TunnelStateData::copyRead(), TunnelStateData::finishWritingAndDelete(), TunnelStateData::getHost(), TunnelStateData::keepGoingAfterRead(), TunnelStateData::noConnections(), operator<<(), TunnelStateData::retryOrBail(), TunnelStateData::sendError(), tunnelErrorComplete(), tunnelStartShoveling(), TunnelStateData::writeClientDone(), and TunnelStateData::writeServerDone().

◆ delayedLoops

uint8_t TunnelStateData::Connection::delayedLoops

Definition at line 171 of file tunnel.cc.

Referenced by TunnelStateData::copyRead(), operator<<(), TunnelStateData::readClient(), and TunnelStateData::readServer().

◆ delayId

DelayId TunnelStateData::Connection::delayId

Definition at line 183 of file tunnel.cc.

Referenced by TunnelStateData::establishTunnelThruProxy().

◆ dirty

bool TunnelStateData::Connection::dirty

Definition at line 173 of file tunnel.cc.

Referenced by TunnelStateData::notePeerReadyToShovel(), operator<<(), and TunnelStateData::retryOrBail().

◆ len

int TunnelStateData::Connection::len

Definition at line 160 of file tunnel.cc.

Referenced by TunnelStateData::copyRead(), TunnelStateData::keepGoingAfterRead(), operator<<(), TunnelStateData::tunnelEstablishmentDone(), and tunnelStartShoveling().

◆ readPending

TunnelStateData* TunnelStateData::Connection::readPending

Definition at line 178 of file tunnel.cc.

Referenced by TunnelStateData::copyRead(), operator<<(), tunnelDelayedClientRead(), and tunnelDelayedServerRead().

◆ readPendingFunc

EVH* TunnelStateData::Connection::readPendingFunc

Definition at line 179 of file tunnel.cc.

Referenced by TunnelStateData::TunnelStateData(), and TunnelStateData::copyRead().

◆ receivedEof

bool TunnelStateData::Connection::receivedEof = false

Definition at line 175 of file tunnel.cc.

Referenced by operator<<().

◆ side

const char* const TunnelStateData::Connection::side

The role of the agent we are communicating with. This string literal is only used for debugging.

Definition at line 164 of file tunnel.cc.

Referenced by operator<<().

◆ size_ptr

uint64_t* TunnelStateData::Connection::size_ptr

Definition at line 168 of file tunnel.cc.

Referenced by TunnelStateData::TunnelStateData().

◆ writer

AsyncCall::Pointer TunnelStateData::Connection::writer

Definition at line 167 of file tunnel.cc.

Referenced by TunnelStateData::finishWritingAndDelete(), operator<<(), tunnelConnectedWriteDone(), TunnelStateData::WriteClientDone(), and TunnelStateData::WriteServerDone().

The documentation for this class was generated from the following file: