#include <ksync_sock_user.h>

Inheritance diagram for KSyncSockTypeMap:

Collaboration diagram for KSyncSockTypeMap:

[legend]

Public Types
enum	KSyncSockEntryType { KSYNC_FLOW_ENTRY_TYPE = 0 , KSYNC_MAX_ENTRY_TYPE }

typedef std::map< int, vr_nexthop_req >	ksync_map_nh

typedef boost::unordered_map< int, vr_flow_req >	ksync_map_flow

typedef std::map< int, vr_interface_req >	ksync_map_if

typedef std::set< vr_route_req, TestRouteCmp >	ksync_rt_tree

typedef std::map< int, vr_mpls_req >	ksync_map_mpls

typedef std::map< int, vr_mirror_req >	ksync_map_mirror

typedef std::set< vr_vrf_assign_req, TestVrfAssignCmp >	ksync_vrf_assign_tree

typedef std::map< int, vr_vrf_stats_req >	ksync_map_vrf_stats

typedef std::map< int, vr_vxlan_req >	ksync_map_vxlan

typedef std::map< int, vr_vrf_req >	ksync_map_vrf

typedef std::queue< KSyncUserSockContext * >	ksync_map_ctx_queue

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

Public Member Functions
	KSyncSockTypeMap (boost::asio::io_context &ios)

	~KSyncSockTypeMap ()

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)

void	PurgeTxBuffer ()

void	ProcessSandesh (const uint8_t , std::size_t, KSyncUserSockContext )

vr_bridge_entry *	BridgeMmapAlloc (int size)

void	BridgeMmapFree ()

vr_bridge_entry *	GetBridgeEntry (int idx)

void	SetBridgeEntry (uint32_t idx, vr_route_req *req, bool set)

void	UpdateBridgeEntryInactiveFlag (int idx, bool set)

void	SetBlockMsgProcessing (bool enable)

bool	IsBlockMsgProcessing ()

void	set_is_incremental_index (bool incremental)

bool	is_incremental_index ()

void	SetKSyncError (KSyncSockEntryType type, int ksync_error)

int	GetKSyncError (KSyncSockEntryType type)

void	AddNetlinkTxBuff (struct nl_client *cl)

void	InitNetlinkDoneMsg (struct nlmsghdr *nlh, uint32_t seq_num)

void	DisableReceiveQueue (bool disable)

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	set_error_code (int code)

static int	error_code ()

static void	SimulateResponse (uint32_t, int, int)

static void	SendNetlinkDoneMsg (uint32_t seq_num)

static void	IfDumpResponse (uint32_t)

static void	IfNetlinkMsgSend (uint32_t seq_num, ksync_map_if::const_iterator it)

static void	IfStatsUpdate (int, int, int, int, int, int, int)

static void	IfStatsSet (int, int, int, int, int, int, int)

static void	InterfaceAdd (int id, int flags=0, int mac_size=6)

static void	InterfaceDelete (int id)

static void	NHAdd (int id, int flags=0)

static void	NHDelete (int id)

static void	MplsAdd (int id)

static void	MplsDelete (int id)

static void	MirrorAdd (int id)

static void	MirrorDelete (int id)

static void	RouteAdd (vr_route_req &req)

static void	RouteDelete (vr_route_req &req)

static void	VrfAssignAdd (vr_vrf_assign_req &req)

static void	VrfAssignDelete (vr_vrf_assign_req &req)

static void	VrfAdd (vr_vrf_req &req)

static void	VrfDelete (vr_vrf_req &req)

static void	VrfStatsAdd (int vrf_id)

static void	VrfStatsUpdate (int vrf_id, const vr_vrf_stats_req &req)

static void	VrfStatsDelete (int vrf_id)

static void	VxlanAdd (int id)

static void	VxlanDelete (int id)

static void	SetDropStats (const vr_drop_stats_req &req)

static void	SetVRouterOps (const vrouter_ops &req)

static int	IfCount ()

static int	NHCount ()

static int	MplsCount ()

static int	RouteCount ()

static int	VxLanCount ()

