MetadataClientSession Class Reference

#include <metadata_client_session.h>

Inheritance diagram for MetadataClientSession:

Collaboration diagram for MetadataClientSession:

Public Member Functions
	MetadataClientSession (HttpClient *client, Socket *socket)
virtual	~MetadataClientSession ()
virtual int	GetSessionInstance () const
Public Member Functions inherited from HttpClientSession
	HttpClientSession (HttpClient *client, Socket *socket)
virtual	~HttpClientSession ()
virtual void	OnRead (Buffer buffer)
void	RegisterEventCb (SessionEventCb cb)
void	SetConnection (HttpConnection *conn)
HttpConnection *	Connection ()
tbb::mutex &	mutex ()
Public Member Functions inherited from TcpSession
	TcpSession (TcpServer *server, Socket *socket, bool async_read_ready=true, size_t buffer_send_size=TcpSession::kDefaultWriteBufferSize)
virtual bool	Send (const uint8_t *data, size_t size, size_t *sent)
virtual bool	Connected (Endpoint remote)
virtual void	Accepted ()
void	ConnectFailed ()
void	Close ()
virtual std::string	ToString () const
virtual Socket *	socket () const
NativeSocketType	sock_descriptor ()
TcpServer *	server ()
int32_t	local_port () const
int32_t	remote_port () const
void	set_observer (EventObserver observer)
virtual void	ReleaseBuffer (Buffer buffer)
bool	IsEstablished () const
bool	IsClosed () const
bool	IsServerSession ()
Endpoint	remote_endpoint () const
const std::string &	remote_addr_string () const
Endpoint	local_endpoint () const
const boost::system::error_code &	close_reason () const
virtual boost::system::error_code	SetSocketOptions ()
void	set_read_on_connect (bool read)
void	SessionEstablished (Endpoint remote, Direction direction)
virtual void	AsyncReadStart ()
virtual void	SetDeferReader (bool defer_reader)
virtual bool	IsReaderDeferred () const
const io::SocketStats &	GetSocketStats () const
void	GetRxSocketStats (SocketIOStats *socket_stats) const
void	GetTxSocketStats (SocketIOStats *socket_stats) const
void	GetRxSocketStats (SocketIOStats &socket_stats) const
void	GetTxSocketStats (SocketIOStats &socket_stats) const
int	SetMd5SocketOption (uint32_t peer_ip, const std::string &md5_password)
int	ClearMd5SocketOption (uint32_t peer_ip)
int	SetDscpSocketOption (uint8_t value)
uint8_t	GetDscpValue () const
const std::string &	ToUVEKey () const
boost::system::error_code	SetTcpNoDelay ()
boost::system::error_code	SetTcpSendBufSize (uint32_t size)
boost::system::error_code	SetTcpRecvBufSize (uint32_t size)

Static Public Attributes
static const int	kMetadataSessionInstance = 0
Static Public Attributes inherited from TcpSession
static const int	kDefaultBufferSize = 16 * 1024
static const int	kDefaultWriteBufferSize = 32 * 1024

Private Member Functions
	DISALLOW_COPY_AND_ASSIGN (MetadataClientSession)

Additional Inherited Members
Public Types inherited from HttpClientSession
typedef boost::function< void(HttpClientSession *session, TcpSession::Event event)>	SessionEventCb
typedef boost::intrusive_ptr < TcpSession >	TcpSessionPtr
Public Types inherited from TcpSession
enum	Event {   EVENT_NONE, ACCEPT, CONNECT_COMPLETE, CONNECT_FAILED,   CLOSE }
enum	Direction { ACTIVE, PASSIVE }
typedef boost::asio::ip::tcp::socket	Socket
typedef boost::asio::ip::tcp::socket::native_handle_type	NativeSocketType
typedef boost::asio::ip::tcp::endpoint	Endpoint
typedef boost::function< void(TcpSession *, Event)>	EventObserver
typedef boost::asio::const_buffer	Buffer
Static Public Member Functions inherited from TcpSession
static const uint8_t *	BufferData (const Buffer &buffer)
static size_t	BufferSize (const Buffer &buffer)
static bool	IsSocketErrorHard (const boost::system::error_code &ec)
Protected Types inherited from TcpSession
typedef boost::intrusive_ptr < TcpSession >	TcpSessionPtr
typedef boost::asio::strand < boost::asio::io_context::executor_type >	Strand
Protected Member Functions inherited from TcpSession
void	AsyncReadStartInternal (TcpSessionPtr session)
virtual Task *	CreateReaderTask (boost::asio::mutable_buffer, size_t)
virtual	~TcpSession ()
virtual void	WriteReady (const boost::system::error_code &error)
void	AsyncWriteInternal (TcpSessionPtr session)
virtual void	AsyncReadSome ()
virtual size_t	GetReadBufferSize () const
virtual size_t	ReadSome (boost::asio::mutable_buffer buffer, boost::system::error_code *error)
virtual void	AsyncWrite (const uint8_t *data, std::size_t size)
virtual int	reader_task_id () const
bool	established () const
EventObserver	observer ()
boost::system::error_code	SetSocketKeepaliveOptions (int keepalive_time, int keepalive_intvl, int keepalive_probes, int tcp_user_timeout_val=0)
void	CloseInternal (const boost::system::error_code &ec, bool call_observer, bool notify_server=true)
void	TriggerAsyncReadHandler ()
Static Protected Member Functions inherited from TcpSession
static void	AsyncReadHandler (TcpSessionPtr session)
static void	AsyncWriteHandler (TcpSessionPtr session, const boost::system::error_code &error, std::size_t bytes_transferred)
Protected Attributes inherited from TcpSession
tbb::mutex	mutex_
io::SocketStats	stats_
boost::scoped_ptr< Strand >	io_strand_

Detailed Description

Definition at line 12 of file metadata_client_session.h.

Constructor & Destructor Documentation

MetadataClientSession::MetadataClientSession ( HttpClient *  client, Socket *  socket  )

inline

Definition at line 16 of file metadata_client_session.h.

virtual MetadataClientSession::~MetadataClientSession ( )

inlinevirtual

Definition at line 18 of file metadata_client_session.h.

Member Function Documentation

MetadataClientSession::DISALLOW_COPY_AND_ASSIGN ( MetadataClientSession  )

private

virtual int MetadataClientSession::GetSessionInstance ( ) const

inlinevirtual

Reimplemented from TcpSession.

Definition at line 22 of file metadata_client_session.h.

Member Data Documentation

const int MetadataClientSession::kMetadataSessionInstance = 0

static

Definition at line 14 of file metadata_client_session.h.

---

The documentation for this class was generated from the following file:

• metadata_client_session.h