Data Structures
struct	gst_ucx_conn_req_ctx

struct	gst_ucp_conn_ctx

struct	_GstUcxServerPriv

struct	_GstUcxClientPriv

struct	_NvGstBufferParams

struct	_NvBufSurfaceDsUcx

struct	_NvBufRawDsUcx

struct	_NvBufAudioDsUcx

union	_NvDsUcxBuf

struct	_NvDsCustomMetaUcx

struct	_NvDsUcxAmDesc

struct	_NvDsUcxAmEventDesc

struct	__GstUcxThreadDataSource

struct	_GstUcxThreadDataSink

struct	_GstUcxClient

struct	_GstUcxServer

struct	_GstUcxSrc

struct	_GstUcxSinkAmHdrParams

struct	_GstUcxSinkRdmaParams

struct	_GstUcxSink

Macros
#define	UCX_DEFAULT_ADDR "127.0.0.1"

#define	UCX_DEFAULT_HIGH_PERF TRUE

#define	UCX_HIGH_PERF_DISABLE_TLS "tcp,cuda"

#define	UCX_MAX_PORT (65535)

#define	UCX_DEFAULT_PORT (7174)

#define	UCX_MAX_CONNS (4)

#define	UCX_DEFAULT_CONNS (1)

#define	IP_STRING_LEN (45)

#define	PORT_STRING_LEN (8)

#define	DEFAULT_ALLOCATOR_BPF (4)

#define	DEFAULT_ALLOCATOR_BUF_LEN (441000)

#define	DEFAULT_GPU_ID (0)

#define	DEFAULT_NVBUF_MEMORY_TYPE NVBUF_MEM_CUDA_UNIFIED

#define	MIN_NUM_NVBUF (0)

#define	MAX_NUM_NVBUF (20)

#define	DEFAULT_NUM_NVBUF (4)

#define	MIN_NVBUF_BATCH_SIZE (1)

#define	MAX_NVBUF_BATCH_SIZE INT_MAX

#define	MIN_MAX_EP_NUM (1)

#define	MAX_MAX_EP_NUM INT_MAX

#define	DEFAULT_NVBUF_BATCH_SIZE (1)

#define	DEFAULT_RAW_BUFFER_SIZE (1 << 13)

#define	BATCH_END_TIMEOUT_SEC (10)

#define	DEFAULT_MAX_EP_NUM (128)

#define	CLIENT_ID_SIZE (32)

#define	GST_CAPS_FEATURE_MEMORY_NVMM "memory:NVMM"

#define	VIDEO_FORMATS "{ NV12, RGBA, I420 }"

#define	AUDIO_FORMAT

#define	AUDIO_CHANNELS "[1, 2147483647]"

#define	GST_AUDIO_CAPS_MAKE_WITH_FEATURES(features, format, channels)

#define	GST_TEXT_CAPS_MAKE(format) "text/x-raw, format=(string){" format "}"

#define	NVTX_WRAPPER_START

#define	NVTX_WRAPPER_END nvtx_helper_start_end(NULL, &nvtx_id)

#define	GST_TYPE_NVDSUCX_BUF_TYPE (gst_nvdsucx_buf_type_get_type ())

#define	EVENT_DATA_MAX_LEN 1024

#define	UCX_THREAD_DATA_COMMON_FIELDS

Typedefs
typedef struct gst_ucx_conn_req_ctx	gst_ucx_conn_req_ctx_t

typedef struct gst_ucp_conn_ctx	gst_ucp_conn_ctx_t

typedef struct _GstUcxServerPriv	GstUcxServerPriv

typedef struct _GstUcxClientPriv	GstUcxClientPriv

typedef struct _NvGstBufferParams	NvGstBufferParams

typedef struct _NvBufSurfaceDsUcx	NvBufSurfaceDsUcx

typedef struct _NvBufRawDsUcx	NvBufRawDsUcx

typedef struct _NvBufAudioDsUcx	NvBufAudioDsUcx

typedef union _NvDsUcxBuf	NvDsUcxBuf

typedef struct _NvDsCustomMetaUcx	NvDsCustomMetaUcx

