#include <Prefetch.h>
Inherits Continuation.
Public Types | |
typedef int(PrefetchUrlBlaster::* | EventHandler )(int, void *) |
Public Member Functions | |
PrefetchUrlBlaster () | |
void | init (PrefetchUrlEntry *list_head, TSPrefetchBlastData const &u_bd=UDP_BLAST_DATA) |
void | free () |
void | writeBuffer (MIOBuffer *buf) |
int | udpUrlBlaster (int event, void *data) |
Data Fields | |
PrefetchUrlEntry * | url_head |
TSPrefetchBlastData | blast |
Action * | action |
Definition at line 234 of file Prefetch.h.
typedef int(PrefetchUrlBlaster::* PrefetchUrlBlaster::EventHandler)(int, void *) |
Definition at line 237 of file Prefetch.h.
PrefetchUrlBlaster::PrefetchUrlBlaster | ( | ) | [inline] |
Definition at line 239 of file Prefetch.h.
References blast.
void PrefetchUrlBlaster::free | ( | void | ) | [inline] |
Definition at line 911 of file Prefetch.cc.
References action, PrefetchUrlEntry::blaster_link, Action::cancel(), Ptr< T >::clear(), PrefetchUrlEntry::free(), Continuation::mutex, prefetchUrlBlasterAllocator, PrefetchUrlEntry::resp_blaster, EThread::schedule_imm(), this_ethread(), and url_head.
Referenced by udpUrlBlaster().
void PrefetchUrlBlaster::init | ( | PrefetchUrlEntry * | list_head, | |
TSPrefetchBlastData const & | u_bd = UDP_BLAST_DATA | |||
) |
Definition at line 263 of file Prefetch.h.
References blast, Continuation::mutex, MUTEX_LOCK, new_ProxyMutex(), SIMPLE_EVENT_EVENTS_START, this_ethread(), udpUrlBlaster(), and url_head.
Referenced by BlasterUrlList::invokeUrlBlaster().
int PrefetchUrlBlaster::udpUrlBlaster | ( | int | event, | |
void * | data | |||
) |
Definition at line 956 of file Prefetch.cc.
References MIOBuffer::alloc_reader(), KeepAliveConnTable::append(), ats_ip_copy(), ats_ip_port_cast(), blast, PrefetchUrlEntry::child_ip, Debug, MIOBuffer::fill(), free(), MIOBuffer::get_current_block(), get_udp_seq_no(), ink_assert, NET_EVENT_DATAGRAM_WRITE_COMPLETE, NET_EVENT_DATAGRAM_WRITE_ERROR, new_MIOBuffer, prefetch_udp_fd, PRELOAD_HEADER_LEN, PRELOAD_UDP_HEADER_LEN, IOBufferBlock::read_avail(), IOBufferReader::read_avail(), UDPNetProcessor::sendto_re(), SET_HANDLER, setup_object_header(), setup_udp_header(), SIMPLE_EVENT_EVENTS_START, IOBufferBlock::start(), IOBufferReader::start(), PrefetchConfiguration::stuffer_port, TS_PREFETCH_TCP_BLAST, TSPrefetchBlastData::type, udpNet, url_head, PrefetchUrlEntry::url_multicast_ip, and writeBuffer().
Referenced by init().
void PrefetchUrlBlaster::writeBuffer | ( | MIOBuffer * | buf | ) |
Definition at line 929 of file Prefetch.cc.
References PrefetchUrlEntry::blaster_link, Debug, PrefetchUrlEntry::len, PrefetchUrlEntry::url, url_head, and MIOBuffer::write().
Referenced by udpUrlBlaster().
Definition at line 252 of file Prefetch.h.
Referenced by free().
Definition at line 250 of file Prefetch.h.
Referenced by init(), PrefetchUrlBlaster(), and udpUrlBlaster().
Definition at line 249 of file Prefetch.h.
Referenced by free(), init(), udpUrlBlaster(), and writeBuffer().