File Reference
#include "squid.h"
#include "base/AsyncCbdataCalls.h"
#include "base/Packable.h"
#include "base/Raw.h"
#include "comm.h"
#include "comm/Connection.h"
#include "comm/Read.h"
#include "comm/Write.h"
#include "debug/Messages.h"
#include "fd.h"
#include "fde.h"
#include "format/Quoting.h"
#include "helper.h"
#include "helper/Reply.h"
#include "helper/Request.h"
#include "MemBuf.h"
#include "SquidConfig.h"
#include "SquidIpc.h"
#include "SquidMath.h"
#include "Store.h"
#include "wordlist.h"
#include "mem/Pool.h"
Include dependency graph for

Go to the source code of this file.


#define HELPER_MAX_ARGS   64
#define MAX_RETRIES   2
 The maximum allowed request retries. More...


const size_t ReadBufSize (32 *1024)
 Helpers input buffer size. More...
static void Enqueue (helper *hlp, Helper::Xaction *r)
 Handles a request when all running helpers, if any, are busy. More...
static helper_serverGetFirstAvailable (const helper::Pointer &)
static helper_stateful_serverStatefulGetFirstAvailable (const statefulhelper::Pointer &)
static void helperDispatch (helper_server *srv, Helper::Xaction *r)
static void helperStatefulDispatch (helper_stateful_server *srv, Helper::Xaction *r)
static void helperKickQueue (const helper::Pointer &)
static void helperStatefulKickQueue (const statefulhelper::Pointer &)
static void helperStatefulServerDone (helper_stateful_server *srv)
static void StatefulEnqueue (statefulhelper *hlp, Helper::Xaction *r)
 InstanceIdDefinitions (HelperServerBase, "Hlpr")
void helperOpenServers (const helper::Pointer &hlp)
void helperStatefulOpenServers (const statefulhelper::Pointer &hlp)
static void SubmissionFailure (const helper::Pointer &hlp, HLPCB *callback, void *data)
 handles helperSubmit() and helperStatefulSubmit() failures More...
void helperSubmit (const helper::Pointer &hlp, const char *buf, HLPCB *callback, void *data)
void helperStatefulSubmit (const statefulhelper::Pointer &hlp, const char *buf, HLPCB *callback, void *data, const Helper::ReservationId &reservation)
void helperShutdown (const helper::Pointer &hlp)
void helperStatefulShutdown (const statefulhelper::Pointer &hlp)
static void helperReturnBuffer (helper_server *srv, const helper::Pointer &hlp, char *msg, size_t msgSize, char *msgEnd)
 Calls back with a pointer to the buffer with the helper output. More...
static void helperHandleRead (const Comm::ConnectionPointer &conn, char *, size_t len, Comm::Flag flag, int, void *data)
static void helperStatefulHandleRead (const Comm::ConnectionPointer &conn, char *, size_t len, Comm::Flag flag, int, void *data)
static void helperDispatchWriteDone (const Comm::ConnectionPointer &, char *, size_t, Comm::Flag flag, int, void *data)
static void helperStatefulDispatchWriteDone (const Comm::ConnectionPointer &, char *, size_t, Comm::Flag, int, void *)


static IOCB helperHandleRead
static IOCB helperStatefulHandleRead

Macro Definition Documentation


#define HELPER_MAX_ARGS   64

Definition at line 36 of file


#define MAX_RETRIES   2

Definition at line 39 of file

Function Documentation

◆ Enqueue()

◆ GetFirstAvailable()

◆ helperDispatch()

◆ helperDispatchWriteDone()

◆ helperHandleRead()

◆ helperKickQueue()

static void helperKickQueue ( const helper::Pointer hlp)

Definition at line 1525 of file

References GetFirstAvailable(), helperDispatch(), and helper::nextRequest().

Referenced by helperOpenServers(), and helperReturnBuffer().

◆ helperOpenServers()

◆ helperReturnBuffer()

◆ helperShutdown()

◆ helperStatefulDispatch()

◆ helperStatefulDispatchWriteDone()

static void helperStatefulDispatchWriteDone ( const Comm::ConnectionPointer ,
char *  ,
size_t  ,
Comm::Flag  ,
int  ,
void *   

Definition at line 1473 of file

Referenced by helperStatefulDispatch().

◆ helperStatefulHandleRead()

static void helperStatefulHandleRead ( const Comm::ConnectionPointer conn,
char *  ,
size_t  len,
Comm::Flag  flag,
int  ,
void *  data 

◆ helperStatefulKickQueue()

◆ helperStatefulOpenServers()

◆ helperStatefulServerDone()

◆ helperStatefulShutdown()

◆ helperStatefulSubmit()

void helperStatefulSubmit ( const statefulhelper::Pointer hlp,
const char *  buf,
HLPCB callback,
void *  data,
const Helper::ReservationId reservation 

Submit request or callback the caller with a Helper::Error error. If the reservation is not set then reserves a new helper.

Definition at line 582 of file

◆ helperSubmit()

void helperSubmit ( const helper::Pointer hlp,
const char *  buf,
HLPCB callback,
void *  data 

◆ InstanceIdDefinitions()

InstanceIdDefinitions ( HelperServerBase  ,

◆ ReadBufSize()

const size_t ReadBufSize ( 32 *  1024)

◆ StatefulEnqueue()

◆ StatefulGetFirstAvailable()

◆ SubmissionFailure()

static void SubmissionFailure ( const helper::Pointer hlp,
HLPCB callback,
void *  data 

Definition at line 475 of file

References debugs, Helper::Error, and Helper::Unknown.

Variable Documentation

◆ helperHandleRead

IOCB helperHandleRead

Definition at line 44 of file

Referenced by helperHandleRead(), and helperOpenServers().

◆ helperStatefulHandleRead

IOCB helperStatefulHandleRead

Definition at line 45 of file

Referenced by helperStatefulHandleRead(), and helperStatefulOpenServers().






Web Site Translations