helper_server Class Reference

represents a single "stateless helper" process More...

#include <helper.h>

Inheritance diagram for helper_server:

Collaboration diagram for helper_server:

Public Types
typedef std::map< uint64_t, Requests::iterator >	RequestIndex
typedef std::list< Helper::Xaction * >	Requests

Public Member Functions
virtual	~helper_server ()
Helper::Xaction *	popRequest (int requestId)
void	checkForTimedOutRequests (bool const retry)
virtual bool	reserved () override
	whether the server is locked for exclusive use by a client More...
virtual void	dropQueued () override
	dequeues and sends a Helper::Unknown answer to all queued requests More...
virtual helper *	getParent () const override
	the helper object that created this server More...
void	closePipesSafely (const char *name)
void	closeWritePipeSafely (const char *name)
void	initStats ()
virtual void *	toCbdata ()=0

Static Public Member Functions
static void	requestTimeout (const CommTimeoutCbParams &io)
	Read timeout handler. More...
static void	HelperServerClosed (helper_server *srv)
	close handler to handle exited server processes More...

Public Attributes
uint64_t	nextRequestId
MemBuf *	wqueue
MemBuf *	writebuf
helper *	parent
Helper::Xaction *	replyXaction
bool	ignoreToEom
	Whether to ignore current message, because it is timed-out or other reason. More...
RequestIndex	requestsIndex
	maps request IDs to requests More...
const InstanceId< HelperServerBase >	index
int	pid
Ip::Address	addr
Comm::ConnectionPointer	readPipe
Comm::ConnectionPointer	writePipe
void *	hIpc
char *	rbuf
size_t	rbuf_sz
size_t	roffset
struct timeval	dispatch_time
struct timeval	answer_time
dlink_node	link
struct HelperServerBase::_helper_flags	flags
Requests	requests
	requests in order of submission/expiration More...
struct {
uint64_t   uses
uint64_t   replies
uint64_t   pending
uint64_t   releases
uint64_t   timedout
}	stats

Private Member Functions
	CBDATA_CHILD (helper_server)

Detailed Description

Definition at line 243 of file helper.h.

Member Typedef Documentation

RequestIndex

typedef std::map<uint64_t, Requests::iterator> helper_server::RequestIndex

Definition at line 265 of file helper.h.

Requests

typedef std::list<Helper::Xaction *> HelperServerBase::Requests

inherited

Definition at line 225 of file helper.h.

Constructor & Destructor Documentation

~helper_server()

helper_server::~helper_server ( )

virtual

Definition at line 147 of file helper.cc.

References assert, cbdataReferenceDone, helper::childs, MemBuf::clean(), HelperServerBase::closeWritePipeSafely(), dlinkDelete(), helper::id_name, Comm::IsConnOpen(), HelperServerBase::link, Helper::ChildConfig::n_running, NULL, parent, HelperServerBase::requests, helper::servers, wqueue, writebuf, and HelperServerBase::writePipe.

Member Function Documentation

CBDATA_CHILD()

helper_server::CBDATA_CHILD ( helper_server  )

private

checkForTimedOutRequests()

void helper_server::checkForTimedOutRequests

(

bool const

retry

)

Run over the active requests lists and forces a retry, or timedout reply or the configured "on timeout response" for timedout requests.

Definition at line 1513 of file helper.cc.

References Helper::Reply::accumulate(), assert, Helper::Request::callback, cbdataReferenceValid(), cbdataReferenceValidDone, helper::childs, Helper::ChildConfig::concurrency, Helper::Request::data, debugs, Helper::Reply::finalize(), Helper::Request::Id, SBuf::isEmpty(), SBuf::length(), MAX_RETRIES, helper::onTimedOutResponse, parent, SBuf::rawContent(), Helper::Xaction::reply, Helper::Xaction::request, HelperServerBase::requests, requestsIndex, Helper::Reply::result, Helper::Request::retries, helper::stats, HelperServerBase::stats, helper::submitRequest(), helper::_stats::timedout, Helper::TimedOut, and helper::timeout.

