#include <Prefetch.h>

Collaboration diagram for PrefetchBlaster:

Public Types
typedef int(PrefetchBlaster::*	EventHandler )(int event, void *data)
Public Member Functions
	PrefetchBlaster ()
	~PrefetchBlaster ()
int	init (PrefetchUrlEntry entry, HTTPHdr request, PrefetchTransform *p_trans)
int	handleEvent (int event, void *data)
	Receives the event code and data for an Event.
int	bufferObject (int event, void *data)
int	blastObject (int event, void *data)
int	httpClient (int event, void *data)
int	invokeBlaster ()
void	initCacheLookupConfig ()
void	handleCookieHeaders (HTTPHdr req_hdr, HTTPHdr resp_hdr, const char domain_start, const char domain_end, const char *host_start, int host_len, bool no_dot)
void	free ()
Data Fields
PrefetchUrlEntry *	url_ent
PrefetchTransform *	transform
BlasterUrlList *	url_list
HTTPHdr *	request
CacheHTTPInfo *	cache_http_info
MIOBuffer *	buf
IOBufferReader *	reader
VConnection *	serverVC
TSPrefetchBlastData	data_blast
CacheLookupHttpConfig	cache_lookup_config
uint32_t	n_pkts_sent
uint32_t	seq_no
IOBufferBlock *	io_block

Detailed Description

Definition at line 286 of file Prefetch.h.

Member Typedef Documentation

typedef int(PrefetchBlaster::* PrefetchBlaster::EventHandler)(int event, void *data)

Definition at line 290 of file Prefetch.h.

Constructor & Destructor Documentation

PrefetchBlaster::PrefetchBlaster ( ) [inline]

Definition at line 292 of file Prefetch.h.

PrefetchBlaster::~PrefetchBlaster ( ) [inline]

Definition at line 297 of file Prefetch.h.

Member Function Documentation

int PrefetchBlaster::blastObject	(	int	event,
		void *	data
	)

Definition at line 1684 of file Prefetch.cc.

References KeepAliveConnTable::append(), ats_ip_copy(), ats_ip_port_cast(), ats_is_ip(), buf, BUFFER_SIZE_INDEX_32K, PrefetchUrlEntry::child_ip, data_blast, PrefetchUrlEntry::data_multicast_ip, Debug, VConnection::do_io_close(), PrefetchConfiguration::embedded_obj_hook, TSPrefetchInfo::embedded_url, IOBufferBlock::end(), EVENT_IMMEDIATE, IOBufferBlock::fill(), free(), get_udp_seq_no(), ink_assert, io_block, ioBlockAllocator, n_pkts_sent, NET_EVENT_DATAGRAM_WRITE_COMPLETE, NET_EVENT_DATAGRAM_WRITE_ERROR, TSPrefetchInfo::object_buf, TSPrefetchInfo::object_buf_reader, TSPrefetchInfo::object_buf_status, PrefetchUrlEntry::object_buf_status, prefetch_udp_fd, PRELOAD_UDP_HEADER_LEN, IOBufferReader::read(), IOBufferBlock::read_avail(), IOBufferReader::read_avail(), reader, IOBufferBlock::reset(), IpEndpoint::sa, UDPNetProcessor::sendto_re(), seq_no, serverVC, SET_HANDLER, setup_object_header(), setup_udp_header(), IOBufferBlock::start(), IOBufferReader::start(), PrefetchConfiguration::stuffer_port, TS_PREFETCH_EMBEDDED_OBJECT_HOOK, TS_PREFETCH_OBJ_BUF_NEEDED, TS_PREFETCH_OBJ_BUF_NOT_NEEDED, TS_PREFETCH_TCP_BLAST, TSIOBufferCreate(), TSIOBufferReaderAlloc(), TSPrefetchBlastData::type, udpNet, PrefetchUrlEntry::url, url_ent, and IOBufferBlock::write_avail().

Referenced by bufferObject().

int PrefetchBlaster::bufferObject	(	int	event,
		void *	data
	)

Definition at line 1636 of file Prefetch.cc.

References blastObject(), buf, cache_http_info, copy_header(), Debug, VConnection::do_io_read(), EVENT_IMMEDIATE, EVENT_INTERVAL, MIOBuffer::fill(), get_vc_event_name(), MIOBuffer::high_water(), PrefetchUrlEntry::len, PrefetchConfiguration::max_object_size, PRELOAD_HEADER_LEN, request, MIOBuffer::reset(), serverVC, PrefetchUrlEntry::url, url_ent, VC_EVENT_EOS, VC_EVENT_READ_COMPLETE, VC_EVENT_READ_READY, MIOBuffer::water_mark, and MIOBuffer::write().

Referenced by handleEvent(), and httpClient().

void PrefetchBlaster::free ( void )

Definition at line 1110 of file Prefetch.cc.

References buf, Ptr< T >::clear(), HdrHeapSDKHandle::destroy(), VConnection::do_io_close(), IOBufferBlock::free(), PrefetchTransform::free(), PrefetchUrlEntry::free(), free_MIOBuffer(), io_block, Continuation::mutex, prefetchBlasterAllocator, request, serverVC, transform, and url_ent.

Referenced by blastObject(), handleEvent(), httpClient(), init(), and invokeBlaster().

void PrefetchBlaster::handleCookieHeaders	(	HTTPHdr *	req_hdr,
		HTTPHdr *	resp_hdr,
		const char *	domain_start,
		const char *	domain_end,
		const char *	host_start,
		int	host_len,
		bool	no_dot
	)

int PrefetchBlaster::handleEvent	(	int	event,
		void *	data
	)

Receives the event code and data for an Event.

This function receives the event code and data for an event and forwards them to the current continuation handler. The processor calling back the continuation is responsible for acquiring its lock.

Parameters: