#include <ksync_sock.h>

Inheritance diagram for KSyncSockNetlink:

Collaboration diagram for KSyncSockNetlink:

[legend]

Public Member Functions
	KSyncSockNetlink (boost::asio::io_context &ios, int protocol)

virtual	~KSyncSockNetlink ()

virtual uint32_t	GetSeqno (char *data)

virtual bool	IsMoreData (char *data)

virtual bool	BulkDecoder (char data, KSyncBulkSandeshContext ctxt)

virtual bool	Decoder (char data, AgentSandeshContext ctxt)

virtual bool	Validate (char *data)

virtual void	AsyncReceive (boost::asio::mutable_buffers_1, HandlerCb)

virtual void	AsyncSendTo (KSyncBufferList *iovec, uint32_t seq_no, HandlerCb cb)

virtual std::size_t	SendTo (KSyncBufferList *iovec, uint32_t seq_no)

virtual void	Receive (boost::asio::mutable_buffers_1)

Public Member Functions inherited from KSyncSock
	KSyncSock ()

virtual	~KSyncSock ()

void	SendAsync (KSyncEntry entry, int msg_len, char msg, KSyncEntry::KSyncEvent event)

std::size_t	BlockingSend (char *msg, int msg_len)

bool	BlockingRecv ()

void	GenericSend (IoContext *ctx)

uint32_t	AllocSeqNo (IoContext::Type type)

uint32_t	AllocSeqNo (IoContext::Type type, uint32_t instance)

KSyncReceiveQueue *	GetReceiveQueue (IoContext::Type type, uint32_t instance)

KSyncReceiveQueue *	GetReceiveQueue (uint32_t seqno)

KSyncBulkMsgContext *	LocateBulkContext (uint32_t seqno, IoContext::Type io_context_type, uint32_t work_queue_index)

int	SendBulkMessage (KSyncBulkMsgContext *bulk_context, uint32_t seqno)

bool	TryAddToBulk (KSyncBulkMsgContext bulk_context, IoContext ioc)

void	OnEmptyQueue (bool done)

int	tx_count () const

const KSyncTxQueue *	send_queue () const

const KSyncReceiveQueue *	get_receive_work_queue (uint16_t index) const

KSyncReceiveQueue *	AllocQueue (KSyncBulkSandeshContext ctxt[], uint32_t task_id, uint32_t instance, const char *name)

uint32_t	WaitTreeSize () const

void	SetSeqno (uint32_t seq)

void	SetMeasureQueueDelay (bool val)

void	reset_use_wait_tree ()

void	set_process_data_inline ()

void	EnqueueRxProcessData (KSyncEntry *entry, KSyncEntry::KSyncEvent event)

Static Public Member Functions
static void	NetlinkDecoder (char data, SandeshContext ctxt)

static void	NetlinkBulkDecoder (char data, SandeshContext ctxt, bool more)

static void	Init (boost::asio::io_context &ios, int protocol, bool use_work_queue, const std::string &cpu_pin_policy)

Static Public Member Functions inherited from KSyncSock
static void	Start (bool read_inline)

static void	Shutdown ()

static KSyncSock *	Get (DBTablePartBase *partition)

static KSyncSock *	Get (int partition_id)

static uint32_t	GetPid ()

static int	GetNetlinkFamilyId ()

static void	SetNetlinkFamilyId (int id)

static AgentSandeshContext *	GetAgentSandeshContext (uint32_t type)

static void	SetAgentSandeshContext (AgentSandeshContext *ctx, uint32_t idx)

Private Attributes
boost::asio::netlink::raw::socket	sock_

Additional Inherited Members
Public Types inherited from KSyncSock
typedef std::map< uint32_t, KSyncBulkMsgContext >	WaitTree

typedef std::pair< uint32_t, KSyncBulkMsgContext >	WaitTreePair

typedef boost::function< void(const boost::system::error_code &, size_t)>	HandlerCb

typedef WorkQueue< KSyncRxData >	KSyncReceiveQueue

typedef WorkQueue< KSyncRxQueueData >	KSyncRxWorkQueue

Static Public Attributes inherited from KSyncSock
static const int	kRxWorkQueueCount = 2

static const int	kMsgGrowSize = 16

static const unsigned	kBufLen = (4*1024)

static const unsigned	kMaxBulkMsgCount = 16

static const unsigned	kInvalidBulkSeqNo = 0xFFFFFFFF

Protected Member Functions inherited from KSyncSock
bool	ValidateAndEnqueue (char data, KSyncBulkMsgContext context)

KSyncBulkSandeshContext *	GetBulkSandeshContext (uint32_t seqno)

void	ProcessDataInline (char *data)

Static Protected Member Functions inherited from KSyncSock
static void	Init (bool use_work_queue, const std::string &cpu_pin_policy)

static void	SetSockTableEntry (KSyncSock *sock)

Protected Attributes inherited from KSyncSock
tbb::mutex	mutex_

