#include <P_ClusterCacheInternal.h>

Collaboration diagram for CacheContinuation:

Public Types
enum	{ MagicNo = 0x92183123 }
Public Member Functions
int	lookupEvent (int event, void *d)
int	probeLookupEvent (int event, void *d)
int	remoteOpEvent (int event, Event *e)
int	replyLookupEvent (int event, void *d)
int	replyOpEvent (int event, VConnection *vc)
int	handleReplyEvent (int event, Event *e)
int	callbackEvent (int event, Event *e)
int	setupVCdataRead (int event, VConnection *vc)
int	VCdataRead (int event, VIO *target_vio)
int	setupReadWriteVC (int, VConnection *)
ClusterVConnection *	lookupOpenWriteVC ()
int	lookupOpenWriteVCEvent (int, Event *)
int	localVCsetupEvent (int event, ClusterVConnection *vc)
void	insert_cache_callback_user (ClusterVConnection , int, void )
int	insertCallbackEvent (int, Event *)
void	callback_user (int result, void *d)
void	defer_callback_result (int result, void *d)
int	callbackResultEvent (int event, Event *e)
void	setupReadBufTunnel (VConnection , VConnection )
int	tunnelClosedEvent (int event, void *)
int	remove_and_delete (int, Event *)
void	setMsgBufferLen (int l, IOBufferData *b=0)
int	getMsgBufferLen ()
void	allocMsgBuffer ()
char *	getMsgBuffer ()
IOBufferData *	getMsgBufferIOBData ()
void	freeMsgBuffer ()
void	free ()
	CacheContinuation ()
Static Public Member Functions
static bool	is_ClusterThread (EThread *et)
static int	init ()
static CacheContinuation *	cacheContAllocator_alloc ()
static void	cacheContAllocator_free (CacheContinuation *)
static inkcoreapi Action *	callback_failure (Action , int, int, CacheContinuation this_cc=0)
static Action *	do_remote_lookup (Continuation , CacheKey , CacheContinuation , CacheFragType, char , int)
static inkcoreapi Action *	do_op (Continuation , ClusterMachine , void , int, char , int, int nbytes=-1, MIOBuffer *b=0)
static int	setup_local_vc (char data, int data_len, CacheContinuation cc, ClusterMachine mp, Action *)
static void	disposeOfDataBuffer (void *buf)
static int	handleDisposeEvent (int event, CacheContinuation *cc)
static int32_t	getObjectSize (VConnection , int, CacheHTTPInfo )
Data Fields
int	magicno
void *	callback_data
void *	callback_data_2
INK_MD5	url_md5
Event *	timeout
Action	action
ClusterMachine *	target_machine
int	probe_depth
ClusterMachine *	past_probes [CONFIGURATION_HISTORY_PROBE_DEPTH]
ink_hrtime	start_time
ClusterMachine *	from
ClusterHandler *	ch
VConnection *	cache_vc
bool	cache_read
int	result
int	result_error
ClusterVCToken	token
unsigned int	seq_number
uint16_t	cfl_flags
CacheFragType	frag_type
int	nbytes
unsigned int	target_ip
int	request_opcode
bool	request_purge
bool	local_lookup_only
bool	no_reply_message
bool	request_timeout
bool	expect_cache_callback
bool	use_deferred_callback
time_t	pin_in_cache
Ptr< IOBufferData >	rw_buf_msg
int	rw_buf_msg_len
ClusterVConnection *	read_cluster_vc
ClusterVConnection *	write_cluster_vc
int	cluster_vc_channel
ClusterVCToken	open_local_token
int	caller_buf_freebytes
VIO *	readahead_vio
IOBufferReader *	readahead_reader
Ptr< IOBufferBlock >	readahead_data
bool	have_all_data
CacheHTTPInfo	cache_vc_info
OneWayTunnel *	tunnel
Ptr< ProxyMutex >	tunnel_mutex
CacheContinuation *	tunnel_cont
bool	tunnel_closed
Action *	cache_action
Event *	lookup_open_write_vc_event
Arena	ic_arena
CacheHTTPHdr	ic_request
CacheHTTPHdr	ic_response
CacheLookupHttpConfig *	ic_params
CacheHTTPInfo	ic_old_info
CacheHTTPInfo	ic_new_info
Ptr< IOBufferData >	ic_hostname
int	ic_hostname_len
int	cache_op_ClusterFunction