static KSyncSockTypeMap *	GetKSyncSockTypeMap ()

static void	Init (boost::asio::io_context &ios)

static void	Shutdown ()

static vr_flow_entry *	FlowMmapAlloc (int size)

static void	FlowMmapFree ()

static vr_flow_entry *	GetFlowEntry (int idx)

static void	SetFlowEntry (vr_flow_req *req, bool set)

static void	IncrFlowStats (int idx, int pkts, int bytes)

static void	SetTcpFlag (int idx, uint32_t flags)

static void	SetOFlowStats (int idx, uint8_t pkts, uint16_t bytes)

static void	SetFlowTcpFlags (int idx, uint16_t flags)

static void	SetEvictedFlag (int idx)

static void	ResetEvictedFlag (int idx)

static void	FlowNatResponse (uint32_t seq_num, vr_flow_req *req, int code=0)

static void	SetUnderlaySourcePort (int idx, int port)

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)

Public Attributes
ksync_map_nh	nh_map

ksync_map_flow	flow_map

ksync_map_if	if_map

ksync_rt_tree	rt_tree

ksync_map_mpls	mpls_map

ksync_map_mirror	mirror_map

ksync_vrf_assign_tree	vrf_assign_tree

ksync_map_vrf_stats	vrf_stats_map

vr_drop_stats_req	drop_stats

vrouter_ops	ksync_vrouter_ops

ksync_map_vxlan	vxlan_map

ksync_map_vrf	vrf_map

ksync_map_ctx_queue	ctx_queue_

tbb::mutex	ctx_queue_lock_

Private Member Functions
void	PurgeBlockedMsg ()

	DISALLOW_COPY_AND_ASSIGN (KSyncSockTypeMap)

Private Attributes
udp::socket	sock_

udp::endpoint	local_ep_

int	ksync_error_ [KSYNC_MAX_ENTRY_TYPE]

bool	block_msg_processing_

bool	is_incremental_index_

vr_bridge_entry *	bridge_table_

std::vector< struct nl_client >	tx_buff_list_

Static Private Attributes
static KSyncSockTypeMap *	singleton_

static vr_flow_entry *	flow_table_

static int	error_code_

Friends
class	MockDumpHandlerBase

class	RouteDumpHandler

class	VrfAssignDumpHandler

class	VrfDumpHandler

Additional Inherited Members
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 86 of file ksync_sock_user.h.

Member Typedef Documentation

◆ ksync_map_ctx_queue

typedef std::queue<KSyncUserSockContext *> KSyncSockTypeMap::ksync_map_ctx_queue

Definition at line 131 of file ksync_sock_user.h.

◆ ksync_map_flow

typedef boost::unordered_map<int, vr_flow_req> KSyncSockTypeMap::ksync_map_flow

Definition at line 111 of file ksync_sock_user.h.

◆ ksync_map_if

typedef std::map<int, vr_interface_req> KSyncSockTypeMap::ksync_map_if

Definition at line 113 of file ksync_sock_user.h.

◆ ksync_map_mirror

typedef std::map<int, vr_mirror_req> KSyncSockTypeMap::ksync_map_mirror

Definition at line 119 of file ksync_sock_user.h.

◆ ksync_map_mpls

typedef std::map<int, vr_mpls_req> KSyncSockTypeMap::ksync_map_mpls

Definition at line 117 of file ksync_sock_user.h.

◆ ksync_map_nh

typedef std::map<int, vr_nexthop_req> KSyncSockTypeMap::ksync_map_nh

Definition at line 109 of file ksync_sock_user.h.

◆ ksync_map_vrf

typedef std::map<int, vr_vrf_req> KSyncSockTypeMap::ksync_map_vrf

Definition at line 129 of file ksync_sock_user.h.

◆ ksync_map_vrf_stats

typedef std::map<int, vr_vrf_stats_req> KSyncSockTypeMap::ksync_map_vrf_stats

Definition at line 123 of file ksync_sock_user.h.

◆ ksync_map_vxlan

typedef std::map<int, vr_vxlan_req> KSyncSockTypeMap::ksync_map_vxlan

