OpenSDN source code
|
This is the complete list of members for KSyncSock, including all inherited members.
ack_count_ | KSyncSock | private |
agent_sandesh_ctx_ | KSyncSock | privatestatic |
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)=0 | KSyncSock | privatepure virtual |
AsyncSendTo(KSyncBufferList *iovec, uint32_t seq_no, HandlerCb cb)=0 | KSyncSock | privatepure 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_context_ | KSyncSock | private |
bulk_msg_count_ | KSyncSock | protected |
bulk_seq_no_ | KSyncSock | protected |
BulkDecoder(char *data, KSyncBulkSandeshContext *ctxt)=0 | KSyncSock | pure virtual |
Decoder(char *data, AgentSandeshContext *ctxt)=0 | KSyncSock | pure virtual |
DISALLOW_COPY_AND_ASSIGN(KSyncSock) | KSyncSock | private |
EnqueueRxProcessData(KSyncEntry *entry, KSyncEntry::KSyncEvent event) | KSyncSock | |
err_count_ | KSyncSock | 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 |
GetNetlinkFamilyId() | KSyncSock | inlinestatic |
GetPid() | KSyncSock | inlinestatic |
GetReceiveQueue(IoContext::Type type, uint32_t instance) | KSyncSock | |
GetReceiveQueue(uint32_t seqno) | KSyncSock | |
GetSeqno(char *data)=0 | KSyncSock | privatepure virtual |
HandlerCb typedef | KSyncSock | |
Init(bool use_work_queue, const std::string &cpu_pin_policy) | KSyncSock | protectedstatic |
IsMoreData(char *data)=0 | KSyncSock | privatepure virtual |
kBufLen | KSyncSock | static |
kInvalidBulkSeqNo | KSyncSock | static |
kMaxBulkMsgCount | KSyncSock | static |
kMaxBulkMsgSize | KSyncSock | static |
kMsgGrowSize | KSyncSock | static |
kRxWorkQueueCount | KSyncSock | static |
ksync_bulk_sandesh_context_ | KSyncSock | private |
ksync_rx_queue | KSyncSock | protected |
KSyncReceiveQueue typedef | KSyncSock | |
KSyncRxWorkQueue typedef | KSyncSock | |
KSyncSock() | KSyncSock | |
KSyncTxQueue class | KSyncSock | friend |
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 |
mutex_ | KSyncSock | protected |
nl_client_ | KSyncSock | protected |
OnEmptyQueue(bool done) | KSyncSock | |
pid_ | KSyncSock | privatestatic |
process_data_inline_ | KSyncSock | private |
ProcessDataInline(char *data) | KSyncSock | protected |
ProcessKernelData(KSyncBulkSandeshContext *ksync_context, const KSyncRxData &data) | KSyncSock | private |
ProcessRxData(KSyncRxQueueData data) | KSyncSock | private |
read_inline_ | KSyncSock | private |
ReadHandler(const boost::system::error_code &error, size_t bytes_transferred) | KSyncSock | private |
Receive(boost::asio::mutable_buffers_1)=0 | KSyncSock | privatepure virtual |
reset_use_wait_tree() | KSyncSock | inline |
rx_buff_ | KSyncSock | private |
rx_process_queue_ | KSyncSock | private |
send_queue() const | KSyncSock | inline |
send_queue_ | KSyncSock | protected |
SendAsync(KSyncEntry *entry, int msg_len, char *msg, KSyncEntry::KSyncEvent event) | KSyncSock | |
SendAsyncImpl(IoContext *ioc) | KSyncSock | private |
SendAsyncStart() | KSyncSock | inlineprivate |
SendBulkMessage(KSyncBulkMsgContext *bulk_context, uint32_t seqno) | KSyncSock | |
SendTo(KSyncBufferList *iovec, uint32_t seq_no)=0 | KSyncSock | privatepure virtual |
seqno_ | KSyncSock | private |
set_process_data_inline() | KSyncSock | inline |
SetAgentSandeshContext(AgentSandeshContext *ctx, uint32_t idx) | KSyncSock | inlinestatic |
SetMeasureQueueDelay(bool val) | KSyncSock | |
SetNetlinkFamilyId(int id) | KSyncSock | static |
SetSeqno(uint32_t seq) | KSyncSock | |
SetSockTableEntry(KSyncSock *sock) | KSyncSock | protectedstatic |
Shutdown() | KSyncSock | static |
shutdown_ | KSyncSock | privatestatic |
sock_ | KSyncSock | privatestatic |
Start(bool read_inline) | KSyncSock | static |
TryAddToBulk(KSyncBulkMsgContext *bulk_context, IoContext *ioc) | KSyncSock | |
tx_count() const | KSyncSock | inline |
tx_count_ | KSyncSock | private |
use_wait_tree_ | KSyncSock | private |
uve_bulk_sandesh_context_ | KSyncSock | private |
uve_rx_queue | KSyncSock | protected |
uve_seqno_ | KSyncSock | private |
Validate(char *data)=0 | KSyncSock | privatepure virtual |
ValidateAndEnqueue(char *data, KSyncBulkMsgContext *context) | KSyncSock | protected |
vnsw_netlink_family_id_ | KSyncSock | privatestatic |
wait_tree_ | KSyncSock | protected |
WaitTree typedef | KSyncSock | |
WaitTreePair typedef | KSyncSock | |
WaitTreeSize() const | KSyncSock | |
WriteHandler(const boost::system::error_code &error, size_t bytes_transferred) | KSyncSock | private |
~KSyncSock() | KSyncSock | virtual |