OpenSDN source code
KSyncSockTcp Member List

This is the complete list of members for KSyncSockTcp, including all inherited members.

accept_socket() constTcpServerprotectedvirtual
AcceptHandlerComplete(TcpSessionPtr session)TcpServerprotectedvirtual
AcceptHandlerInternal(TcpServerPtr server, const boost::system::error_code &error)TcpServerprivate
acceptor_TcpServerprivate
AcceptSession(TcpSession *session)TcpServerprotectedvirtual
ack_count_KSyncSockprivate
agent_sandesh_ctx_KSyncSockprivatestatic
AllocQueue(KSyncBulkSandeshContext ctxt[], uint32_t task_id, uint32_t instance, const char *name)KSyncSock
AllocSeqNo(IoContext::Type type)KSyncSock
AllocSeqNo(IoContext::Type type, uint32_t instance)KSyncSock
AllocSession(Socket *socket)KSyncSockTcpvirtual
TcpServer::AllocSession(bool server_session)TcpServerprotectedvirtual
AsyncAccept()TcpServerprivate
AsyncReadStart()KSyncSockTcp
AsyncReceive(boost::asio::mutable_buffers_1, HandlerCb)KSyncSockTcpvirtual
AsyncSendTo(KSyncBufferList *iovec, uint32_t seq_no, HandlerCb cb)KSyncSockTcpvirtual
BlockingRecv()KSyncSock
BlockingSend(char *msg, int msg_len)KSyncSock
bmca_cons_KSyncSockprotected
bmca_prod_KSyncSockprotected
bulk_buf_size_KSyncSockprotected
bulk_mctx_arr_KSyncSockprotected
bulk_msg_context_KSyncSockprivate
bulk_msg_count_KSyncSockprotected
bulk_seq_no_KSyncSockprotected
BulkDecoder(char *data, KSyncBulkSandeshContext *ctxt)KSyncSockTcpvirtual
ClearSessions()TcpServer
cond_var_TcpServerprivate
Connect(TcpSession *session, Endpoint remote)TcpServervirtual
connect_complete() constKSyncSockTcpinline
connect_complete_KSyncSockTcpprivate
ConnectHandler(TcpServerPtr server, TcpSessionPtr session, const boost::system::error_code &error)TcpServerprivate
ConnectHandlerComplete(TcpSessionPtr session)TcpServerprotectedvirtual
CreateSession()TcpServervirtual
Decoder(char *data, AgentSandeshContext *ctxt)KSyncSockTcpvirtual
DeleteSession(TcpSession *session)TcpServervirtual
DisableSandeshLogMessages() constTcpServerinlinevirtual
KSyncSock::DISALLOW_COPY_AND_ASSIGN(KSyncSock)KSyncSockprivate
Endpoint typedefTcpServer
EnqueueRxProcessData(KSyncEntry *entry, KSyncEntry::KSyncEvent event)KSyncSock
err_count_KSyncSockprivate
event_manager()TcpServerinline
evm_KSyncSockTcpprivate
GenericSend(IoContext *ctx)KSyncSock
Get(DBTablePartBase *partition)KSyncSockstatic
Get(int partition_id)KSyncSockstatic
get_receive_work_queue(uint16_t index) constKSyncSockinline
GetAgentSandeshContext(uint32_t type)KSyncSockinlinestatic
GetBulkSandeshContext(uint32_t seqno)KSyncSockprotected
GetDscpValue(NativeSocketType fd) constTcpServer
GetNetlinkFamilyId()KSyncSockinlinestatic
GetPid()KSyncSockinlinestatic
GetPort() constTcpServer
GetReceiveQueue(IoContext::Type type, uint32_t instance)KSyncSock
GetReceiveQueue(uint32_t seqno)KSyncSock
GetRxSocketStats(SocketIOStats *socket_stats) constTcpServer
GetRxSocketStats(SocketIOStats &socket_stats) constTcpServerinline
GetSeqno(char *data)KSyncSockTcpvirtual
GetSession(Endpoint remote)TcpServer
GetSessionCount() constTcpServerinline
GetSocketStats() constTcpServerinline
GetTxSocketStats(SocketIOStats *socket_stats) constTcpServer
GetTxSocketStats(SocketIOStats &socket_stats) constTcpServerinline
HandlerCb typedefKSyncSock
HasSessionReadAvailable() constTcpServer
HasSessions() constTcpServer
Init(EventManager *evm, boost::asio::ip::address ip_addr, int port, const std::string &cpu_pin_policy)KSyncSockTcpstatic
KSyncSock::Init(bool use_work_queue, const std::string &cpu_pin_policy)KSyncSockprotectedstatic
Initialize(unsigned short port)TcpServervirtual
Initialize(unsigned short port, const IpAddress &host_ip, int intf_id=-1)TcpServervirtual
InitializeInternal(boost::asio::ip::tcp::endpoint localaddr)TcpServer
InsertSessionToMap(Endpoint remote, TcpSession *session)TcpServerprivate
intf_id_TcpServerprivate
IsMoreData(char *data)KSyncSockTcpvirtual
kBufLenKSyncSockstatic
kInvalidBulkSeqNoKSyncSockstatic
kMaxBulkMsgCountKSyncSockstatic
kMsgGrowSizeKSyncSockstatic
kRxWorkQueueCountKSyncSockstatic
ksync_bulk_sandesh_context_KSyncSockprivate
ksync_rx_queueKSyncSockprotected
KSyncReceiveQueue typedefKSyncSock
KSyncRxWorkQueue typedefKSyncSock
KSyncSock()KSyncSock
KSyncSockTcp(EventManager *evm, boost::asio::ip::address ip_addr, int port)KSyncSockTcp
LocalEndpoint() constTcpServerprotected
LocateBulkContext(uint32_t seqno, IoContext::Type io_context_type, uint32_t work_queue_index)KSyncSock
max_bulk_buf_size_KSyncSockprotected
max_bulk_msg_count_KSyncSockprotected
KSyncSock::mutex_KSyncSockprotected
name_TcpServerprivate
NativeSocketType typedefTcpServer
nl_client_KSyncSockprotected
OnEmptyQueue(bool done)KSyncSock
OnSessionClose(TcpSession *session)TcpServerprivate
OnSessionEvent(TcpSession *session, TcpSession::Event event)KSyncSockTcp
pid_KSyncSockprivatestatic
process_data_inline_KSyncSockprivate
ProcessDataInline(char *data)KSyncSockprotected
ProcessKernelData(KSyncBulkSandeshContext *ksync_context, const KSyncRxData &data)KSyncSockprivate
ProcessRxData(KSyncRxQueueData data)KSyncSockprivate
read_inline_KSyncSockprivate
ReadHandler(const boost::system::error_code &error, size_t bytes_transferred)KSyncSockprivate
Receive(boost::asio::mutable_buffers_1)KSyncSockTcpvirtual
ReceiveMsg(const u_int8_t *msg, size_t size)KSyncSockTcp
refcount_TcpServerprivate
remain_KSyncSockTcpprivate
RemoveSessionFromMap(Endpoint remote, TcpSession *session)TcpServerprivate
reset_use_wait_tree()KSyncSockinline
ResetAcceptor()TcpServer
Run(void)KSyncSockTcpvirtual
rx_buff_KSyncSockTcpprivate
rx_buff_rem_KSyncSockTcpprivate
rx_process_queue_KSyncSockprivate
send_queue() constKSyncSockinline
send_queue_KSyncSockprotected
SendAsync(KSyncEntry *entry, int msg_len, char *msg, KSyncEntry::KSyncEvent event)KSyncSock
SendAsyncImpl(IoContext *ioc)KSyncSockprivate
SendAsyncStart()KSyncSockinlineprivate
SendBulkMessage(KSyncBulkMsgContext *bulk_context, uint32_t seqno)KSyncSock
SendTo(KSyncBufferList *iovec, uint32_t seq_no)KSyncSockTcpvirtual
seqno_KSyncSockprivate
server_ep_KSyncSockTcpprivate
session_KSyncSockTcpprivate
session_map_TcpServerprivate
session_ref_TcpServerprivate
SessionMap typedefTcpServerprivate
SessionSet typedefTcpServerprivate
set_accept_socket()TcpServerprotectedvirtual
set_process_data_inline()KSyncSockinline
set_socket_open_failure(bool flag)TcpServerinlineprotected
SetAcceptor()TcpServer
SetAgentSandeshContext(AgentSandeshContext *ctx, uint32_t idx)KSyncSockinlinestatic
SetDscpSocketOption(NativeSocketType fd, uint8_t value)TcpServer
SetKeepAliveSocketOption(int fd, const SandeshConfig &sandesh_config)TcpServer
SetListenSocketDscp(uint8_t value)TcpServer
SetListenSocketMd5Option(uint32_t peer_ip, const std::string &md5_password)TcpServer
SetMd5SocketOption(NativeSocketType fd, uint32_t peer_ip, const std::string &md5_password)TcpServer
SetMeasureQueueDelay(bool val)KSyncSock
SetName(Endpoint local_endpoint)TcpServerprivate
SetNetlinkFamilyId(int id)KSyncSockstatic
SetSeqno(uint32_t seq)KSyncSock
SetSocketOptions(const SandeshConfig &sandesh_config)TcpServer
SetSockTableEntry(KSyncSock *sock)KSyncSockprotectedstatic
KSyncSock::Shutdown()KSyncSockstatic
TcpServer::Shutdown()TcpServer
shutdown_KSyncSockprivatestatic
so_accept_TcpServerprivate
sock_KSyncSockprivatestatic
Socket typedefTcpServer
socket_open_failure() constTcpServerinlineprotected
socket_open_failure_TcpServerprivate
Start(bool read_inline)KSyncSockstatic
stats_TcpServerprivate
tcp_socket_KSyncSockTcpprivate
TcpServer(EventManager *evm)TcpServerexplicit
TcpServerPtr typedefTcpServerprotected
TcpSessionPtr typedefTcpServerprotected
ToString() constTcpServerinline
TryAddToBulk(KSyncBulkMsgContext *bulk_context, IoContext *ioc)KSyncSock
tx_count() constKSyncSockinline
tx_count_KSyncSockprivate
UpdateSessionsDscp(uint8_t dscp)TcpServer
use_wait_tree_KSyncSockprivate
uve_bulk_sandesh_context_KSyncSockprivate
uve_rx_queueKSyncSockprotected
uve_seqno_KSyncSockprivate
Validate(char *data)KSyncSockTcpvirtual
ValidateAndEnqueue(char *data, KSyncBulkMsgContext *context)KSyncSockprotected
vnsw_netlink_family_id_KSyncSockprivatestatic
wait_tree_KSyncSockprotected
WaitForEmpty()TcpServer
WaitTree typedefKSyncSock
WaitTreePair typedefKSyncSock
WaitTreeSize() constKSyncSock
WriteHandler(const boost::system::error_code &error, size_t bytes_transferred)KSyncSockprivate
~KSyncSock()KSyncSockvirtual
~KSyncSockTcp()KSyncSockTcpinlinevirtual
~TcpServer()TcpServervirtual