OpenSDN source code
|
This is the complete list of members for KSyncSockTcp, including all inherited members.
accept_socket() const | TcpServer | protectedvirtual |
AcceptHandlerComplete(TcpSessionPtr session) | TcpServer | protectedvirtual |
AcceptSession(TcpSession *session) | TcpServer | protectedvirtual |
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) | KSyncSockTcp | virtual |
TcpServer::AllocSession(bool server_session) | TcpServer | protectedvirtual |
AsyncReadStart() | KSyncSockTcp | |
AsyncReceive(boost::asio::mutable_buffers_1, HandlerCb) | KSyncSockTcp | virtual |
AsyncSendTo(KSyncBufferList *iovec, uint32_t seq_no, HandlerCb cb) | KSyncSockTcp | virtual |
BlockingRecv() | KSyncSock | |
BlockingSend(char *msg, int msg_len) | KSyncSock | |
bmca_cons_ | KSyncSock | protected |
bmca_prod_ | KSyncSock | protected |
bulk_buf_size_ | KSyncSock | protected |
bulk_mctx_arr_ | KSyncSock | protected |
bulk_msg_count_ | KSyncSock | protected |
bulk_seq_no_ | KSyncSock | protected |
BulkDecoder(char *data, KSyncBulkSandeshContext *ctxt) | KSyncSockTcp | virtual |
ClearSessions() | TcpServer | |
Connect(TcpSession *session, Endpoint remote) | TcpServer | virtual |
connect_complete() const | KSyncSockTcp | inline |
connect_complete_ | KSyncSockTcp | private |
ConnectHandlerComplete(TcpSessionPtr session) | TcpServer | protectedvirtual |
CreateSession() | TcpServer | virtual |
Decoder(char *data, AgentSandeshContext *ctxt) | KSyncSockTcp | virtual |
DeleteSession(TcpSession *session) | TcpServer | virtual |
DisableSandeshLogMessages() const | TcpServer | inlinevirtual |
Endpoint typedef | TcpServer | |
EnqueueRxProcessData(KSyncEntry *entry, KSyncEntry::KSyncEvent event) | KSyncSock | |
event_manager() | TcpServer | inline |
evm_ | KSyncSockTcp | private |
GenericSend(IoContext *ctx) | KSyncSock | |
Get(DBTablePartBase *partition) | KSyncSock | static |
Get(int partition_id) | KSyncSock | static |
get_receive_work_queue(uint16_t index) const | KSyncSock | inline |
GetAgentSandeshContext(uint32_t type) | KSyncSock | inlinestatic |
GetBulkSandeshContext(uint32_t seqno) | KSyncSock | protected |
GetDscpValue(NativeSocketType fd) const | TcpServer | |
GetNetlinkFamilyId() | KSyncSock | inlinestatic |
GetPid() | KSyncSock | inlinestatic |
GetPort() const | TcpServer | |
GetReceiveQueue(IoContext::Type type, uint32_t instance) | KSyncSock | |
GetReceiveQueue(uint32_t seqno) | KSyncSock | |
GetRxSocketStats(SocketIOStats *socket_stats) const | TcpServer | |
GetRxSocketStats(SocketIOStats &socket_stats) const | TcpServer | inline |
GetSeqno(char *data) | KSyncSockTcp | virtual |
GetSession(Endpoint remote) | TcpServer | |
GetSessionCount() const | TcpServer | inline |
GetSocketStats() const | TcpServer | inline |
GetTxSocketStats(SocketIOStats *socket_stats) const | TcpServer | |
GetTxSocketStats(SocketIOStats &socket_stats) const | TcpServer | inline |
HandlerCb typedef | KSyncSock | |
HasSessionReadAvailable() const | TcpServer | |
HasSessions() const | TcpServer | |
Init(EventManager *evm, boost::asio::ip::address ip_addr, int port, const std::string &cpu_pin_policy) | KSyncSockTcp | static |
KSyncSock::Init(bool use_work_queue, const std::string &cpu_pin_policy) | KSyncSock | protectedstatic |
Initialize(unsigned short port) | TcpServer | virtual |
Initialize(unsigned short port, const IpAddress &host_ip, int intf_id=-1) | TcpServer | virtual |
InitializeInternal(boost::asio::ip::tcp::endpoint localaddr) | TcpServer | |
IsMoreData(char *data) | KSyncSockTcp | virtual |
kBufLen | KSyncSock | static |
kInvalidBulkSeqNo | KSyncSock | static |
kMaxBulkMsgCount | KSyncSock | static |
kMaxBulkMsgSize | KSyncSock | static |
kMsgGrowSize | KSyncSock | static |
kRxWorkQueueCount | KSyncSock | static |
ksync_rx_queue | KSyncSock | protected |
KSyncReceiveQueue typedef | KSyncSock | |
KSyncRxWorkQueue typedef | KSyncSock | |
KSyncSock() | KSyncSock | |
KSyncSockTcp(EventManager *evm, boost::asio::ip::address ip_addr, int port) | KSyncSockTcp | |
LocalEndpoint() const | TcpServer | protected |
LocateBulkContext(uint32_t seqno, IoContext::Type io_context_type, uint32_t work_queue_index) | KSyncSock | |
max_bulk_buf_size_ | KSyncSock | protected |
max_bulk_msg_count_ | KSyncSock | protected |
KSyncSock::mutex_ | KSyncSock | protected |
NativeSocketType typedef | TcpServer | |
nl_client_ | KSyncSock | protected |
OnEmptyQueue(bool done) | KSyncSock | |
OnSessionEvent(TcpSession *session, TcpSession::Event event) | KSyncSockTcp | |
ProcessDataInline(char *data) | KSyncSock | protected |
Receive(boost::asio::mutable_buffers_1) | KSyncSockTcp | virtual |
ReceiveMsg(const u_int8_t *msg, size_t size) | KSyncSockTcp | |
remain_ | KSyncSockTcp | private |
reset_use_wait_tree() | KSyncSock | inline |
ResetAcceptor() | TcpServer | |
Run(void) | KSyncSockTcp | virtual |
rx_buff_ | KSyncSockTcp | private |
rx_buff_rem_ | KSyncSockTcp | private |
send_queue() const | KSyncSock | inline |
send_queue_ | KSyncSock | protected |
SendAsync(KSyncEntry *entry, int msg_len, char *msg, KSyncEntry::KSyncEvent event) | KSyncSock | |
SendBulkMessage(KSyncBulkMsgContext *bulk_context, uint32_t seqno) | KSyncSock | |
SendTo(KSyncBufferList *iovec, uint32_t seq_no) | KSyncSockTcp | virtual |
server_ep_ | KSyncSockTcp | private |
session_ | KSyncSockTcp | private |
set_accept_socket() | TcpServer | protectedvirtual |
set_process_data_inline() | KSyncSock | inline |
set_socket_open_failure(bool flag) | TcpServer | inlineprotected |
SetAcceptor() | TcpServer | |
SetAgentSandeshContext(AgentSandeshContext *ctx, uint32_t idx) | KSyncSock | inlinestatic |
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 | |
SetNetlinkFamilyId(int id) | KSyncSock | static |
SetSeqno(uint32_t seq) | KSyncSock | |
SetSocketOptions(const SandeshConfig &sandesh_config) | TcpServer | |
SetSockTableEntry(KSyncSock *sock) | KSyncSock | protectedstatic |
KSyncSock::Shutdown() | KSyncSock | static |
TcpServer::Shutdown() | TcpServer | |
Socket typedef | TcpServer | |
socket_open_failure() const | TcpServer | inlineprotected |
Start(bool read_inline) | KSyncSock | static |
tcp_socket_ | KSyncSockTcp | private |
TcpServer(EventManager *evm) | TcpServer | explicit |
TcpServerPtr typedef | TcpServer | protected |
TcpSessionPtr typedef | TcpServer | protected |
ToString() const | TcpServer | inline |
TryAddToBulk(KSyncBulkMsgContext *bulk_context, IoContext *ioc) | KSyncSock | |
tx_count() const | KSyncSock | inline |
UpdateSessionsDscp(uint8_t dscp) | TcpServer | |
uve_rx_queue | KSyncSock | protected |
Validate(char *data) | KSyncSockTcp | virtual |
ValidateAndEnqueue(char *data, KSyncBulkMsgContext *context) | KSyncSock | protected |
wait_tree_ | KSyncSock | protected |
WaitForEmpty() | TcpServer | |
WaitTree typedef | KSyncSock | |
WaitTreePair typedef | KSyncSock | |
WaitTreeSize() const | KSyncSock | |
~KSyncSock() | KSyncSock | virtual |
~KSyncSockTcp() | KSyncSockTcp | inlinevirtual |
~TcpServer() | TcpServer | virtual |