Definition at line 127 of file ksync_sock_user.h.

◆ ksync_rt_tree

typedef std::set<vr_route_req, TestRouteCmp> KSyncSockTypeMap::ksync_rt_tree

Definition at line 115 of file ksync_sock_user.h.

◆ ksync_vrf_assign_tree

typedef std::set<vr_vrf_assign_req, TestVrfAssignCmp> KSyncSockTypeMap::ksync_vrf_assign_tree

Definition at line 121 of file ksync_sock_user.h.

Member Enumeration Documentation

◆ KSyncSockEntryType

enum KSyncSockTypeMap::KSyncSockEntryType

Enumerator
KSYNC_FLOW_ENTRY_TYPE
KSYNC_MAX_ENTRY_TYPE

Definition at line 88 of file ksync_sock_user.h.

Constructor & Destructor Documentation

◆ KSyncSockTypeMap()

KSyncSockTypeMap::KSyncSockTypeMap ( boost::asio::io_context & ios )

inline

Definition at line 93 of file ksync_sock_user.h.

◆ ~KSyncSockTypeMap()

KSyncSockTypeMap::~KSyncSockTypeMap ( )

inline

Definition at line 97 of file ksync_sock_user.h.

Member Function Documentation

◆ AddNetlinkTxBuff()

void KSyncSockTypeMap::AddNetlinkTxBuff ( struct nl_client * cl )

Definition at line 51 of file ksync_sock_user.cc.

◆ AsyncReceive()

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

virtual

Implements KSyncSock.

Definition at line 592 of file ksync_sock_user.cc.

◆ AsyncSendTo()

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

virtual

Implements KSyncSock.

Definition at line 570 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ BridgeMmapAlloc()

vr_bridge_entry * KSyncSockTypeMap::BridgeMmapAlloc ( int size )

Definition at line 708 of file ksync_sock_user.cc.

◆ BridgeMmapFree()

void KSyncSockTypeMap::BridgeMmapFree ( )

Definition at line 714 of file ksync_sock_user.cc.

◆ BulkDecoder()

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

virtual

Implements KSyncSock.

Definition at line 530 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ Decoder()

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

virtual

Implements KSyncSock.

Definition at line 536 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ DisableReceiveQueue()

void KSyncSockTypeMap::DisableReceiveQueue ( bool disable )

Definition at line 227 of file ksync_sock_user.cc.

◆ DISALLOW_COPY_AND_ASSIGN()

KSyncSockTypeMap::DISALLOW_COPY_AND_ASSIGN ( KSyncSockTypeMap )

private

◆ error_code()

static int KSyncSockTypeMap::error_code ( )

inlinestatic

Definition at line 149 of file ksync_sock_user.h.

◆ FlowMmapAlloc()

vr_flow_entry * KSyncSockTypeMap::FlowMmapAlloc ( int size )

static

Definition at line 601 of file ksync_sock_user.cc.

◆ FlowMmapFree()

void KSyncSockTypeMap::FlowMmapFree ( )

static

Definition at line 606 of file ksync_sock_user.cc.

◆ FlowNatResponse()

void KSyncSockTypeMap::FlowNatResponse	(	uint32_t	seq_num,
		vr_flow_req *	req,
		int	code = `0`
	)

static

Definition at line 134 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ GetBridgeEntry()

vr_bridge_entry * KSyncSockTypeMap::GetBridgeEntry ( int idx )

Definition at line 721 of file ksync_sock_user.cc.

◆ GetFlowEntry()

vr_flow_entry * KSyncSockTypeMap::GetFlowEntry ( int idx )

static

Definition at line 613 of file ksync_sock_user.cc.

◆ GetKSyncError()

int KSyncSockTypeMap::GetKSyncError ( KSyncSockEntryType type )

inline

Definition at line 223 of file ksync_sock_user.h.

◆ GetKSyncSockTypeMap()

static KSyncSockTypeMap* KSyncSockTypeMap::GetKSyncSockTypeMap ( )

inlinestatic

Definition at line 183 of file ksync_sock_user.h.

◆ GetSeqno()

