OpenSDN source code
|
#include <diag_proto.h>
Classes | |
struct | DiagStats |
Public Types | |
enum | DiagStatsType { REQUESTS_SENT, REQUESTS_RECEIVED, REPLIES_SENT, REPLIES_RECEIVED } |
typedef std::map< uint32_t, SegmentHealthCheckPkt * > | SessionMap |
typedef std::pair< uint32_t, SegmentHealthCheckPkt * > | SessionPair |
typedef std::map< uint32_t, DiagStats > | DiagStatsMap |
typedef std::pair< uint32_t, DiagStats > | DiagStatsPair |
![]() | |
typedef WorkQueue < boost::shared_ptr< PktInfo > > | ProtoWorkQueue |
Public Member Functions | |
DiagProto (Agent *agent, boost::asio::io_context &io) | |
virtual | ~DiagProto () |
ProtoHandler * | AllocProtoHandler (boost::shared_ptr< PktInfo > info, boost::asio::io_context &io) |
bool | SegmentHealthCheckProcess (HealthCheckTable::HealthCheckServiceAction action, HealthCheckInstanceService *service) |
void | IncrementDiagStats (uint32_t itf_id, DiagStatsType type) |
const DiagStatsMap & | stats () const |
void | FillSandeshHealthCheckResponse (SegmentHealthCheckPktStatsResp *resp) |
![]() | |
Proto (Agent *agent, const char *task_name, PktHandler::PktModuleName mod, boost::asio::io_context &io) | |
virtual | ~Proto () |
virtual bool | Validate (PktInfo *msg) |
virtual bool | Enqueue (boost::shared_ptr< PktInfo > msg) |
virtual void | ProcessStats (PktStatsType::Type type) |
void | FreeBuffer (PktInfo *msg) |
bool | ProcessProto (boost::shared_ptr< PktInfo > msg_info) |
bool | RunProtoHandler (ProtoHandler *handler) |
void | set_trace (bool val) |
void | set_free_buffer (bool val) |
boost::asio::io_context & | get_io_service () const |
Agent * | agent () const |
const ProtoWorkQueue * | work_queue () const |
virtual void | TokenAvailable (TokenPool *pool) |
Private Member Functions | |
DISALLOW_COPY_AND_ASSIGN (DiagProto) | |
Private Attributes | |
SessionMap | session_map_ |
tbb::mutex | stats_mutex_ |
DiagStatsMap | stats_ |
Additional Inherited Members | |
![]() | |
Agent * | agent_ |
PktHandler::PktModuleName | module_ |
bool | trace_ |
bool | free_buffer_ |
boost::asio::io_context & | io_ |
ProtoWorkQueue | work_queue_ |
Definition at line 16 of file diag_proto.h.
typedef std::map<uint32_t, DiagStats> DiagProto::DiagStatsMap |
Definition at line 40 of file diag_proto.h.
typedef std::pair<uint32_t, DiagStats> DiagProto::DiagStatsPair |
Definition at line 41 of file diag_proto.h.
typedef std::map<uint32_t, SegmentHealthCheckPkt *> DiagProto::SessionMap |
Definition at line 19 of file diag_proto.h.
typedef std::pair<uint32_t, SegmentHealthCheckPkt *> DiagProto::SessionPair |
Definition at line 20 of file diag_proto.h.
Enumerator | |
---|---|
REQUESTS_SENT | |
REQUESTS_RECEIVED | |
REPLIES_SENT | |
REPLIES_RECEIVED |
Definition at line 22 of file diag_proto.h.
DiagProto::DiagProto | ( | Agent * | agent, |
boost::asio::io_context & | io | ||
) |
|
inlinevirtual |
Definition at line 44 of file diag_proto.h.
|
virtual |
Implements Proto.
Definition at line 24 of file diag_proto.cc.
|
private |
void DiagProto::FillSandeshHealthCheckResponse | ( | SegmentHealthCheckPktStatsResp * | resp | ) |
Definition at line 118 of file diag_proto.cc.
void DiagProto::IncrementDiagStats | ( | uint32_t | itf_id, |
DiagStatsType | type | ||
) |
Definition at line 93 of file diag_proto.cc.
bool DiagProto::SegmentHealthCheckProcess | ( | HealthCheckTable::HealthCheckServiceAction | action, |
HealthCheckInstanceService * | service | ||
) |
|
inline |
Definition at line 52 of file diag_proto.h.
|
private |
Definition at line 56 of file diag_proto.h.
|
private |
Definition at line 65 of file diag_proto.h.
|
private |
Definition at line 64 of file diag_proto.h.