typedef struct _NvDsUcxAmDesc	NvDsUcxAmDesc

typedef struct _NvDsUcxAmEventDesc	NvDsUcxAmEventDesc

typedef ucs_status_t(*	NvDsUcxSrcPrepAmFunc) (GstBuffer gst_buffer, void rdma_data_ptr, NvDsUcxBuf nv_dsucx_buf, GMutex meta_lock)

typedef ucs_status_t(*	NvDsUcxSrcPrepAmMetaFunc) (GstBuffer gst_buffer, void rdma_data_ptr, NvDsCustomMetaUcx nv_dsucx_meta)

typedef ucs_status_t(*	NvDsUcxAmHandlerFunc) (void arg, const void header, size_t header_length, void data, size_t length, const ucp_am_recv_param_t param)

typedef struct __GstUcxThreadDataSource	GstUcxThreadDataSource

typedef struct _GstUcxThreadDataSink	GstUcxThreadDataSink

typedef G_BEGIN_DECLS struct _GstUcxClient	GstUcxClient

typedef struct _GstUcxServer	GstUcxServer

typedef struct _GstUcxSrc	GstUcxSrc

typedef struct _GstUcxSinkAmHdrParams	GstUcxSinkAmHdrParams

typedef struct _GstUcxSinkRdmaParams	GstUcxRdmaParams

typedef struct _GstUcxSink	GstUcxSink

Enumerations
enum	{ PROP_0, PROP_ADDR, PROP_PORT, PROP_BUF_TYPE, PROP_GPU_DEVICE_ID, PROP_NVBUF_MEMORY_TYPE, PROP_NUM_NVBUF, PROP_NVBUF_BATCH_SIZE, PROP_RAW_BUF_SIZE, PROP_NUM_CONNS, PROP_MAX_EP_NUM, PROP_HIGH_PERF }

enum	GstNvDsUcxBufType { NVDSUCX_BUF_TYPE_VIDEO = 0, NVDSUCX_BUF_TYPE_AUDIO_NV = 1 << 0, NVDSUCX_BUF_TYPE_AUDIO_RAW = 1 << 1, NVDSUCX_BUF_TYPE_TEXT = 1 << 2, NVDSUCX_BUF_TYPE_VIDEO = 0, NVDSUCX_BUF_TYPE_AUDIO_NV = 1 << 0, NVDSUCX_BUF_TYPE_AUDIO_RAW = 1 << 1, NVDSUCX_BUF_TYPE_TEXT = 1 << 2 }

enum	GstNvDsUcxAmId { UCP_AM_ID = 1, EVENT_AM_ID = 4, UCP_AM_ID_META = 7, EVENT_AM_BATCH_END = 9, UCP_AM_ID = 1, EVENT_AM_ID = 4, UCP_AM_ID_META = 7, EVENT_AM_BATCH_END = 9 }

Functions
GType	gst_nvdsucx_buf_type_get_type (void)

ucs_status_t	gst_ucp_init_context (ucp_context_h *ucp_context, gboolean high_perf)

ucs_status_t	gst_ucp_send (ucp_worker_h ucp_worker, ucp_ep_h ep, GstNvDsUcxAmId am_id, void am_hdr_buf, size_t am_hdr_buf_size, void rdma_buffer, size_t rdma_buffer_size)

ucs_status_t	gst_ucp_send_event (ucp_worker_h ucp_worker, ucp_ep_h ep, void *msg, size_t msg_len)

ucs_status_t	gst_ucp_send_only (ucp_worker_h ucp_worker, ucp_ep_h ep, unsigned int am_tag)

ucs_status_t	gst_ucp_recv (ucp_worker_h ucp_worker, GstBuffer *gst_buffer, NvDsUcxSrcPrepAmFunc prep_am, NvDsUcxAmDesc am_desc, GMutex meta_lock, ucs_status_t conn_status)

ucs_status_t	gst_ucp_recv_meta (ucp_worker_h ucp_worker, GstBuffer *gst_buffer, NvDsUcxSrcPrepAmMetaFunc prep_am_meta, NvDsUcxAmDesc am_desc, ucs_status_t *conn_status)