uint32_t KSyncSockTypeMap::GetSeqno ( char * data )

virtual

Implements KSyncSock.

Definition at line 519 of file ksync_sock_user.cc.

◆ IfCount()

int KSyncSockTypeMap::IfCount ( )

static

Definition at line 494 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ IfDumpResponse()

static void KSyncSockTypeMap::IfDumpResponse ( uint32_t )

static

◆ IfNetlinkMsgSend()

static void KSyncSockTypeMap::IfNetlinkMsgSend	(	uint32_t	seq_num,
		ksync_map_if::const_iterator	it
	)

static

◆ IfStatsSet()

void KSyncSockTypeMap::IfStatsSet	(	int	idx,
		int	ibytes,
		int	ipkts,
		int	ierrors,
		int	obytes,
		int	opkts,
		int	oerrors
	)

static

Definition at line 481 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ IfStatsUpdate()

void KSyncSockTypeMap::IfStatsUpdate	(	int	idx,
		int	ibytes,
		int	ipkts,
		int	ierrors,
		int	obytes,
		int	opkts,
		int	oerrors
	)

static

Definition at line 468 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ IncrFlowStats()

void KSyncSockTypeMap::IncrFlowStats	(	int	idx,
		int	pkts,
		int	bytes
	)

static

Definition at line 671 of file ksync_sock_user.cc.

◆ Init()

void KSyncSockTypeMap::Init ( boost::asio::io_context & ios )

static

Definition at line 760 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ InitNetlinkDoneMsg()

void KSyncSockTypeMap::InitNetlinkDoneMsg	(	struct nlmsghdr *	nlh,
		uint32_t	seq_num
	)

Definition at line 195 of file ksync_sock_user.cc.

◆ InterfaceAdd()

void KSyncSockTypeMap::InterfaceAdd	(	int	id,
		int	flags = `0`,
		int	mac_size = `6`
	)

static

Definition at line 243 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ InterfaceDelete()

void KSyncSockTypeMap::InterfaceDelete ( int id )

static

Definition at line 266 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ is_incremental_index()

bool KSyncSockTypeMap::is_incremental_index ( )

inline

Definition at line 217 of file ksync_sock_user.h.

◆ IsBlockMsgProcessing()

bool KSyncSockTypeMap::IsBlockMsgProcessing ( )

inline

Definition at line 208 of file ksync_sock_user.h.

◆ IsMoreData()

bool KSyncSockTypeMap::IsMoreData ( char * data )

virtual

Implements KSyncSock.

Definition at line 524 of file ksync_sock_user.cc.

◆ MirrorAdd()

void KSyncSockTypeMap::MirrorAdd ( int id )

static

Definition at line 316 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ MirrorDelete()

void KSyncSockTypeMap::MirrorDelete ( int id )

static

Definition at line 327 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ MplsAdd()

void KSyncSockTypeMap::MplsAdd ( int id )

static

Definition at line 296 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ MplsCount()

int KSyncSockTypeMap::MplsCount ( )

static

Definition at line 504 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ MplsDelete()

void KSyncSockTypeMap::MplsDelete ( int id )

static

Definition at line 307 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ NHAdd()

void KSyncSockTypeMap::NHAdd	(	int	id,
		int	flags = `0`
	)

static

Definition at line 275 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ NHCount()

int KSyncSockTypeMap::NHCount ( )

static

Definition at line 499 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ NHDelete()

void KSyncSockTypeMap::NHDelete ( int id )

static

Definition at line 287 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ ProcessSandesh()

void KSyncSockTypeMap::ProcessSandesh	(	const uint8_t *	,
		std::size_t	,
		KSyncUserSockContext *
	)

Definition at line 58 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ PurgeBlockedMsg()

void KSyncSockTypeMap::PurgeBlockedMsg ( )

private

Definition at line 780 of file ksync_sock_user.cc.

◆ PurgeTxBuffer()

void KSyncSockTypeMap::PurgeTxBuffer ( )

Definition at line 84 of file ksync_sock_user.cc.

◆ Receive()

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

virtual

Implements KSyncSock.