Referenced by helperReturnBuffer(), and requestTimeout().

closePipesSafely()

void HelperServerBase::closePipesSafely ( const char *  name )

inherited

Closes pipes to the helper safely. Handles the case where the read and write pipes are the same FD.

Parameters

name	displayed for the helper being shutdown if logging an error

Definition at line 73 of file helper.cc.

References Comm::Connection::close(), HelperServerBase::_helper_flags::closing, DBG_IMPORTANT, debugs, Comm::Connection::fd, HelperServerBase::flags, getCurrentTime(), HelperServerBase::hIpc, HelperServerBase::index, HelperServerBase::pid, HelperServerBase::readPipe, and HelperServerBase::writePipe.

Referenced by helperHandleRead(), helperReturnBuffer(), helperShutdown(), helperStatefulHandleRead(), and helperStatefulShutdown().

closeWritePipeSafely()

void HelperServerBase::closeWritePipeSafely ( const char *  name )

inherited

Closes the reading pipe. If the read and write sockets are the same the write pipe will also be closed. Otherwise its left open for later handling.

Parameters

name	displayed for the helper being shutdown if logging an error

Definition at line 99 of file helper.cc.

References Comm::Connection::close(), HelperServerBase::_helper_flags::closing, DBG_IMPORTANT, debugs, Comm::Connection::fd, HelperServerBase::flags, getCurrentTime(), HelperServerBase::hIpc, HelperServerBase::index, HelperServerBase::pid, HelperServerBase::readPipe, and HelperServerBase::writePipe.

Referenced by ~helper_server(), helper_stateful_server::~helper_stateful_server(), and helperStatefulServerDone().

dropQueued()

void helper_server::dropQueued ( )

overridevirtual

Reimplemented from HelperServerBase.

Definition at line 171 of file helper.cc.

References HelperServerBase::dropQueued(), and requestsIndex.

Referenced by HelperServerClosed().

getParent()

virtual helper* helper_server::getParent ( ) const

inlineoverridevirtual

Implements HelperServerBase.

Definition at line 282 of file helper.h.

References parent.

Referenced by HelperServerClosed().

HelperServerClosed()

void helper_server::HelperServerClosed ( helper_server *  srv )

static

Definition at line 852 of file helper.cc.

References DBG_IMPORTANT, debugs, dropQueued(), getParent(), helper::handleKilledServer(), and helperOpenServers().

Referenced by helperOpenServers().

initStats()

void HelperServerBase::initStats ( )

inherited

Definition at line 63 of file helper.cc.

References HelperServerBase::stats.

Referenced by helperOpenServers(), and helperStatefulOpenServers().

popRequest()

Helper::Xaction * helper_server::popRequest

(

int

requestId

)

Search in queue for the request with requestId, return the related Xaction object and remove it from queue. If concurrency is disabled then the requestId is ignored and the Xaction of the next request in queue is retrieved.

Definition at line 888 of file helper.cc.

References helper::childs, Helper::ChildConfig::concurrency, parent, HelperServerBase::requests, and requestsIndex.

Referenced by helperHandleRead().

requestTimeout()

void helper_server::requestTimeout ( const CommTimeoutCbParams &  io )

static

Definition at line 1552 of file helper.cc.

References checkForTimedOutRequests(), commCbCall(), commSetConnTimeout(), CommCommonCbParams::conn, CommCommonCbParams::data, debugs, HERE(), max(), parent, HelperServerBase::requests, helper::retryTimedOut, squid_curtime, and helper::timeout.

Referenced by helperOpenServers().

reserved()

virtual bool helper_server::reserved ( )

inlineoverridevirtual

Implements HelperServerBase.

Definition at line 280 of file helper.h.

toCbdata()

virtual void* CbdataParent::toCbdata ( )

pure virtualinherited

Implemented in HttpStateData, ClientHttpRequest, and BodySink.

Referenced by AsyncJob::callException(), and AsyncJob::callStart().

