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


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.
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().