int	get_thread_num (gpointer ucxdata, bool is_src, bool is_server)

gboolean	gst_ucx_is_recv_meta (GstUcxSrc *src, int batch_id)

void	free_gst_ucp_conn_ctx (gpointer data)

void	clear_gst_ucp_conn_ctx (gpointer data)

bool	gst_ucx_server_set_property (GstUcxServer ucxserver, guint property_id, const GValue value, GParamSpec *pspec)

bool	gst_ucx_client_set_property (GstUcxClient ucxclient, guint property_id, const GValue value, GParamSpec *pspec)

bool	gst_ucx_src_set_property (GstUcxSrc ucxsrc, guint property_id, const GValue value, GParamSpec *pspec)

bool	gst_ucx_sink_set_property (GstUcxSink ucxsink, guint property_id, const GValue value, GParamSpec *pspec)

bool	gst_ucx_server_get_property (GstUcxServer ucxserver, guint property_id, GValue value, GParamSpec *pspec)

bool	gst_ucx_client_get_property (GstUcxClient ucxclient, guint property_id, GValue value, GParamSpec *pspec)

bool	gst_ucx_src_get_property (GstUcxSrc ucxsrc, guint property_id, GValue value, GParamSpec *pspec)

bool	gst_ucx_sink_get_property (GstUcxSink ucxsink, guint property_id, GValue value, GParamSpec *pspec)

void	gst_ucx_server_init (GstUcxServer *ucxserver)

void	gst_ucx_sink_init (GstUcxSink *ucxsink)

void	gst_ucx_src_init (GstUcxSrc *ucxsrc)

void	gst_ucx_client_init (GstUcxClient *ucxclient)

gboolean	gst_ucx_src_negotiate_caps (GstBaseSrc src, GstUcxSrc ucxsrc)

gboolean	gst_ucx_sink_cap_event_handling (GstUcxSink ucxsink, GstBaseSink basesink, GstEvent event, NvDsUcxAmEventDesc event_data, gboolean *send_event)

void	gst_ucx_set_nvevent_data (GstEvent event, NvDsUcxAmEventDesc event_data, gboolean *send_event)

int	start_server (gpointer data, bool is_src)

int	start_client (gpointer data, bool is_src)

int	start_sink (GstUcxSink *ucxsink)

int	start_src (GstUcxSrc ucxsrc, GstBaseSrc src)

void	stop_client (GstUcxClient *ucxclient)

void	stop_server (GstUcxServer *ucxserver)

void	stop_sink (GstUcxSink *ucxsink)

void	stop_src (GstUcxSrc *ucxsrc)

void	gst_ucx_init ()

gboolean	gst_ucx_src_buffer_pool_new (GstUcxSrc ucxsrc, GstCaps caps)

int	ucx_src_init_buffer_type_attr (GstUcxSrc *ucxsrc)

int	gst_ucx_create_thread_pool (GstTaskPool **pool, gint nvbuf_batch_size)

gboolean	batch_end_check_func (gpointer arg)

static G_END_DECLS void	copy_gstbuf_info (NvGstBufferParams inNvGst, GstBuffer inGstBuf, NvGstBufferParams outNvGst, GstBuffer outGstBuf)

static void	copy_nvbufsurf_params (NvBufSurfaceParams in, NvBufSurfaceParams out)

static void	copy_nvbufaudio_params (NvBufAudioParams in, NvBufAudioParams out)

Macro Definition Documentation

◆ AUDIO_CHANNELS

#define AUDIO_CHANNELS "[1, 2147483647]"

Definition at line 85 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ AUDIO_FORMAT

#define AUDIO_FORMAT

Value:

    "S8, U8, S16LE, S16BE, U16LE, U16BE, S24_32LE, S24_32BE, "        \
    "U24_32LE, U24_32BE, S32LE, S32BE, U32LE, U32BE, S24LE, S24BE, "  \
    "U24LE, U24BE, S20LE, S20BE, U20LE, U20BE, S18LE, S18BE, U18LE, " \
    "U18BE, F32LE, F32BE, F64LE, F64BE"

Definition at line 79 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ BATCH_END_TIMEOUT_SEC

