store_client.cc File Reference

#include "squid.h"
#include "acl/FilledChecklist.h"
#include "base/AsyncCbdataCalls.h"
#include "base/CodeContext.h"
#include "event.h"
#include "globals.h"
#include "HttpReply.h"
#include "HttpRequest.h"
#include "MemBuf.h"
#include "MemObject.h"
#include "mime_header.h"
#include "sbuf/Stream.h"
#include "SquidConfig.h"
#include "SquidMath.h"
#include "StatCounters.h"
#include "Store.h"
#include "store/SwapMetaIn.h"
#include "store_swapin.h"
#include "StoreClient.h"
#include "DelayPools.h"

Include dependency graph for store_client.cc:

Go to the source code of this file.

Functions
static void	storeClientCopy2 (StoreEntry *e, store_client *sc)
static bool	CheckQuickAbortIsReasonable (StoreEntry *entry)
store_client *	storeClientListAdd (StoreEntry *e, void *data)
void	storeClientCopy (store_client *sc, StoreEntry *e, StoreIOBuffer copyInto, STCB *callback, void *data)
static void	storeClientReadHeader (void *data, const char *buf, ssize_t len, StoreIOState::Pointer)
static void	storeClientReadBody (void *data, const char *buf, ssize_t len, StoreIOState::Pointer)
int	storeUnregister (store_client *sc, StoreEntry *e, void *data)
int	storePendingNClients (const StoreEntry *e)

Variables
static StoreIOState::STRCB	storeClientReadBody
static StoreIOState::STRCB	storeClientReadHeader

Function Documentation

CheckQuickAbortIsReasonable()

static bool CheckQuickAbortIsReasonable ( StoreEntry *  entry )

static

Definition at line 900 of file store_client.cc.

References assert, MemObject::baseReply(), RequestFlags::cachable, Config, debugs, EBIT_TEST, MemObject::endOffset(), ENTRY_SPECIAL, HttpRequest::flags, StoreEntry::flags, HttpRequest::getRangeOffsetLimit(), KEY_PRIVATE, SquidConfig::max, StoreEntry::mem_obj, SquidConfig::min, SquidConfig::pct, SquidConfig::quickAbort, HttpRequest::range, MemObject::request, Store::Root(), shutting_down, STORE_PENDING, StoreEntry::store_status, and storePendingNClients().

Referenced by storeUnregister().

storeClientCopy()

void storeClientCopy	(	store_client *	,
		StoreEntry *	,
		StoreIOBuffer	,
		STCB *	,
		void *
	)

Asynchronously read HTTP response headers and/or body bytes from Store.

The requested zero-based HTTP body offset is specified via the StoreIOBuffer::offset field. The first call (for a given store_client object) must specify zero offset.

The requested HTTP body portion size is specified via the StoreIOBuffer::length field. The function may return fewer body bytes.

See STCB for result delivery details.

Definition at line 224 of file store_client.cc.

References assert, and sc.

Referenced by asHandleReply(), asnCacheStart(), netdbExchangeHandleReply(), netdbExchangeStart(), peerDigestHandleReply(), peerDigestRequest(), Mgr::StoreToCommWriter::scheduleStoreCopy(), UrnState::start(), and urnHandleReply().

storeClientCopy2()

static void storeClientCopy2 ( StoreEntry *  e, store_client *  sc  )

static

Definition at line 333 of file store_client.cc.

References assert, debugs, StoreEntry::getMD5Text(), and sc.

Referenced by store_client::copy(), and StoreEntry::invokeHandlers().

storeClientListAdd()

store_client* storeClientListAdd	(	StoreEntry *	e,
		void *	data
	)

Definition at line 124 of file store_client.cc.

References MemObject::addClient(), assert, StoreEntry::mem_obj, NULL, and sc.

Referenced by asnCacheStart(), clientReplyContext::createStoreEntry(), clientReplyContext::doGetMoreData(), netdbExchangeStart(), peerDigestRequest(), clientReplyContext::processExpired(), Ssl::ServerBump::ServerBump(), clientReplyContext::setReplyToStoreEntry(), UrnState::start(), and Mgr::StoreToCommWriter::start().

storeClientReadBody()

static void storeClientReadBody ( void *  data, const char *  buf, ssize_t  len, StoreIOState::Pointer    )

static

Definition at line 720 of file store_client.cc.

References sc.

storeClientReadHeader()

static void storeClientReadHeader ( void *  data, const char *  buf, ssize_t  len, StoreIOState::Pointer    )

static

Definition at line 713 of file store_client.cc.

References sc.

storePendingNClients()

int storePendingNClients

(

const StoreEntry *

e

)

Definition at line 890 of file store_client.cc.

References debugs, StoreEntry::mem_obj, and MemObject::nclients.

Referenced by CheckQuickAbortIsReasonable(), FwdState::completed(), StoreEntry::doAbandon(), and statStoreEntry().

storeUnregister()

int storeUnregister	(	store_client *	sc,
		StoreEntry *	e,
		void *	data
	)

Definition at line 765 of file store_client.cc.

References StoreEntry::abort(), assert, cbdataReferenceDone, CheckQuickAbortIsReasonable(), MemObject::clientCount(), MemObject::clients, debugs, dlinkDelete(), StoreEntry::getMD5Text(), StatCounters::ins, StoreEntry::kickProducer(), MemObject::kickReads(), StoreEntry::lock(), StoreEntry::mem_obj, MemObject::nclients, StoreIOState::readerDone, sc, statCounter, STORE_OK, StoreEntry::store_status, storeClose(), StatCounters::swap, StoreEntry::swapOut(), StoreEntry::swapoutFailed(), StoreEntry::swappedOut(), and StoreEntry::unlock().

Referenced by peerDigestFetchReply(), clientReplyContext::removeStoreReference(), Mgr::StoreToCommWriter::swanSong(), ASState::~ASState(), DigestFetchState::~DigestFetchState(), netdbExchangeState::~netdbExchangeState(), Ssl::ServerBump::~ServerBump(), and UrnState::~UrnState().

Variable Documentation

storeClientReadBody

StoreIOState::STRCB storeClientReadBody

static

Definition at line 42 of file store_client.cc.

Referenced by store_client::fileRead().

storeClientReadHeader

StoreIOState::STRCB storeClientReadHeader

static

Definition at line 43 of file store_client.cc.

Referenced by store_client::fileRead().