OpenSDN source code
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
KSyncSockUds Member List

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

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)KSyncSockUdsvirtual
AsyncSendTo(KSyncBufferList *iovec, uint32_t seq_no, HandlerCb cb)KSyncSockUdsvirtual
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_count_KSyncSockprotected
bulk_seq_no_KSyncSockprotected
BulkDecoder(char *data, KSyncBulkSandeshContext *ctxt)KSyncSockUdsvirtual
connected_KSyncSockUdsprivate
Decoder(char *data, AgentSandeshContext *ctxt)KSyncSockUdsvirtual
EnqueueRxProcessData(KSyncEntry *entry, KSyncEntry::KSyncEvent event)KSyncSock
GenericSend(IoContext *ctx)KSyncSock
Get(DBTablePartBase *partition)KSyncSockstatic
Get(int partition_id)KSyncSockstatic
get_receive_work_queue(uint16_t index) const KSyncSockinline
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)KSyncSockUdsvirtual
HandlerCb typedefKSyncSock
Init(boost::asio::io_context &ios, const std::string &cpu_pin_policy, const std::string &sockpathvr="")KSyncSockUdsstatic
KSyncSock::Init(bool use_work_queue, const std::string &cpu_pin_policy)KSyncSockprotectedstatic
IsMoreData(char *data)KSyncSockUdsvirtual
kBufLenKSyncSockstatic
kInvalidBulkSeqNoKSyncSockstatic
kMaxBulkMsgCountKSyncSockstatic
kMaxBulkMsgSizeKSyncSockstatic
kMsgGrowSizeKSyncSockstatic
kRxWorkQueueCountKSyncSockstatic
ksync_rx_queueKSyncSockprotected
KSyncReceiveQueue typedefKSyncSock
KSyncRxWorkQueue typedefKSyncSock
KSyncSock()KSyncSock
KSyncSockUds(boost::asio::io_context &ios)KSyncSockUds
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
ProcessDataInline(char *data)KSyncSockprotected
Receive(boost::asio::mutable_buffers_1)KSyncSockUdsvirtual
remain_KSyncSockUdsprivate
reset_use_wait_tree()KSyncSockinline
Run(void)KSyncSockUdsvirtual
rx_buff_KSyncSockUdsprivate
rx_buff_q_KSyncSockUdsprivate
send_queue() const KSyncSockinline
send_queue_KSyncSockprotected
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)KSyncSockUdsvirtual
server_ep_KSyncSockUdsprivate
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
sock_KSyncSockUdsprivate
socket_KSyncSockUdsprivate
sockpath_KSyncSockUdsprivatestatic
Start(bool read_inline)KSyncSockstatic
TryAddToBulk(KSyncBulkMsgContext *bulk_context, IoContext *ioc)KSyncSock
tx_count() const KSyncSockinline
uve_rx_queueKSyncSockprotected
Validate(char *data)KSyncSockUdsvirtual
ValidateAndEnqueue(char *data, KSyncBulkMsgContext *context)KSyncSockprotected
wait_tree_KSyncSockprotected
WaitTree typedefKSyncSock
WaitTreePair typedefKSyncSock
WaitTreeSize() const KSyncSock
~KSyncSock()KSyncSockvirtual
~KSyncSockUds()KSyncSockUdsinlinevirtual