#define BATCH_END_TIMEOUT_SEC (10)

Definition at line 68 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ CLIENT_ID_SIZE

#define CLIENT_ID_SIZE (32)

Definition at line 70 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ DEFAULT_ALLOCATOR_BPF

#define DEFAULT_ALLOCATOR_BPF (4)

Definition at line 55 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ DEFAULT_ALLOCATOR_BUF_LEN

#define DEFAULT_ALLOCATOR_BUF_LEN (441000)

Definition at line 56 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ DEFAULT_GPU_ID

#define DEFAULT_GPU_ID (0)

Definition at line 57 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ DEFAULT_MAX_EP_NUM

#define DEFAULT_MAX_EP_NUM (128)

Definition at line 69 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ DEFAULT_NUM_NVBUF

#define DEFAULT_NUM_NVBUF (4)

Definition at line 61 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ DEFAULT_NVBUF_BATCH_SIZE

#define DEFAULT_NVBUF_BATCH_SIZE (1)

Definition at line 66 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ DEFAULT_NVBUF_MEMORY_TYPE

#define DEFAULT_NVBUF_MEMORY_TYPE NVBUF_MEM_CUDA_UNIFIED

Definition at line 58 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ DEFAULT_RAW_BUFFER_SIZE

#define DEFAULT_RAW_BUFFER_SIZE (1 << 13)

Definition at line 67 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ EVENT_DATA_MAX_LEN

#define EVENT_DATA_MAX_LEN 1024

Definition at line 139 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ GST_AUDIO_CAPS_MAKE_WITH_FEATURES

#define GST_AUDIO_CAPS_MAKE_WITH_FEATURES	(	features,
		format,
		channels
	)

Value:

    "audio/x-raw(" features "), "                          \
    "format = (string) { " format                          \
    "}"                                                    \
    ", "                                                   \
    "rate = [ 1, 2147483647 ], "                           \
    "layout = (string) { interleaved, non-interleaved }, " \
    "channels = (int)" channels

Definition at line 87 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ GST_CAPS_FEATURE_MEMORY_NVMM

#define GST_CAPS_FEATURE_MEMORY_NVMM "memory:NVMM"

Definition at line 73 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ GST_TEXT_CAPS_MAKE

#define GST_TEXT_CAPS_MAKE ( format ) "text/x-raw, format=(string){" format "}"

Definition at line 97 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ GST_TYPE_NVDSUCX_BUF_TYPE

#define GST_TYPE_NVDSUCX_BUF_TYPE (gst_nvdsucx_buf_type_get_type ())

Definition at line 134 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ IP_STRING_LEN

#define IP_STRING_LEN (45)

Definition at line 53 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ MAX_MAX_EP_NUM

#define MAX_MAX_EP_NUM INT_MAX

Definition at line 65 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ MAX_NUM_NVBUF

#define MAX_NUM_NVBUF (20)

Definition at line 60 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ MAX_NVBUF_BATCH_SIZE

#define MAX_NVBUF_BATCH_SIZE INT_MAX

Definition at line 63 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ MIN_MAX_EP_NUM

#define MIN_MAX_EP_NUM (1)

Definition at line 64 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ MIN_NUM_NVBUF

#define MIN_NUM_NVBUF (0)

Definition at line 59 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ MIN_NVBUF_BATCH_SIZE

#define MIN_NVBUF_BATCH_SIZE (1)

Definition at line 62 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ NVTX_WRAPPER_END

#define NVTX_WRAPPER_END nvtx_helper_start_end(NULL, &nvtx_id)

Definition at line 106 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ NVTX_WRAPPER_START

#define NVTX_WRAPPER_START

Value:

    uint64_t nvtx_id; \
    char context_name[256]; \
    strcpy(context_name, __func__); \
    nvtx_helper_start_end(context_name, &nvtx_id)

Definition at line 100 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ PORT_STRING_LEN

#define PORT_STRING_LEN (8)

Definition at line 54 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ UCX_DEFAULT_ADDR

#define UCX_DEFAULT_ADDR "127.0.0.1"

Definition at line 46 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ UCX_DEFAULT_CONNS

#define UCX_DEFAULT_CONNS (1)

