vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-05-02 17:00:10 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

Fix ZMQ drops computation when collecting from cento. Add ZMQ_FLAG_EVENT_SOCKET zmq message flag.

Browse source
This commit is contained in:
Alfredo Cardigliano 2025-08-27 11:58:33 +02:00
parent e8cdfbf461
commit fd3a0d7abf
7 changed files with 67 additions and 125 deletions
Download patch file Download diff file Expand all files Collapse all files

15
include/ZMQParserInterface.h
View file

@ -115,23 +115,22 @@ class ZMQParserInterface : public ParserInterface {
bool getCounterId(char *sym, u_int32_t sym_len, u_int32_t *id) const;
u_int8_t parseJSONFlow(const char *payload, int payload_size,
u_int32_t source_id, u_int32_t msg_id);
u_int32_t source_id);
u_int32_t parseTLVFlows(const char *payload, int payload_size,
u_int32_t source_id, u_int32_t msg_id, void *data);
u_int32_t source_id, void *data);
u_int8_t parseEvent(const char *payload, int payload_size, u_int32_t source_id,
u_int32_t msg_id, void *data);
bool check_clock_drift, void *data);
u_int8_t parseTLVCounter(const char *payload, int payload_size);
u_int8_t parseJSONCounter(const char *payload, int payload_size);
u_int8_t parseJSONCustomIE(const char *payload, int payload_size);
u_int8_t parseTemplate(const char *payload, int payload_size,
u_int32_t source_id, u_int32_t msg_id, void *data);
u_int32_t source_id, void *data);
u_int8_t parseOption(const char *payload, int payload_size,
u_int32_t source_id, u_int32_t msg_id, void *data);
u_int32_t source_id, void *data);
u_int8_t parseListeningPorts(const char *payload, int payload_size,
u_int32_t source_id, u_int32_t msg_id,
void *data);
u_int32_t source_id, void *data);
u_int8_t parseSNMPIntefaces(const char *payload, int payload_size,
u_int32_t source_id, u_int32_t msg_id, void *data);
u_int32_t source_id, void *data);
u_int32_t periodicStatsUpdateFrequency() const;
virtual void setRemoteStats(nProbeStats *zrs);