Detailed Description

Definition at line 90 of file P_ClusterCacheInternal.h.

Member Enumeration Documentation

anonymous enum

Enumerator:

MagicNo

Definition at line 92 of file P_ClusterCacheInternal.h.

Constructor & Destructor Documentation

CacheContinuation::CacheContinuation ( ) [inline]

Definition at line 274 of file P_ClusterCacheInternal.h.

References ClusterVCToken::clear(), remoteOpEvent(), SET_HANDLER, and token.

Member Function Documentation

void CacheContinuation::allocMsgBuffer ( ) [inline]

Definition at line 212 of file P_ClusterCacheInternal.h.

References ats_malloc(), buffer_size_to_index(), DEFAULT_MAX_BUFFER_SIZE, ink_assert, MAX_BUFFER_SIZE_INDEX, new_IOBufferData, new_xmalloc_IOBufferData, rw_buf_msg, and rw_buf_msg_len.

Referenced by cache_op_ClusterFunction(), do_remote_lookup(), and setup_local_vc().

CacheContinuation * CacheContinuation::cacheContAllocator_alloc ( ) [static]

Definition at line 2848 of file ClusterCache.cc.

References cacheContAllocator.

Referenced by cache_lookup_ClusterFunction(), cache_op_ClusterFunction(), cache_op_result_ClusterFunction(), callback_failure(), Cluster_lookup(), do_op(), do_remote_lookup(), and setupReadBufTunnel().

void CacheContinuation::cacheContAllocator_free ( CacheContinuation * c ) [static]

Definition at line 2858 of file ClusterCache.cc.

References action, cacheContAllocator, free(), ink_assert, MagicNo, magicno, Continuation::mutex, start_time, and tunnel_mutex.

Referenced by callback_user(), callbackEvent(), callbackResultEvent(), Cluster_lookup(), disposeOfDataBuffer(), handleDisposeEvent(), handleReplyEvent(), localVCsetupEvent(), remoteOpEvent(), remove_and_delete(), replyLookupEvent(), replyOpEvent(), and tunnelClosedEvent().

Action * CacheContinuation::callback_failure	(	Action *	a,
		int	result,
		int	err,
		CacheContinuation *	this_cc = `0`
	)			`[static]`

Definition at line 2884 of file ClusterCache.cc.

References action, cacheContAllocator_alloc(), callbackEvent(), ET_CACHE_CONT_SM, eventProcessor, Action::mutex, Continuation::mutex, result, result_error, EventProcessor::schedule_imm(), and SET_CONTINUATION_HANDLER.

Referenced by Cluster_deref(), Cluster_link(), Cluster_lookup(), Cluster_read(), Cluster_remove(), Cluster_write(), remove_and_delete(), and setup_local_vc().

void CacheContinuation::callback_user	(	int	result,
		void *	d
	)

Definition at line 2800 of file ClusterCache.cc.

References action, cacheContAllocator_free(), Action::cancelled, Action::continuation, defer_callback_result(), Continuation::handleEvent(), is_ClusterThread(), Continuation::mutex, MUTEX_TRY_LOCK, and this_ethread().

Referenced by insert_cache_callback_user(), insertCallbackEvent(), probeLookupEvent(), and remoteOpEvent().

int CacheContinuation::callbackEvent	(	int	event,
		Event *	e
	)

Definition at line 2908 of file ClusterCache.cc.

References action, cacheContAllocator_free(), Action::cancelled, Action::continuation, Continuation::handleEvent(), result, and result_error.

Referenced by callback_failure().

int CacheContinuation::callbackResultEvent	(	int	event,
		Event *	e
	)

Definition at line 2832 of file ClusterCache.cc.

References action, cacheContAllocator_free(), callback_data, Action::cancelled, Action::continuation, Continuation::handleEvent(), and result.

Referenced by defer_callback_result().

void CacheContinuation::defer_callback_result	(	int	result,
		void *	d
	)

Definition at line 2823 of file ClusterCache.cc.