Definition at line 52 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ UCX_DEFAULT_HIGH_PERF

#define UCX_DEFAULT_HIGH_PERF TRUE

Definition at line 47 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ UCX_DEFAULT_PORT

#define UCX_DEFAULT_PORT (7174)

Definition at line 50 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ UCX_HIGH_PERF_DISABLE_TLS

#define UCX_HIGH_PERF_DISABLE_TLS "tcp,cuda"

Definition at line 48 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ UCX_MAX_CONNS

#define UCX_MAX_CONNS (4)

Definition at line 51 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ UCX_MAX_PORT

#define UCX_MAX_PORT (65535)

Definition at line 49 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ UCX_THREAD_DATA_COMMON_FIELDS

#define UCX_THREAD_DATA_COMMON_FIELDS

Value:

                                      gint batch_id; \
                                      void *buffer; \
                                      void *ucxparent; \
                                      gpointer thread_id

Definition at line 294 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ VIDEO_FORMATS

#define VIDEO_FORMATS "{ NV12, RGBA, I420 }"

Definition at line 76 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

Typedef Documentation

◆ gst_ucp_conn_ctx_t

typedef struct gst_ucp_conn_ctx gst_ucp_conn_ctx_t

◆ gst_ucx_conn_req_ctx_t

typedef struct gst_ucx_conn_req_ctx gst_ucx_conn_req_ctx_t

◆ GstUcxClient

typedef G_BEGIN_DECLS struct _GstUcxClient GstUcxClient

◆ GstUcxClientPriv

typedef struct _GstUcxClientPriv GstUcxClientPriv

◆ GstUcxRdmaParams

typedef struct _GstUcxSinkRdmaParams GstUcxRdmaParams

◆ GstUcxServer

typedef struct _GstUcxServer GstUcxServer

◆ GstUcxServerPriv

typedef struct _GstUcxServerPriv GstUcxServerPriv

◆ GstUcxSink

typedef struct _GstUcxSink GstUcxSink

◆ GstUcxSinkAmHdrParams

typedef struct _GstUcxSinkAmHdrParams GstUcxSinkAmHdrParams

◆ GstUcxSrc

typedef struct _GstUcxSrc GstUcxSrc

◆ GstUcxThreadDataSink

typedef struct _GstUcxThreadDataSink GstUcxThreadDataSink

◆ GstUcxThreadDataSource

typedef struct __GstUcxThreadDataSource GstUcxThreadDataSource

◆ NvBufAudioDsUcx

typedef struct _NvBufAudioDsUcx NvBufAudioDsUcx

◆ NvBufRawDsUcx

typedef struct _NvBufRawDsUcx NvBufRawDsUcx

◆ NvBufSurfaceDsUcx

typedef struct _NvBufSurfaceDsUcx NvBufSurfaceDsUcx

◆ NvDsCustomMetaUcx

typedef struct _NvDsCustomMetaUcx NvDsCustomMetaUcx

◆ NvDsUcxAmDesc

typedef struct _NvDsUcxAmDesc NvDsUcxAmDesc

◆ NvDsUcxAmEventDesc

typedef struct _NvDsUcxAmEventDesc NvDsUcxAmEventDesc

◆ NvDsUcxAmHandlerFunc

typedef ucs_status_t(* NvDsUcxAmHandlerFunc) (void *arg, const void *header, size_t header_length, void *data, size_t length, const ucp_am_recv_param_t *param)

Definition at line 270 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ NvDsUcxBuf

typedef union _NvDsUcxBuf NvDsUcxBuf

◆ NvDsUcxSrcPrepAmFunc

typedef ucs_status_t(* NvDsUcxSrcPrepAmFunc) (GstBuffer **gst_buffer, void **rdma_data_ptr, NvDsUcxBuf *nv_dsucx_buf, GMutex *meta_lock)

Definition at line 266 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ NvDsUcxSrcPrepAmMetaFunc

typedef ucs_status_t(* NvDsUcxSrcPrepAmMetaFunc) (GstBuffer **gst_buffer, void **rdma_data_ptr, NvDsCustomMetaUcx nv_dsucx_meta)

Definition at line 268 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ NvGstBufferParams

typedef struct _NvGstBufferParams NvGstBufferParams

Enumeration Type Documentation

◆ anonymous enum

anonymous enum

Enumerator
PROP_0
PROP_ADDR
PROP_PORT
PROP_BUF_TYPE
PROP_GPU_DEVICE_ID
PROP_NVBUF_MEMORY_TYPE
PROP_NUM_NVBUF
PROP_NVBUF_BATCH_SIZE
PROP_RAW_BUF_SIZE
PROP_NUM_CONNS
PROP_MAX_EP_NUM
PROP_HIGH_PERF

Definition at line 110 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ GstNvDsUcxAmId

enum GstNvDsUcxAmId

Enumerator
UCP_AM_ID
EVENT_AM_ID
UCP_AM_ID_META
EVENT_AM_BATCH_END
UCP_AM_ID
EVENT_AM_ID
UCP_AM_ID_META
EVENT_AM_BATCH_END

Definition at line 141 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

◆ GstNvDsUcxBufType

enum GstNvDsUcxBufType

Enumerator
NVDSUCX_BUF_TYPE_VIDEO
NVDSUCX_BUF_TYPE_AUDIO_NV
NVDSUCX_BUF_TYPE_AUDIO_RAW
NVDSUCX_BUF_TYPE_TEXT
NVDSUCX_BUF_TYPE_VIDEO
NVDSUCX_BUF_TYPE_AUDIO_NV
NVDSUCX_BUF_TYPE_AUDIO_RAW
NVDSUCX_BUF_TYPE_TEXT

Definition at line 126 of file sources/gst-plugins/gst-nvdsucx/gstucx.h.

Function Documentation

◆ batch_end_check_func()

gboolean batch_end_check_func ( gpointer arg )

◆ clear_gst_ucp_conn_ctx()

void clear_gst_ucp_conn_ctx ( gpointer data )

◆ copy_gstbuf_info()

static G_END_DECLS void copy_gstbuf_info	(	NvGstBufferParams *	inNvGst,
		GstBuffer *	inGstBuf,
		NvGstBufferParams *	outNvGst,
		GstBuffer *	outGstBuf
	)

static

◆ copy_nvbufaudio_params()

static void copy_nvbufaudio_params	(	NvBufAudioParams *	in,
		NvBufAudioParams *	out
	)

static

◆ copy_nvbufsurf_params()

static void copy_nvbufsurf_params	(	NvBufSurfaceParams *	in,
		NvBufSurfaceParams *	out
	)

static

◆ free_gst_ucp_conn_ctx()

void free_gst_ucp_conn_ctx ( gpointer data )

◆ get_thread_num()

int get_thread_num	(	gpointer	ucxdata,
		bool	is_src,
		bool	is_server
	)

◆ gst_nvdsucx_buf_type_get_type()

GType gst_nvdsucx_buf_type_get_type ( void )

◆ gst_ucp_init_context()

ucs_status_t gst_ucp_init_context	(	ucp_context_h *	ucp_context,
		gboolean	high_perf
	)

◆ gst_ucp_recv()

ucs_status_t gst_ucp_recv	(	ucp_worker_h	ucp_worker,
		GstBuffer **	gst_buffer,
		NvDsUcxSrcPrepAmFunc	prep_am,
		NvDsUcxAmDesc *	am_desc,
		GMutex *	meta_lock,
		ucs_status_t *	conn_status
	)

◆ gst_ucp_recv_meta()

ucs_status_t gst_ucp_recv_meta	(	ucp_worker_h	ucp_worker,
		GstBuffer **	gst_buffer,
		NvDsUcxSrcPrepAmMetaFunc	prep_am_meta,
		NvDsUcxAmDesc *	am_desc,
		ucs_status_t *	conn_status
	)

◆ gst_ucp_send()

ucs_status_t gst_ucp_send	(	ucp_worker_h	ucp_worker,
		ucp_ep_h	ep,
		GstNvDsUcxAmId	am_id,
		void *	am_hdr_buf,
		size_t	am_hdr_buf_size,
		void *	rdma_buffer,
		size_t	rdma_buffer_size
	)

◆ gst_ucp_send_event()

ucs_status_t gst_ucp_send_event	(	ucp_worker_h	ucp_worker,
		ucp_ep_h	ep,
		void *	msg,
		size_t	msg_len
	)

◆ gst_ucp_send_only()

ucs_status_t gst_ucp_send_only	(	ucp_worker_h	ucp_worker,
		ucp_ep_h	ep,
		unsigned int	am_tag
	)

◆ gst_ucx_client_get_property()

bool gst_ucx_client_get_property	(	GstUcxClient *	ucxclient,
		guint	property_id,
		GValue *	value,
		GParamSpec *	pspec
	)

◆ gst_ucx_client_init()

void gst_ucx_client_init ( GstUcxClient * ucxclient )

◆ gst_ucx_client_set_property()

bool gst_ucx_client_set_property	(	GstUcxClient *	ucxclient,
		guint	property_id,
		const GValue *	value,
		GParamSpec *	pspec
	)

◆ gst_ucx_create_thread_pool()

int gst_ucx_create_thread_pool	(	GstTaskPool **	pool,
		gint	nvbuf_batch_size
	)

◆ gst_ucx_init()

void gst_ucx_init ( )

◆ gst_ucx_is_recv_meta()

gboolean gst_ucx_is_recv_meta	(	GstUcxSrc *	src,
		int	batch_id
	)

◆ gst_ucx_server_get_property()

bool gst_ucx_server_get_property	(	GstUcxServer *	ucxserver,
		guint	property_id,
		GValue *	value,
		GParamSpec *	pspec
	)

◆ gst_ucx_server_init()

void gst_ucx_server_init ( GstUcxServer * ucxserver )

◆ gst_ucx_server_set_property()

bool gst_ucx_server_set_property	(	GstUcxServer *	ucxserver,
		guint	property_id,
		const GValue *	value,
		GParamSpec *	pspec
	)

◆ gst_ucx_set_nvevent_data()

void gst_ucx_set_nvevent_data	(	GstEvent *	event,
		NvDsUcxAmEventDesc *	event_data,
		gboolean *	send_event
	)

◆ gst_ucx_sink_cap_event_handling()

gboolean gst_ucx_sink_cap_event_handling	(	GstUcxSink *	ucxsink,
		GstBaseSink *	basesink,
		GstEvent *	event,
		NvDsUcxAmEventDesc *	event_data,
		gboolean *	send_event
	)

◆ gst_ucx_sink_get_property()

bool gst_ucx_sink_get_property	(	GstUcxSink *	ucxsink,
		guint	property_id,
		GValue *	value,
		GParamSpec *	pspec
	)

◆ gst_ucx_sink_init()

void gst_ucx_sink_init ( GstUcxSink * ucxsink )

◆ gst_ucx_sink_set_property()

bool gst_ucx_sink_set_property	(	GstUcxSink *	ucxsink,
		guint	property_id,
		const GValue *	value,
		GParamSpec *	pspec
	)

◆ gst_ucx_src_buffer_pool_new()

gboolean gst_ucx_src_buffer_pool_new	(	GstUcxSrc *	ucxsrc,
		GstCaps *	caps
	)

◆ gst_ucx_src_get_property()

bool gst_ucx_src_get_property	(	GstUcxSrc *	ucxsrc,
		guint	property_id,
		GValue *	value,
		GParamSpec *	pspec
	)

◆ gst_ucx_src_init()

void gst_ucx_src_init ( GstUcxSrc * ucxsrc )

◆ gst_ucx_src_negotiate_caps()

gboolean gst_ucx_src_negotiate_caps	(	GstBaseSrc *	src,
		GstUcxSrc *	ucxsrc
	)

◆ gst_ucx_src_set_property()

bool gst_ucx_src_set_property	(	GstUcxSrc *	ucxsrc,
		guint	property_id,
		const GValue *	value,
		GParamSpec *	pspec
	)

◆ start_client()

int start_client	(	gpointer	data,
		bool	is_src
	)

◆ start_server()

int start_server	(	gpointer	data,
		bool	is_src
	)

◆ start_sink()

