nvmsgbroker_internal.h File Reference

Go to the source code of this file.

Data Structures
struct	NvMsgBrokerThread_t
struct	proto_adapter
struct	NvMsgBrokerHandle
struct	NvMsgBrokerSendCB_info

Macros
#define	DEFAULT_RETRY_INTERVAL   2
#define	DEFAULT_MAX_RETRY_LIMIT   360
#define	DEFAULT_WORK_INTERVAL   10000

Typedefs
typedef struct proto_adapter	AdapterLib

Enumerations
enum	NvMsgBrokerReturnVal {   SUCCESS,   FAIL,   ERROR }

Functions
void *	do_work_func (void *)
void	adapter_connect_cb (NvDsMsgApiHandle *adapter_h_ptr, NvDsMsgApiEventType ds_evt)
void	adapter_send_cb (void *user_ptr, NvDsMsgApiErrorType completion_flag)
void	adapter_subscribe_cb (NvDsMsgApiErrorType flag, void *msg, int msglen, char *topic, void *user_ptr)
void	handle_error (void *handle, pthread_mutex_t *lock, AdapterLib *lib, const char *log, const char *error)
bool	fetch_adapter_api (void *so_handle, AdapterLib *LIB)
NvMsgBrokerReturnVal	reconnect (NvMsgBrokerHandle *h_ptr)
void	__attribute__ ((constructor)) nvmsgbroker_init(void)
void	__attribute__ ((destructor)) nvmsgbroker_deinit(void)

Variables
const char *	nvmsgbrokerConfig = "/opt/nvidia/deepstream/deepstream/sources/libs/nvmsgbroker/cfg_nvmsgbroker.txt"
bool	auto_reconnect
unsigned	retry_interval
unsigned	max_retry_limit
unsigned	work_interval
map< pair< string, AdapterLib * >, NvMsgBrokerHandle * >	conn_string_handle_map
unordered_set< NvMsgBrokerHandle * >	conn_Handle_list
unordered_map< NvDsMsgApiHandle, NvMsgBrokerHandle * >	adapter_msgbroker_map
unordered_map< void *, AdapterLib * >	so_handle_map
pthread_mutex_t	h_ptr_lock

Macro Definition Documentation

DEFAULT_MAX_RETRY_LIMIT

#define DEFAULT_MAX_RETRY_LIMIT   360

Definition at line 28 of file nvmsgbroker_internal.h.

DEFAULT_RETRY_INTERVAL

#define DEFAULT_RETRY_INTERVAL   2

Definition at line 27 of file nvmsgbroker_internal.h.

DEFAULT_WORK_INTERVAL

#define DEFAULT_WORK_INTERVAL   10000

Definition at line 29 of file nvmsgbroker_internal.h.

Typedef Documentation

AdapterLib

typedef struct proto_adapter AdapterLib

Enumeration Type Documentation

NvMsgBrokerReturnVal

enum NvMsgBrokerReturnVal

Enumerator
SUCCESS
FAIL
ERROR

Definition at line 39 of file nvmsgbroker_internal.h.

Function Documentation

__attribute__() [1/2]

void __attribute__

(

(constructor)

)

__attribute__() [2/2]

void __attribute__

(

(destructor)

)

adapter_connect_cb()

void adapter_connect_cb	(	NvDsMsgApiHandle *	adapter_h_ptr,
		NvDsMsgApiEventType	ds_evt
	)

adapter_send_cb()

void adapter_send_cb	(	void *	user_ptr,
		NvDsMsgApiErrorType	completion_flag
	)

adapter_subscribe_cb()

void adapter_subscribe_cb	(	NvDsMsgApiErrorType	flag,
		void *	msg,
		int	msglen,
		char *	topic,
		void *	user_ptr
	)

do_work_func()

void* do_work_func

(

void *

)

fetch_adapter_api()

bool fetch_adapter_api	(	void *	so_handle,
		AdapterLib *	LIB
	)

handle_error()

void handle_error	(	void *	handle,
		pthread_mutex_t *	lock,
		AdapterLib *	lib,
		const char *	log,
		const char *	error
	)

reconnect()

NvMsgBrokerReturnVal reconnect

(

NvMsgBrokerHandle *

h_ptr

)

Variable Documentation

adapter_msgbroker_map

unordered_map<NvDsMsgApiHandle, NvMsgBrokerHandle *> adapter_msgbroker_map

Definition at line 101 of file nvmsgbroker_internal.h.

auto_reconnect

bool auto_reconnect

Definition at line 34 of file nvmsgbroker_internal.h.

conn_Handle_list

unordered_set<NvMsgBrokerHandle *> conn_Handle_list

Definition at line 100 of file nvmsgbroker_internal.h.

conn_string_handle_map

map<pair<string, AdapterLib *>, NvMsgBrokerHandle *> conn_string_handle_map

Definition at line 99 of file nvmsgbroker_internal.h.

h_ptr_lock

pthread_mutex_t h_ptr_lock

Definition at line 105 of file nvmsgbroker_internal.h.

max_retry_limit

unsigned max_retry_limit

Definition at line 36 of file nvmsgbroker_internal.h.

nvmsgbrokerConfig

const char* nvmsgbrokerConfig = "/opt/nvidia/deepstream/deepstream/sources/libs/nvmsgbroker/cfg_nvmsgbroker.txt"

Definition at line 32 of file nvmsgbroker_internal.h.

retry_interval

unsigned retry_interval

Definition at line 35 of file nvmsgbroker_internal.h.

so_handle_map

unordered_map<void *, AdapterLib *> so_handle_map

Definition at line 102 of file nvmsgbroker_internal.h.

work_interval

unsigned work_interval

Definition at line 37 of file nvmsgbroker_internal.h.