Definition at line 597 of file ksync_sock_user.cc.

◆ ResetEvictedFlag()

void KSyncSockTypeMap::ResetEvictedFlag ( int idx )

static

Definition at line 663 of file ksync_sock_user.cc.

◆ RouteAdd()

void KSyncSockTypeMap::RouteAdd ( vr_route_req & req )

static

Definition at line 336 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ RouteCount()

int KSyncSockTypeMap::RouteCount ( )

static

Definition at line 509 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ RouteDelete()

void KSyncSockTypeMap::RouteDelete ( vr_route_req & req )

static

Definition at line 354 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ SendNetlinkDoneMsg()

static void KSyncSockTypeMap::SendNetlinkDoneMsg ( uint32_t seq_num )

static

◆ SendTo()

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

virtual

Implements KSyncSock.

Definition at line 581 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ set_error_code()

static void KSyncSockTypeMap::set_error_code ( int code )

inlinestatic

Definition at line 148 of file ksync_sock_user.h.

◆ set_is_incremental_index()

void KSyncSockTypeMap::set_is_incremental_index ( bool incremental )

inline

Definition at line 213 of file ksync_sock_user.h.

◆ SetBlockMsgProcessing()

void KSyncSockTypeMap::SetBlockMsgProcessing ( bool enable )

Definition at line 789 of file ksync_sock_user.cc.

◆ SetBridgeEntry()

void KSyncSockTypeMap::SetBridgeEntry	(	uint32_t	idx,
		vr_route_req *	req,
		bool	set
	)

Definition at line 725 of file ksync_sock_user.cc.

◆ SetDropStats()

void KSyncSockTypeMap::SetDropStats ( const vr_drop_stats_req & req )

static

Definition at line 233 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ SetEvictedFlag()

void KSyncSockTypeMap::SetEvictedFlag ( int idx )

static

Definition at line 656 of file ksync_sock_user.cc.

◆ SetFlowEntry()

void KSyncSockTypeMap::SetFlowEntry	(	vr_flow_req *	req,
		bool	set
	)

static

Definition at line 617 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ SetFlowTcpFlags()

void KSyncSockTypeMap::SetFlowTcpFlags	(	int	idx,
		uint16_t	flags
	)

static

Definition at line 686 of file ksync_sock_user.cc.

◆ SetKSyncError()

void KSyncSockTypeMap::SetKSyncError	(	KSyncSockEntryType	type,
		int	ksync_error
	)

inline

Definition at line 219 of file ksync_sock_user.h.

◆ SetOFlowStats()

void KSyncSockTypeMap::SetOFlowStats	(	int	idx,
		uint8_t	pkts,
		uint16_t	bytes
	)

static

Definition at line 700 of file ksync_sock_user.cc.

◆ SetTcpFlag()

void KSyncSockTypeMap::SetTcpFlag	(	int	idx,
		uint32_t	flags
	)

static

Definition at line 679 of file ksync_sock_user.cc.

◆ SetUnderlaySourcePort()

void KSyncSockTypeMap::SetUnderlaySourcePort	(	int	idx,
		int	port
	)

static

Definition at line 693 of file ksync_sock_user.cc.

◆ SetVRouterOps()

void KSyncSockTypeMap::SetVRouterOps ( const vrouter_ops & req )

static

Definition at line 238 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ Shutdown()

void KSyncSockTypeMap::Shutdown ( )

static

Definition at line 775 of file ksync_sock_user.cc.

◆ SimulateResponse()

void KSyncSockTypeMap::SimulateResponse	(	uint32_t	seq_num,
		int	code,
		int	flags
	)

static

Definition at line 203 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ UpdateBridgeEntryInactiveFlag()

void KSyncSockTypeMap::UpdateBridgeEntryInactiveFlag	(	int	idx,
		bool	set
	)

Definition at line 750 of file ksync_sock_user.cc.

◆ Validate()

bool KSyncSockTypeMap::Validate ( char * data )

virtual

Implements KSyncSock.

Definition at line 541 of file ksync_sock_user.cc.

◆ VrfAdd()

static void KSyncSockTypeMap::VrfAdd ( vr_vrf_req & req )

