#include <HttpTunnel.h>

Collaboration diagram for HttpTunnel:

Data Structures
struct	FlowControl
	Data for implementing flow control across a tunnel.
Public Member Functions
	HttpTunnel ()
void	init (HttpSM sm_arg, ProxyMutex amutex)
void	reset ()
void	kill_tunnel ()
bool	is_tunnel_active () const
bool	is_tunnel_alive () const
bool	has_cache_writer () const
void	copy_partial_post_data ()
void	allocate_redirect_postdata_producer_buffer ()
void	allocate_redirect_postdata_buffers (IOBufferReader *ua_reader)
void	deallocate_redirect_postdata_buffers ()
HttpTunnelProducer *	add_producer (VConnection vc, int64_t nbytes, IOBufferReader reader_start, HttpProducerHandler sm_handler, HttpTunnelType_t vc_type, const char *name)
void	set_producer_chunking_action (HttpTunnelProducer *p, int64_t skip_bytes, TunnelChunkingAction_t action)
void	set_producer_chunking_size (HttpTunnelProducer *producer, int64_t size)
	Set the maximum (preferred) chunk size of chunked output for producer.
HttpTunnelConsumer *	add_consumer (VConnection vc, VConnection producer, HttpConsumerHandler sm_handler, HttpTunnelType_t vc_type, const char *name, int64_t skip_bytes=0)
int	deallocate_buffers ()
DLL< HttpTunnelConsumer > *	get_consumers (VConnection *vc)
HttpTunnelProducer *	get_producer (VConnection *vc)
HttpTunnelConsumer *	get_consumer (VConnection *vc)
void	tunnel_run (HttpTunnelProducer *p=NULL)
int	main_handler (int event, void *data)
bool	consumer_reenable (HttpTunnelConsumer *c)
bool	consumer_handler (int event, HttpTunnelConsumer *c)
bool	producer_handler (int event, HttpTunnelProducer *p)
int	producer_handler_dechunked (int event, HttpTunnelProducer *p)
int	producer_handler_chunked (int event, HttpTunnelProducer *p)
void	local_finish_all (HttpTunnelProducer *p)
void	chain_finish_all (HttpTunnelProducer *p)
void	chain_abort_cache_write (HttpTunnelProducer *p)
void	chain_abort_all (HttpTunnelProducer *p)
void	abort_cache_write_finish_others (HttpTunnelProducer *p)
void	append_message_to_producer_buffer (HttpTunnelProducer p, const char msg, int64_t msg_len)
void	chain (HttpTunnelConsumer c, HttpTunnelProducer p)
	Mark a producer and consumer as the same underlying object.
void	close_vc (HttpTunnelProducer *p)
void	close_vc (HttpTunnelConsumer *c)
Data Fields
PostDataBuffers *	postbuf
Friends
class	HttpPagesHandler
class	CoreUtils

Detailed Description

Definition at line 279 of file HttpTunnel.h.

Constructor & Destructor Documentation

HttpTunnel::HttpTunnel ( )

Definition at line 465 of file HttpTunnel.cc.

Member Function Documentation

void HttpTunnel::abort_cache_write_finish_others ( HttpTunnelProducer * p ) [inline]

Definition at line 401 of file HttpTunnel.h.

References chain_abort_cache_write(), and local_finish_all().

Referenced by HttpSM::tunnel_handler_post_ua(), HttpSM::tunnel_handler_server(), and HttpSM::tunnel_handler_transform_read().

HttpTunnelConsumer * HttpTunnel::add_consumer	(	VConnection *	vc,
		VConnection *	producer,
		HttpConsumerHandler	sm_handler,
		HttpTunnelType_t	vc_type,
		const char *	name,
		int64_t	skip_bytes = `0`
	)

Definition at line 670 of file HttpTunnel.cc.