Member Data Documentation

addr

Ip::Address HelperServerBase::addr

inherited

Definition at line 205 of file helper.h.

Referenced by helperOpenServers(), and helperStatefulOpenServers().

answer_time

struct timeval HelperServerBase::answer_time

inherited

Definition at line 212 of file helper.h.

Referenced by helperReturnBuffer(), helperStatefulHandleRead(), and helper::packStatsInto().

dispatch_time

struct timeval HelperServerBase::dispatch_time

inherited

Definition at line 212 of file helper.h.

Referenced by helperReturnBuffer(), helperStatefulDispatch(), helperStatefulHandleRead(), and helper::packStatsInto().

flags

struct HelperServerBase::_helper_flags HelperServerBase::flags

inherited

Referenced by HelperServerBase::closePipesSafely(), HelperServerBase::closeWritePipeSafely(), GetFirstAvailable(), helper::handleKilledServer(), helperDispatch(), helperDispatchWriteDone(), helperReturnBuffer(), helperShutdown(), helperStatefulServerDone(), helperStatefulShutdown(), helper::packStatsInto(), and StatefulGetFirstAvailable().

hIpc

void* HelperServerBase::hIpc

inherited

Definition at line 208 of file helper.h.

Referenced by HelperServerBase::closePipesSafely(), HelperServerBase::closeWritePipeSafely(), helperOpenServers(), and helperStatefulOpenServers().

ignoreToEom

bool helper_server::ignoreToEom

Definition at line 262 of file helper.h.

Referenced by helperHandleRead(), and helperOpenServers().

index

const InstanceId<HelperServerBase> HelperServerBase::index

inherited

Helper program identifier; does not change when contents do, including during assignment

Definition at line 203 of file helper.h.

Referenced by helper_stateful_server::clearReservation(), HelperServerBase::closePipesSafely(), HelperServerBase::closeWritePipeSafely(), GetFirstAvailable(), helper::handleKilledServer(), helperDispatch(), helperDispatchWriteDone(), helperHandleRead(), helperReturnBuffer(), helperShutdown(), helperStatefulDispatch(), helperStatefulHandleRead(), helperStatefulKickQueue(), helperStatefulShutdown(), helper::packStatsInto(), helper_stateful_server::reserve(), and StatefulGetFirstAvailable().

link

dlink_node HelperServerBase::link

inherited

Definition at line 217 of file helper.h.

Referenced by ~helper_server(), helper_stateful_server::~helper_stateful_server(), helperOpenServers(), and helperStatefulOpenServers().

nextRequestId

uint64_t helper_server::nextRequestId

Definition at line 248 of file helper.h.

Referenced by helperDispatch(), and helperOpenServers().

parent

helper* helper_server::parent

Definition at line 253 of file helper.h.

Referenced by ~helper_server(), checkForTimedOutRequests(), getParent(), helperDispatch(), helperDispatchWriteDone(), helperHandleRead(), helperOpenServers(), popRequest(), and requestTimeout().

pending

uint64_t HelperServerBase::pending

inherited

Definition at line 231 of file helper.h.

Referenced by GetFirstAvailable(), helperDispatch(), helperHandleRead(), helperReturnBuffer(), helperShutdown(), helperStatefulDispatch(), helperStatefulHandleRead(), helperStatefulServerDone(), helperStatefulShutdown(), helper::packStatsInto(), and StatefulGetFirstAvailable().

pid

int HelperServerBase::pid

inherited

Definition at line 204 of file helper.h.

Referenced by HelperServerBase::closePipesSafely(), HelperServerBase::closeWritePipeSafely(), helperOpenServers(), helperStatefulOpenServers(), and helper::packStatsInto().

rbuf

char* HelperServerBase::rbuf

inherited

Definition at line 210 of file helper.h.

Referenced by HelperServerBase::~HelperServerBase(), helperHandleRead(), helperOpenServers(), helperStatefulHandleRead(), and helperStatefulOpenServers().

rbuf_sz

size_t HelperServerBase::rbuf_sz

inherited

Definition at line 211 of file helper.h.

Referenced by HelperServerBase::~HelperServerBase(), helperHandleRead(), helperOpenServers(), helperReturnBuffer(), helperStatefulHandleRead(), and helperStatefulOpenServers().

readPipe

Comm::ConnectionPointer HelperServerBase::readPipe

inherited

Definition at line 206 of file helper.h.

Referenced by HelperServerBase::closePipesSafely(), HelperServerBase::closeWritePipeSafely(), helperHandleRead(), helperOpenServers(), helperStatefulHandleRead(), helperStatefulOpenServers(), and helper::packStatsInto().

releases

uint64_t HelperServerBase::releases

inherited

Definition at line 232 of file helper.h.

replies

uint64_t HelperServerBase::replies

inherited

Definition at line 230 of file helper.h.

Referenced by helper::handleKilledServer(), helperReturnBuffer(), helperStatefulHandleRead(), and helper::packStatsInto().

replyXaction

Helper::Xaction* helper_server::replyXaction

The helper request Xaction object for the current reply . A helper reply may be distributed to more than one of the retrieved packets from helper. This member stores the Xaction object as long as the end-of-message for current reply is not retrieved.

Definition at line 259 of file helper.h.

Referenced by helperHandleRead(), helperOpenServers(), and helperReturnBuffer().

requests

Requests HelperServerBase::requests

inherited

Definition at line 226 of file helper.h.

Referenced by ~helper_server(), helper_stateful_server::~helper_stateful_server(), checkForTimedOutRequests(), HelperServerBase::dropQueued(), helperDispatch(), helperStatefulDispatch(), helperStatefulHandleRead(), helper::packStatsInto(), popRequest(), and requestTimeout().

requestsIndex

RequestIndex helper_server::requestsIndex

Definition at line 266 of file helper.h.

Referenced by checkForTimedOutRequests(), dropQueued(), helperDispatch(), and popRequest().

roffset

size_t HelperServerBase::roffset

inherited

Definition at line 212 of file helper.h.

Referenced by helperHandleRead(), helperOpenServers(), helperStatefulHandleRead(), helperStatefulOpenServers(), and helper::packStatsInto().

stats

struct { ... } HelperServerBase::stats

Referenced by checkForTimedOutRequests(), helper_stateful_server::clearReservation(), GetFirstAvailable(), helper::handleKilledServer(), helperDispatch(), helperHandleRead(), helperReturnBuffer(), helperShutdown(), helperStatefulDispatch(), helperStatefulHandleRead(), helperStatefulServerDone(), helperStatefulShutdown(), HelperServerBase::initStats(), helper::packStatsInto(), and StatefulGetFirstAvailable().

timedout

uint64_t HelperServerBase::timedout

inherited

Definition at line 233 of file helper.h.

Referenced by helperHandleRead(), and helper::packStatsInto().

uses

uint64_t HelperServerBase::uses

inherited

Definition at line 229 of file helper.h.

Referenced by helperDispatch(), helperStatefulDispatch(), and helper::packStatsInto().

wqueue

MemBuf* helper_server::wqueue

Definition at line 250 of file helper.h.

Referenced by ~helper_server(), helperDispatch(), helperDispatchWriteDone(), and helperOpenServers().

writebuf

MemBuf* helper_server::writebuf

Definition at line 251 of file helper.h.

Referenced by ~helper_server(), helperDispatch(), and helperDispatchWriteDone().

writePipe

Comm::ConnectionPointer HelperServerBase::writePipe

inherited

Definition at line 207 of file helper.h.

Referenced by ~helper_server(), helper_stateful_server::~helper_stateful_server(), HelperServerBase::closePipesSafely(), HelperServerBase::closeWritePipeSafely(), helperDispatch(), helperDispatchWriteDone(), helperOpenServers(), helperReturnBuffer(), helperStatefulDispatch(), and helperStatefulOpenServers().

---

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

• src/helper.h
• src/helper.cc