OpenSDN source code
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Protected Member Functions | Private Member Functions | Private Attributes | List of all members
BgpSession Class Reference

#include <bgp_session.h>

Inheritance diagram for BgpSession:
Inheritance graph
[legend]
Collaboration diagram for BgpSession:
Collaboration graph
[legend]

Public Member Functions

 BgpSession (BgpSessionManager *session_mgr, Socket *socket)
 
virtual ~BgpSession ()
 
void SendNotification (int code, int subcode, const std::string &data=std::string())
 
virtual int GetSessionInstance () const
 
void ProcessWriteReady ()
 
void set_peer (BgpPeer *peer)
 
void clear_peer ()
 
BgpPeer * peer ()
 
void LogNotification (int code, int subcode, const std::string &direction, const std::string &peer_key, const BgpProto::Notification &msg) const
 
- 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)
 

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

bool ReceiveMsg (const u_int8_t *msg, size_t size)
 
virtual void WriteReady (const boost::system::error_code &error)
 
 DISALLOW_COPY_AND_ASSIGN (BgpSession)
 

Private Attributes

BgpSessionManager * session_mgr_
 
BgpPeer * peer_
 
int task_instance_
 
boost::scoped_ptr
< BgpMessageReader > 		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 41 of file bgp_session.h.

Constructor & Destructor Documentation

BgpSession::BgpSession ( BgpSessionManager *  session_mgr,
Socket *  socket 
)

Definition at line 44 of file bgp_session.cc.

BgpSession::~BgpSession ( )
virtual

Definition at line 53 of file bgp_session.cc.

Member Function Documentation

void BgpSession::clear_peer ( )

Definition at line 138 of file bgp_session.cc.

BgpSession::DISALLOW_COPY_AND_ASSIGN ( BgpSession  )
private
virtual int BgpSession::GetSessionInstance ( ) const
inlinevirtual

Reimplemented from TcpSession.

Definition at line 48 of file bgp_session.h.

void BgpSession::LogNotification ( int  code,
int  subcode,
const std::string &  direction,
const std::string &  peer_key,
const BgpProto::Notification &  msg 
) const

Definition at line 97 of file bgp_session.cc.

Here is the call graph for this function:

virtual void BgpSession::OnRead ( Buffer  buffer)
inlineprotectedvirtual

Implements TcpSession.

Definition at line 59 of file bgp_session.h.

BgpPeer* BgpSession::peer ( )
inline

Definition at line 53 of file bgp_session.h.

void BgpSession::ProcessWriteReady ( )

Definition at line 71 of file bgp_session.cc.

Here is the call graph for this function:

bool BgpSession::ReceiveMsg ( const u_int8_t *  msg,
size_t  size 
)
private

Definition at line 59 of file bgp_session.cc.

Here is the call graph for this function:

void BgpSession::SendNotification ( int  code,
int  subcode,
const std::string &  data = std::string() 
)

Definition at line 112 of file bgp_session.cc.

Here is the call graph for this function:

void BgpSession::set_peer ( BgpPeer *  peer)

Definition at line 128 of file bgp_session.cc.

Here is the call graph for this function:

void BgpSession::WriteReady ( const boost::system::error_code &  error)
privatevirtual

Reimplemented from TcpSession.

Definition at line 91 of file bgp_session.cc.

Here is the call graph for this function:

Member Data Documentation

BgpPeer* BgpSession::peer_
private

Definition at line 68 of file bgp_session.h.

boost::scoped_ptr<BgpMessageReader> BgpSession::reader_
private

Definition at line 70 of file bgp_session.h.

BgpSessionManager* BgpSession::session_mgr_
private

Definition at line 67 of file bgp_session.h.

int BgpSession::task_instance_
private

Definition at line 69 of file bgp_session.h.

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