References HttpTunnelConsumer::alive, HttpTunnelProducer::alive, HttpTunnelProducer::consumer_list, Debug, get_producer(), ink_release_assert, HttpTunnelConsumer::name, HttpTunnelProducer::num_consumers, HttpTunnelConsumer::producer, DLL< C, L >::push(), HttpTunnelProducer::read_success, HttpTunnelConsumer::skip_bytes, HttpSM::sm_id, HttpTunnelConsumer::vc, HttpTunnelConsumer::vc_handler, and HttpTunnelConsumer::vc_type.

Referenced by HttpSM::do_setup_post_tunnel(), HttpSM::setup_100_continue_transfer(), HttpSM::setup_blind_tunnel(), HttpSM::setup_cache_read_transfer(), HttpSM::setup_cache_transfer_to_transform(), HttpSM::setup_cache_write_transfer(), HttpSM::setup_internal_transfer(), HttpSM::setup_plugin_agents(), HttpSM::setup_server_transfer(), HttpSM::setup_server_transfer_to_transform(), HttpSM::setup_transfer_from_transform(), and HttpSM::setup_transform_to_server_transfer().

HttpTunnelProducer * HttpTunnel::add_producer	(	VConnection *	vc,
		int64_t	nbytes,
		IOBufferReader *	reader_start,
		HttpProducerHandler	sm_handler,
		HttpTunnelType_t	vc_type,
		const char *	name
	)

Definition at line 611 of file HttpTunnel.cc.

Referenced by HttpSM::do_setup_post_tunnel(), HttpSM::setup_100_continue_transfer(), HttpSM::setup_blind_tunnel(), HttpSM::setup_cache_read_transfer(), HttpSM::setup_cache_transfer_to_transform(), HttpSM::setup_internal_transfer(), HttpSM::setup_push_transfer_to_cache(), HttpSM::setup_server_transfer(), HttpSM::setup_server_transfer_to_cache_only(), HttpSM::setup_server_transfer_to_transform(), HttpSM::setup_transfer_from_transform(), HttpSM::setup_transfer_from_transform_to_cache_only(), and HttpSM::setup_transform_to_server_transfer().

void HttpTunnel::allocate_redirect_postdata_buffers ( IOBufferReader * ua_reader )

Definition at line 1589 of file HttpTunnel.cc.

References MIOBuffer::alloc_reader(), allocate_redirect_postdata_producer_buffer(), buffer_size_to_index(), Debug, HttpTransact::State::hdr_info, new_MIOBuffer, postbuf, PostDataBuffers::postdata_copy_buffer, PostDataBuffers::postdata_copy_buffer_start, HttpSM::t_state, and PostDataBuffers::ua_buffer_reader.

void HttpTunnel::allocate_redirect_postdata_producer_buffer ( )

Definition at line 1576 of file HttpTunnel.cc.

References MIOBuffer::alloc_reader(), buffer_size_to_index(), HttpTransact::State::hdr_info, ink_release_assert, new_MIOBuffer, postbuf, PostDataBuffers::postdata_producer_buffer, PostDataBuffers::postdata_producer_reader, and HttpSM::t_state.

Referenced by allocate_redirect_postdata_buffers(), and HttpSM::tunnel_handler_for_partial_post().

void HttpTunnel::append_message_to_producer_buffer	(	HttpTunnelProducer *	p,
		const char *	msg,
		int64_t	msg_len
	)			`[inline]`

Definition at line 499 of file HttpTunnel.h.

References HttpTunnelProducer::bytes_read, HttpTunnelProducer::nbytes, HttpTunnelProducer::read_buffer, and MIOBuffer::write().

void HttpTunnel::chain	(	HttpTunnelConsumer *	c,
		HttpTunnelProducer *	p
	)

Mark a producer and consumer as the same underlying object.

This is use to chain producer/consumer pairs together to indicate the data flows through them sequentially. The primary example is a transform which serves as a consumer on the server side and a producer on the cache/client side.

Parameters: