#include <ksync_sock.h>

Inheritance diagram for KSyncSockTcpSession:

Collaboration diagram for KSyncSockTcpSession:

Public Member Functions
	KSyncSockTcpSession (TcpServer server, Socket sock, bool async_ready=false)

virtual	~KSyncSockTcpSession ()

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)

virtual int	GetSessionInstance () const

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)

Protected Member Functions
virtual void	OnRead (Buffer buffer)

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 ()

Private Attributes
KSyncSockTcpSessionReader *	reader_

Additional Inherited Members
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)

Static Public Attributes inherited from TcpSession
static const int	kDefaultBufferSize = 16 * 1024

static const int	kDefaultWriteBufferSize = 32 * 1024

Protected Types inherited from TcpSession
typedef boost::intrusive_ptr < TcpSession >	TcpSessionPtr

typedef boost::asio::strand < boost::asio::io_context::executor_type >	Strand

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 622 of file ksync_sock.h.

Constructor & Destructor Documentation

KSyncSockTcpSession::KSyncSockTcpSession	(	TcpServer *	server,
		Socket *	sock,
		bool	async_ready = `false`
	)

Definition at line 292 of file ksync_sock_tcp.cc.

Here is the call graph for this function:

KSyncSockTcpSession::~KSyncSockTcpSession ( )

virtual

Definition at line 299 of file ksync_sock_tcp.cc.

Member Function Documentation

void KSyncSockTcpSession::OnRead ( Buffer buffer )

protectedvirtual

Implements TcpSession.

Definition at line 305 of file ksync_sock_tcp.cc.

Here is the call graph for this function:

Member Data Documentation

KSyncSockTcpSessionReader* KSyncSockTcpSession::reader_

private

Definition at line 630 of file ksync_sock.h.

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

Public Member Functions

Protected Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation