StoreClient.h File Reference

#include "acl/ChecklistFiller.h"
#include "base/AsyncCall.h"
#include "base/forward.h"
#include "dlink.h"
#include "StoreIOBuffer.h"
#include "StoreIOState.h"
#include "DelayId.h"

Include dependency graph for StoreClient.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
class	StoreClient
	a storeGetPublic*() caller More...
class	store_client
struct	store_client::Callback

Typedefs
typedef void	STCB(void *, StoreIOBuffer)

Functions
void	storeClientCopy (store_client *, StoreEntry *, StoreIOBuffer, STCB *, void *)
store_client *	storeClientListAdd (StoreEntry *e, void *data)
int	storeUnregister (store_client *sc, StoreEntry *e, void *data)
int	storePendingNClients (const StoreEntry *e)
int	storeClientIsThisAClient (store_client *sc, void *someClient)

Typedef Documentation

STCB

typedef void STCB(void *, StoreIOBuffer)

Definition at line 19 of file StoreClient.h.

Function Documentation

storeClientCopy()

void storeClientCopy	(	store_client *	sc,
		StoreEntry *	e,
		StoreIOBuffer	copyInto,
		STCB *	callback,
		void *	data
	)

Definition at line 241 of file store_client.cc.

References assert, and sc.

Referenced by asHandleReply(), asnCacheStart(), clientGetMoreData(), clientReplyContext::doGetMoreData(), netdbExchangeHandleReply(), netdbExchangeStart(), peerDigestHandleReply(), peerDigestRequest(), clientReplyContext::processExpired(), Mgr::StoreToCommWriter::scheduleStoreCopy(), UrnState::start(), clientReplyContext::traceReply(), clientReplyContext::triggerInitialStoreRead(), and urnHandleReply().

storeClientIsThisAClient()

int storeClientIsThisAClient	(	store_client *	sc,
		void *	someClient
	)

Referenced by clientReplyContext::processExpired().

storeClientListAdd()

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

Definition at line 121 of file store_client.cc.

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

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

storePendingNClients()

int storePendingNClients

(

const StoreEntry *

e

)

Definition at line 783 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 658 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 ASState::~ASState(), DigestFetchState::~DigestFetchState(), netdbExchangeState::~netdbExchangeState(), Ssl::ServerBump::~ServerBump(), UrnState::~UrnState(), peerDigestFetchFinish(), peerDigestFetchReply(), clientReplyContext::removeStoreReference(), and Mgr::StoreToCommWriter::swanSong().