int start_sink ( GstUcxSink * ucxsink )

◆ start_src()

int start_src	(	GstUcxSrc *	ucxsrc,
		GstBaseSrc *	src
	)

◆ stop_client()

void stop_client ( GstUcxClient * ucxclient )

◆ stop_server()

void stop_server ( GstUcxServer * ucxserver )

◆ stop_sink()

void stop_sink ( GstUcxSink * ucxsink )

◆ stop_src()

void stop_src ( GstUcxSrc * ucxsrc )

◆ ucx_src_init_buffer_type_attr()

int ucx_src_init_buffer_type_attr ( GstUcxSrc * ucxsrc )


NVIDIA DeepStream SDK API Reference	9.2 Release

NVIDIA DeepStream SDK API Reference

9.2 Release

Data Structures

Macros

Typedefs

Enumerations

Functions

Macro Definition Documentation

◆ AUDIO_CHANNELS

◆ AUDIO_FORMAT

◆ BATCH_END_TIMEOUT_SEC

◆ CLIENT_ID_SIZE

◆ DEFAULT_ALLOCATOR_BPF

◆ DEFAULT_ALLOCATOR_BUF_LEN

◆ DEFAULT_GPU_ID

◆ DEFAULT_MAX_EP_NUM

◆ DEFAULT_NUM_NVBUF

◆ DEFAULT_NVBUF_BATCH_SIZE

◆ DEFAULT_NVBUF_MEMORY_TYPE

◆ DEFAULT_RAW_BUFFER_SIZE

◆ EVENT_DATA_MAX_LEN

◆ GST_AUDIO_CAPS_MAKE_WITH_FEATURES

◆ GST_CAPS_FEATURE_MEMORY_NVMM

◆ GST_TEXT_CAPS_MAKE

◆ GST_TYPE_NVDSUCX_BUF_TYPE

◆ IP_STRING_LEN

◆ MAX_MAX_EP_NUM

◆ MAX_NUM_NVBUF

◆ MAX_NVBUF_BATCH_SIZE

◆ MIN_MAX_EP_NUM

◆ MIN_NUM_NVBUF

◆ MIN_NVBUF_BATCH_SIZE

◆ NVTX_WRAPPER_END

◆ NVTX_WRAPPER_START

◆ PORT_STRING_LEN

◆ UCX_DEFAULT_ADDR

◆ UCX_DEFAULT_CONNS

◆ UCX_DEFAULT_HIGH_PERF

◆ UCX_DEFAULT_PORT

◆ UCX_HIGH_PERF_DISABLE_TLS

◆ UCX_MAX_CONNS

◆ UCX_MAX_PORT

◆ UCX_THREAD_DATA_COMMON_FIELDS

◆ VIDEO_FORMATS

Typedef Documentation

◆ gst_ucp_conn_ctx_t

◆ gst_ucx_conn_req_ctx_t

◆ GstUcxClient

◆ GstUcxClientPriv

◆ GstUcxRdmaParams

◆ GstUcxServer

◆ GstUcxServerPriv

◆ GstUcxSink

◆ GstUcxSinkAmHdrParams

◆ GstUcxSrc

◆ GstUcxThreadDataSink

◆ GstUcxThreadDataSource

◆ NvBufAudioDsUcx

◆ NvBufRawDsUcx

◆ NvBufSurfaceDsUcx

◆ NvDsCustomMetaUcx

◆ NvDsUcxAmDesc

◆ NvDsUcxAmEventDesc

◆ NvDsUcxAmHandlerFunc

◆ NvDsUcxBuf

◆ NvDsUcxSrcPrepAmFunc

◆ NvDsUcxSrcPrepAmMetaFunc

◆ NvGstBufferParams

Enumeration Type Documentation

◆ anonymous enum

◆ GstNvDsUcxAmId

◆ GstNvDsUcxBufType

Function Documentation

◆ batch_end_check_func()

◆ clear_gst_ucp_conn_ctx()

◆ copy_gstbuf_info()

◆ copy_nvbufaudio_params()

◆ copy_nvbufsurf_params()

◆ free_gst_ucp_conn_ctx()

◆ get_thread_num()