nl_client *	nl_client_

WaitTree	wait_tree_

KSyncTxQueue	send_queue_

KSyncReceiveQueue *	uve_rx_queue [kRxWorkQueueCount]

KSyncReceiveQueue *	ksync_rx_queue [kRxWorkQueueCount]

uint32_t	max_bulk_msg_count_

uint32_t	max_bulk_buf_size_

uint32_t	bulk_seq_no_

uint32_t	bulk_buf_size_

uint32_t	bulk_msg_count_

uint32_t	bmca_prod_

uint32_t	bmca_cons_

KSyncBulkMsgContext *	bulk_mctx_arr_ [KSYNC_BMC_ARR_SIZE]

Detailed Description

Definition at line 516 of file ksync_sock.h.

Constructor & Destructor Documentation

◆ KSyncSockNetlink()

KSyncSockNetlink::KSyncSockNetlink	(	boost::asio::io_context &	ios,
		int	protocol
	)

Definition at line 645 of file ksync_sock.cc.

◆ ~KSyncSockNetlink()

KSyncSockNetlink::~KSyncSockNetlink ( )

virtual

Definition at line 662 of file ksync_sock.cc.

Member Function Documentation

◆ AsyncReceive()

void KSyncSockNetlink::AsyncReceive	(	boost::asio::mutable_buffers_1	,
		HandlerCb
	)

virtual

Implements KSyncSock.

Definition at line 742 of file ksync_sock.cc.

◆ AsyncSendTo()

void KSyncSockNetlink::AsyncSendTo	(	KSyncBufferList *	iovec,
		uint32_t	seq_no,
		HandlerCb	cb
	)

virtual

Implements KSyncSock.

Definition at line 684 of file ksync_sock.cc.

Here is the call graph for this function:

◆ BulkDecoder()

bool KSyncSockNetlink::BulkDecoder	(	char *	data,
		KSyncBulkSandeshContext *	ctxt
	)

virtual

Implements KSyncSock.

Definition at line 733 of file ksync_sock.cc.

Here is the call graph for this function:

◆ Decoder()

bool KSyncSockNetlink::Decoder	(	char *	data,
		AgentSandeshContext *	ctxt
	)

virtual

Implements KSyncSock.

Definition at line 716 of file ksync_sock.cc.

Here is the call graph for this function:

◆ GetSeqno()

uint32_t KSyncSockNetlink::GetSeqno ( char * data )

virtual

Implements KSyncSock.

Definition at line 671 of file ksync_sock.cc.

Here is the call graph for this function:

◆ Init()

void KSyncSockNetlink::Init	(	boost::asio::io_context &	ios,
		int	protocol,
		bool	use_work_queue,
		const std::string &	cpu_pin_policy
	)

static

Definition at line 665 of file ksync_sock.cc.

Here is the call graph for this function:

◆ IsMoreData()

bool KSyncSockNetlink::IsMoreData ( char * data )

virtual

Implements KSyncSock.

Definition at line 675 of file ksync_sock.cc.

Here is the call graph for this function:

◆ NetlinkBulkDecoder()

void KSyncSockNetlink::NetlinkBulkDecoder	(	char *	data,
		SandeshContext *	ctxt,
		bool	more
	)

static

Definition at line 722 of file ksync_sock.cc.

Here is the call graph for this function:

◆ NetlinkDecoder()

void KSyncSockNetlink::NetlinkDecoder	(	char *	data,
		SandeshContext *	ctxt
	)

static

Definition at line 708 of file ksync_sock.cc.

Here is the call graph for this function:

◆ Receive()

void KSyncSockNetlink::Receive ( boost::asio::mutable_buffers_1 )

virtual

Implements KSyncSock.

Definition at line 746 of file ksync_sock.cc.

◆ SendTo()

size_t KSyncSockNetlink::SendTo	(	KSyncBufferList *	iovec,
		uint32_t	seq_no
	)

virtual

Implements KSyncSock.

Definition at line 696 of file ksync_sock.cc.

Here is the call graph for this function:

◆ Validate()

bool KSyncSockNetlink::Validate ( char * data )

virtual

Implements KSyncSock.

Definition at line 679 of file ksync_sock.cc.

Here is the call graph for this function:

Member Data Documentation

◆ sock_

boost::asio::netlink::raw::socket KSyncSockNetlink::sock_

private

Definition at line 537 of file ksync_sock.h.

The documentation for this class was generated from the following files:

Public Member Functions

Static Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ KSyncSockNetlink()

◆ ~KSyncSockNetlink()

Member Function Documentation

◆ AsyncReceive()

◆ AsyncSendTo()

◆ BulkDecoder()

◆ Decoder()

◆ GetSeqno()

◆ Init()

◆ IsMoreData()

◆ NetlinkBulkDecoder()

◆ NetlinkDecoder()

◆ Receive()

◆ SendTo()

◆ Validate()

Member Data Documentation

◆ sock_