References callback_data, callbackResultEvent(), ET_CACHE_CONT_SM, eventProcessor, result, EventProcessor::schedule_imm(), and SET_HANDLER.

Referenced by callback_user().

void CacheContinuation::disposeOfDataBuffer ( void * buf ) [static]

Definition at line 1906 of file ClusterCache.cc.

References ClusterVConnection::allow_remote_close(), cache_vc, cacheContAllocator_free(), VIO::CLOSE, VConnection::do_io(), ET_CALL, EVENT_CONT, eventProcessor, handleDisposeEvent(), have_all_data, HRTIME_MSECONDS, ink_assert, ClusterVConnection::pending_remote_fill, readahead_data, readahead_vio, ClusterVConnection::remote_closed, EventProcessor::schedule_in(), and write_cluster_vc.

Referenced by replyOpEvent().

Action * CacheContinuation::do_op	(	Continuation *	c,
		ClusterMachine *	mp,
		void *	args,
		int	user_opcode,
		char *	data,
		int	data_len,
		int	nbytes = `-1`,
		MIOBuffer *	b = `0`
	)			`[static]`

Definition at line 375 of file ClusterCache.cc.

References action, ALLOCA_DOUBLE, CacheOpMsg_long::buffer_size, CacheOpMsg_short::buffer_size, cache_cluster_timeout, CACHE_DEREF, CACHE_LINK, CACHE_NO_RESPONSE, CACHE_OP_CLUSTER_FUNCTION, CACHE_OP_MALLOCED_CLUSTER_FUNCTION, CACHE_OPEN_READ, CACHE_OPEN_READ_BUFFER, CACHE_OPEN_READ_BUFFER_LONG, CACHE_OPEN_READ_LONG, CACHE_OPEN_WRITE, CACHE_OPEN_WRITE_BUFFER, CACHE_OPEN_WRITE_BUFFER_LONG, CACHE_OPEN_WRITE_LONG, CACHE_REMOVE, CACHE_RETRY_PERIOD, CACHE_UPDATE, cacheContAllocator_alloc(), Action::cancelled, CacheOpMsg_short_2::cfl_flags, CacheOpMsg_long::cfl_flags, CacheOpMsg_short::cfl_flags, ch, clusterProcessor, CacheOpMsg_long::data, CacheOpMsg_short::data, Debug, Queue< C, L >::enqueue(), ET_CACHE_CONT_SM, eventProcessor, FOLDHASH, CacheOpMsg_short_2::frag_type, frag_type, CacheOpMsg_long::frag_type, CacheOpMsg_short::frag_type, from, CacheOpMsg_short_2::init(), CacheOpMsg_long::init(), CacheOpMsg_short::init(), ink_get_hrtime(), ink_release_assert, ClusterProcessor::invoke_remote(), ClusterMachine::ip, CacheOpMsg_short::md5, CacheOpMsg_short_2::md5_1, CacheOpMsg_short_2::md5_2, Continuation::mutex, MUTEX_RELEASE, MUTEX_TRY_LOCK, CacheOpMsg_long::nbytes, CacheOpMsg_short::nbytes, new_cache_sequence_number(), op_failure(), op_needs_marshalled_coi(), op_to_sizeof_fixedlen_msg(), CacheOpMsg_short_2::opcode, CacheOpMsg_long::opcode, CacheOpMsg_short::opcode, pin_in_cache, ClusterMachine::pop_ClusterHandler(), remoteOpEvent(), remove_and_delete(), request_opcode, result, EventProcessor::schedule_in(), CacheOpMsg_short_2::seq_number, CacheOpMsg_long::seq_number, CacheOpMsg_short::seq_number, seq_number, SET_CONTINUATION_HANDLER, setup_local_vc(), start_time, target_ip, target_machine, this_ethread(), timeout, CacheOpMsg_long::url_md5, and url_md5.

Referenced by Cluster_deref(), Cluster_link(), Cluster_read(), Cluster_remove(), and Cluster_write().

Action * CacheContinuation::do_remote_lookup	(	Continuation *	cont,
		CacheKey *	key,
		CacheContinuation *	c,
		CacheFragType	ft,
		char *	hostname,
		int	hostname_len
	)			`[static]`