static

◆ VrfAssignAdd()

void KSyncSockTypeMap::VrfAssignAdd ( vr_vrf_assign_req & req )

static

Definition at line 363 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ VrfAssignDelete()

void KSyncSockTypeMap::VrfAssignDelete ( vr_vrf_assign_req & req )

static

Definition at line 372 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ VrfDelete()

static void KSyncSockTypeMap::VrfDelete ( vr_vrf_req & req )

static

◆ VrfStatsAdd()

void KSyncSockTypeMap::VrfStatsAdd ( int vrf_id )

static

Definition at line 381 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ VrfStatsDelete()

void KSyncSockTypeMap::VrfStatsDelete ( int vrf_id )

static

Definition at line 406 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ VrfStatsUpdate()

void KSyncSockTypeMap::VrfStatsUpdate	(	int	vrf_id,
		const vr_vrf_stats_req &	req
	)

static

Definition at line 415 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ VxlanAdd()

void KSyncSockTypeMap::VxlanAdd ( int id )

static

Definition at line 445 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ VxLanCount()

int KSyncSockTypeMap::VxLanCount ( )

static

Definition at line 514 of file ksync_sock_user.cc.

Here is the call graph for this function:

◆ VxlanDelete()

void KSyncSockTypeMap::VxlanDelete ( int id )

static

Definition at line 458 of file ksync_sock_user.cc.

Here is the call graph for this function:

Friends And Related Function Documentation

◆ MockDumpHandlerBase

friend class MockDumpHandlerBase

friend

Definition at line 203 of file ksync_sock_user.h.

◆ RouteDumpHandler

friend class RouteDumpHandler

friend

Definition at line 204 of file ksync_sock_user.h.

◆ VrfAssignDumpHandler

friend class VrfAssignDumpHandler

friend

Definition at line 205 of file ksync_sock_user.h.

◆ VrfDumpHandler

friend class VrfDumpHandler

friend

Definition at line 206 of file ksync_sock_user.h.

Member Data Documentation

◆ block_msg_processing_

bool KSyncSockTypeMap::block_msg_processing_

private

Definition at line 236 of file ksync_sock_user.h.

◆ bridge_table_

vr_bridge_entry* KSyncSockTypeMap::bridge_table_

private

Definition at line 240 of file ksync_sock_user.h.

◆ ctx_queue_

ksync_map_ctx_queue KSyncSockTypeMap::ctx_queue_

Definition at line 132 of file ksync_sock_user.h.

◆ ctx_queue_lock_

tbb::mutex KSyncSockTypeMap::ctx_queue_lock_

Definition at line 133 of file ksync_sock_user.h.

◆ drop_stats

vr_drop_stats_req KSyncSockTypeMap::drop_stats

Definition at line 125 of file ksync_sock_user.h.

◆ error_code_

int KSyncSockTypeMap::error_code_

staticprivate

Definition at line 241 of file ksync_sock_user.h.

◆ flow_map

ksync_map_flow KSyncSockTypeMap::flow_map

Definition at line 112 of file ksync_sock_user.h.

◆ flow_table_

vr_flow_entry * KSyncSockTypeMap::flow_table_

staticprivate

Definition at line 239 of file ksync_sock_user.h.

◆ if_map

ksync_map_if KSyncSockTypeMap::if_map

Definition at line 114 of file ksync_sock_user.h.

◆ is_incremental_index_

bool KSyncSockTypeMap::is_incremental_index_

private

Definition at line 237 of file ksync_sock_user.h.

◆ ksync_error_

int KSyncSockTypeMap::ksync_error_[KSYNC_MAX_ENTRY_TYPE]

private

Definition at line 235 of file ksync_sock_user.h.

◆ ksync_vrouter_ops

vrouter_ops KSyncSockTypeMap::ksync_vrouter_ops

Definition at line 126 of file ksync_sock_user.h.

◆ local_ep_

udp::endpoint KSyncSockTypeMap::local_ep_

private

Definition at line 234 of file ksync_sock_user.h.

◆ mirror_map

ksync_map_mirror KSyncSockTypeMap::mirror_map

Definition at line 120 of file ksync_sock_user.h.

◆ mpls_map

ksync_map_mpls KSyncSockTypeMap::mpls_map

Definition at line 118 of file ksync_sock_user.h.

◆ nh_map

ksync_map_nh KSyncSockTypeMap::nh_map

Definition at line 110 of file ksync_sock_user.h.

◆ rt_tree

ksync_rt_tree KSyncSockTypeMap::rt_tree

Definition at line 116 of file ksync_sock_user.h.

◆ singleton_

KSyncSockTypeMap * KSyncSockTypeMap::singleton_

staticprivate

Definition at line 238 of file ksync_sock_user.h.

◆ sock_

udp::socket KSyncSockTypeMap::sock_

private

Definition at line 233 of file ksync_sock_user.h.

◆ tx_buff_list_

std::vector<struct nl_client> KSyncSockTypeMap::tx_buff_list_

private

Definition at line 245 of file ksync_sock_user.h.

◆ vrf_assign_tree

ksync_vrf_assign_tree KSyncSockTypeMap::vrf_assign_tree

Definition at line 122 of file ksync_sock_user.h.

◆ vrf_map

ksync_map_vrf KSyncSockTypeMap::vrf_map

Definition at line 130 of file ksync_sock_user.h.

◆ vrf_stats_map

ksync_map_vrf_stats KSyncSockTypeMap::vrf_stats_map

Definition at line 124 of file ksync_sock_user.h.

◆ vxlan_map

ksync_map_vxlan KSyncSockTypeMap::vxlan_map

Definition at line 128 of file ksync_sock_user.h.

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

Public Types

Public Member Functions

Static Public Member Functions

Public Attributes

Private Member Functions

Private Attributes

Static Private Attributes

Friends

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ ksync_map_ctx_queue

◆ ksync_map_flow

◆ ksync_map_if

◆ ksync_map_mirror

◆ ksync_map_mpls

◆ ksync_map_nh

◆ ksync_map_vrf

◆ ksync_map_vrf_stats

◆ ksync_map_vxlan

◆ ksync_rt_tree

◆ ksync_vrf_assign_tree

Member Enumeration Documentation

◆ KSyncSockEntryType

Constructor & Destructor Documentation

◆ KSyncSockTypeMap()

◆ ~KSyncSockTypeMap()

Member Function Documentation

◆ AddNetlinkTxBuff()

◆ AsyncReceive()

◆ AsyncSendTo()

◆ BridgeMmapAlloc()

◆ BridgeMmapFree()

◆ BulkDecoder()

◆ Decoder()

◆ DisableReceiveQueue()

◆ DISALLOW_COPY_AND_ASSIGN()

◆ error_code()

◆ FlowMmapAlloc()

◆ FlowMmapFree()

◆ FlowNatResponse()

◆ GetBridgeEntry()

◆ GetFlowEntry()

◆ GetKSyncError()

◆ GetKSyncSockTypeMap()

◆ GetSeqno()

◆ IfCount()

◆ IfDumpResponse()

◆ IfNetlinkMsgSend()

◆ IfStatsSet()

◆ IfStatsUpdate()

◆ IncrFlowStats()

◆ Init()

◆ InitNetlinkDoneMsg()

◆ InterfaceAdd()

◆ InterfaceDelete()

◆ is_incremental_index()

◆ IsBlockMsgProcessing()

◆ IsMoreData()

◆ MirrorAdd()

◆ MirrorDelete()

◆ MplsAdd()

◆ MplsCount()

◆ MplsDelete()

◆ NHAdd()

◆ NHCount()

◆ NHDelete()

◆ ProcessSandesh()

◆ PurgeBlockedMsg()

◆ PurgeTxBuffer()

◆ Receive()

◆ ResetEvictedFlag()

◆ RouteAdd()

◆ RouteCount()

◆ RouteDelete()

◆ SendNetlinkDoneMsg()

◆ SendTo()

◆ set_error_code()

◆ set_is_incremental_index()

◆ SetBlockMsgProcessing()