sources/libs/mqtt_protocol_adaptor/nvds_mqtt_proto.h File Reference

Go to the source code of this file.

Data Structures
struct	ExtractedData
struct	ProtobufWrapper
struct	send_msg_info_t
struct	NvDsMqttClientHandle

Macros
#define	MAX_FIELD_LEN   1024
#define	DEFAULT_LOOP_TIMEOUT   2000
#define	DEFAULT_KEEP_ALIVE   60

Functions
NvDsMsgApiErrorType	nvds_mqtt_read_config (NvDsMqttClientHandle *mh, char *config_path)
void	mosq_mqtt_log_callback (struct mosquitto *mosq, void *obj, int level, const char *str)
void	my_disconnect_callback (struct mosquitto *mosq, void *obj, int rc, const mosquitto_property *properties)
void	my_connect_callback (struct mosquitto *mosq, void *obj, int result, int flags, const mosquitto_property *properties)
void	my_publish_callback (struct mosquitto *mosq, void *obj, int mid, int reason_code, const mosquitto_property *properties)
bool	is_valid_mqtt_connection_str (char *connection_str, std::string &burl, std::string &bport)
ExtractedData	extract_data_from_payload (const uint8_t *payload, size_t nbuf)
std::string	create_protobuf_wrapper (const uint8_t *payload, size_t nbuf)
std::string	create_enhanced_payload (const uint8_t *payload, size_t nbuf)
std::string	serialize_protobuf_wrapper (const ProtobufWrapper &wrapper)

Macro Definition Documentation

DEFAULT_KEEP_ALIVE

#define DEFAULT_KEEP_ALIVE   60

Definition at line 43 of file sources/libs/mqtt_protocol_adaptor/nvds_mqtt_proto.h.

DEFAULT_LOOP_TIMEOUT

#define DEFAULT_LOOP_TIMEOUT   2000

Definition at line 42 of file sources/libs/mqtt_protocol_adaptor/nvds_mqtt_proto.h.

MAX_FIELD_LEN

#define MAX_FIELD_LEN   1024

Definition at line 28 of file sources/libs/mqtt_protocol_adaptor/nvds_mqtt_proto.h.

Function Documentation

create_enhanced_payload()

std::string create_enhanced_payload	(	const uint8_t *	payload,
		size_t	nbuf
	)

create_protobuf_wrapper()

std::string create_protobuf_wrapper	(	const uint8_t *	payload,
		size_t	nbuf
	)

extract_data_from_payload()

ExtractedData extract_data_from_payload	(	const uint8_t *	payload,
		size_t	nbuf
	)

is_valid_mqtt_connection_str()

bool is_valid_mqtt_connection_str	(	char *	connection_str,
		std::string &	burl,
		std::string &	bport
	)

mosq_mqtt_log_callback()

void mosq_mqtt_log_callback	(	struct mosquitto *	mosq,
		void *	obj,
		int	level,
		const char *	str
	)

my_connect_callback()

void my_connect_callback	(	struct mosquitto *	mosq,
		void *	obj,
		int	result,
		int	flags,
		const mosquitto_property *	properties
	)

my_disconnect_callback()

void my_disconnect_callback	(	struct mosquitto *	mosq,
		void *	obj,
		int	rc,
		const mosquitto_property *	properties
	)

my_publish_callback()

void my_publish_callback	(	struct mosquitto *	mosq,
		void *	obj,
		int	mid,
		int	reason_code,
		const mosquitto_property *	properties
	)

nvds_mqtt_read_config()

NvDsMsgApiErrorType nvds_mqtt_read_config	(	NvDsMqttClientHandle *	mh,
		char *	config_path
	)

serialize_protobuf_wrapper()

std::string serialize_protobuf_wrapper

(

const ProtobufWrapper &

wrapper

)