OpenSDN source code
KSyncSockUdp Member List

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

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
AsyncReceive(boost::asio::mutable_buffers_1, HandlerCb)KSyncSockUdpvirtual
AsyncSendTo(KSyncBufferList *iovec, uint32_t seq_no, HandlerCb cb)KSyncSockUdpvirtual
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)KSyncSockUdpvirtual
Decoder(char *data, AgentSandeshContext *ctxt)KSyncSockUdpvirtual
DISALLOW_COPY_AND_ASSIGN(KSyncSock)KSyncSockprivate
EnqueueRxProcessData(KSyncEntry *entry, KSyncEntry::KSyncEvent event)KSyncSock
err_count_KSyncSockprivate
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
GetNetlinkFamilyId()KSyncSockinlinestatic
GetPid()KSyncSockinlinestatic
GetReceiveQueue(IoContext::Type type, uint32_t instance)KSyncSock
GetReceiveQueue(uint32_t seqno)KSyncSock
GetSeqno(char *data)KSyncSockUdpvirtual
HandlerCb typedefKSyncSock
Init(boost::asio::io_context &ios, int port, const std::string &cpu_pin_policy)KSyncSockUdpstatic
KSyncSock::Init(bool use_work_queue, const std::string &cpu_pin_policy)KSyncSockprotectedstatic
IsMoreData(char *data)KSyncSockUdpvirtual
kBufLenKSyncSockstatic
kInvalidBulkSeqNoKSyncSockstatic
kMaxBulkMsgCountKSyncSockstatic
kMsgGrowSizeKSyncSockstatic
kRxWorkQueueCountKSyncSockstatic
ksync_bulk_sandesh_context_KSyncSockprivate
ksync_rx_queueKSyncSockprotected
KSyncReceiveQueue typedefKSyncSock
KSyncRxWorkQueue typedefKSyncSock
KSyncSock()KSyncSock
KSyncSockUdp(boost::asio::io_context &ios, int port)KSyncSockUdp
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
mutex_KSyncSockprotected
nl_client_KSyncSockprotected
OnEmptyQueue(bool done)KSyncSock
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)KSyncSockUdpvirtual
reset_use_wait_tree()KSyncSockinline
rx_buff_KSyncSockprivate
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)KSyncSockUdpvirtual
seqno_KSyncSockprivate
server_ep_KSyncSockUdpprivate
set_process_data_inline()KSyncSockinline
SetAgentSandeshContext(AgentSandeshContext *ctx, uint32_t idx)KSyncSockinlinestatic
SetMeasureQueueDelay(bool val)KSyncSock
SetNetlinkFamilyId(int id)KSyncSockstatic
SetSeqno(uint32_t seq)KSyncSock
SetSockTableEntry(KSyncSock *sock)KSyncSockprotectedstatic
Shutdown()KSyncSockstatic
shutdown_KSyncSockprivatestatic
sock_KSyncSockUdpprivate
Start(bool read_inline)KSyncSockstatic
TryAddToBulk(KSyncBulkMsgContext *bulk_context, IoContext *ioc)KSyncSock
tx_count() constKSyncSockinline
tx_count_KSyncSockprivate
use_wait_tree_KSyncSockprivate
uve_bulk_sandesh_context_KSyncSockprivate
uve_rx_queueKSyncSockprotected
uve_seqno_KSyncSockprivate
Validate(char *data)KSyncSockUdpvirtual
ValidateAndEnqueue(char *data, KSyncBulkMsgContext *context)KSyncSockprotected
vnsw_netlink_family_id_KSyncSockprivatestatic
wait_tree_KSyncSockprotected
WaitTree typedefKSyncSock
WaitTreePair typedefKSyncSock
WaitTreeSize() constKSyncSock
WriteHandler(const boost::system::error_code &error, size_t bytes_transferred)KSyncSockprivate
~KSyncSock()KSyncSockvirtual
~KSyncSockUdp()KSyncSockUdpinlinevirtual