9.2/sources/libs/gstnvdscustomhelper/gst-nvdscommonconfig.h

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: Copyright (c) 2022-2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
 * SPDX-License-Identifier: Apache-2.0
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
 
#ifndef _GST_NVDSCOMMON_CONFIG_H_
#define _GST_NVDSCOMMON_CONFIG_H_
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include <gst/gst.h>
 
typedef enum
{
  SOURCE_TYPE_AUTO,
  SOURCE_TYPE_URI,
  SOURCE_TYPE_RTSP
} NvDsUriSrcBinType;
 
typedef enum
{
  DEC_SKIP_FRAMES_TYPE_NONE,
  DEC_SKIP_FRAMES_TYPE_NONREF,
  DEC_SKIP_FRAMES_TYPE_KEY_FRAME_ONLY
} NvDsUriSrcBinDecSkipFrame;
 
typedef enum
{
  RTP_PROTOCOL_UNKNOWN = 0,
  RTP_PROTOCOL_UDP = 1,
  RTP_PROTOCOL_UDP_MCAST = 2,
  RTP_PROTOCOL_TCP = 4,
  RTP_PROTOCOL_UDP_UDPMCAST_TCP = 7,
  RTP_PROTOCOL_HTTP = 10,
  RTP_PROTOCOL_TLS = 20
} NvDsUriSrcBinRtpProtocol;
 
typedef enum
{
  LEAKY_NONE,
  LEAKY_UPSTREAM,
  LEAKY_DOWNSTREAM
} NvDsUriSrcBinLeaky;
 
typedef enum
{
  BUFFER_MODE_UNKNOWN = 0,
  BUFFER_MODE_SLAVE = 1,
  BUFFER_MODE_BUFFER = 2,
  BUFFER_MODE_AUTO = 3,
  BUFFER_MODE_SYNCED = 4
} NvDsUriSrcBinBufferMode;
 
typedef enum
{
  SMART_REC_DISABLE,
  SMART_REC_CLOUD,
  SMART_REC_MULTI
} NvDsUriSrcBinSRType;
 
typedef enum
{
  SMART_REC_AUDIO_VIDEO,
  SMART_REC_VIDEO_ONLY,
  SMART_REC_AUDIO_ONLY
} NvDsUriSrcBinSRMode;
 
typedef enum
{
  SMART_REC_MP4,
  SMART_REC_MKV
} NvDsUriSrcBinSRCont;
 
typedef struct _NvDsSensorInfo
{
  guint source_id;
  gchar const* uri;
  gchar const* sensor_id;
  gchar const* sensor_name;
  /* Full per-stream metadata object from the REST stream/add request, forwarded
   * verbatim as a JSON string (variable keys). NULL/empty when none was sent.
   * Appended at end of struct to preserve ABI of existing callers. */
  gchar const* sensor_metadata;
}NvDsSensorInfo;
 
/* Model-plane completion event carried to the app bus (nvmodelmux -> app),
 * mirroring NvDsSensorInfo for streams. Emitted when an async model operation
 * ACTUALLY finishes: an engine finished warming, a version was torn down, an OTA
 * committed, or a reroute settled -- so an app can react/print exactly like it
 * does for `new stream added`. */
typedef struct _NvDsModelEventInfo
{
  gchar const* event;       /* "model-loaded" | "model-unloaded" | "model-updated" | "streams-routed" */
  gchar const* name;        /* model name                                                            */
  gchar const* version;     /* version token ("1"), or "1 -> 2" for an update                        */
  gint         gpu;         /* resolved inference device (-1 = not applicable)                       */
  gboolean     ok;          /* TRUE = success, FALSE = failed                                        */
  gchar const* detail;      /* optional extra context (e.g. routed stream list); NULL/empty if none  */
}NvDsModelEventInfo;
 
typedef struct _NvDsRtspAttemptsInfo
{
  gboolean attempt_exceeded;
  guint source_id;
}NvDsRtspAttemptsInfo;
 
/* MODEL-PLANE control payload -- carried on the model-load / model-unload /
 * model-update custom events (and bus messages) forwarded by nvmultiurisrcbin
 * when its native REST receives /api/v1/model/load|unload|update.
 *
 * The payload is the request's "value" object, SERIALIZED VERBATIM as JSON:
 * one schema end-to-end (REST body == event payload == action-signal payload),
 * so nested fields (engine_files{}, instances[]) travel intact and the schema
 * can grow without new positional arguments. The consuming element parses it
 * (nvmodelmux uses json-glib). See gst-nvmodelmux/API_DESIGN.md for the schema:
 *   load:   { name, version, config_file?, engine_file?|engine_files{}?,
 *             instances[{gpu}]? }
 *   unload: { name, version? }
 *   update: { name, from_version, version, engine_file|engine_files{} }
 *           (IN-PLACE checkpoint transition -- never routes streams) */
typedef struct _NvDsModelInfo
{
  gchar const* value_json;          
}NvDsModelInfo;
 
/* STREAM-ROUTING control payload -- carried on the model-routing custom event
 * (and bus message) for /api/v1/model/routing. Same verbatim-JSON contract as
 * NvDsModelInfo. nvmultiurisrcbin AUGMENTS each route entry with the resolved
 * "source_ids" array (it owns the camera_id -> source_id map) before
 * forwarding; a camera_id that resolves to no live stream rejects the whole
 * document at the bin (atomic admission).
 *   { if_revision?, routes[ { streams:[camera_id...]|"all", source_ids[]?,
 *     model:{name,version,gpu?}|null, shadow:{...}|null } ]?,
 *     default{ model:{...}, shadow:{...}|null }? } */
typedef struct _NvDsRouteInfo
{
  gchar const* value_json;          
}NvDsRouteInfo;
 
typedef struct _GstDsNvUriSrcConfig
{
  NvDsUriSrcBinType src_type;
  gboolean loop;
  gchar *uri;
  gchar *sei_uuid;
  gint latency;
  NvDsUriSrcBinSRType smart_record;
  gchar *smart_rec_dir_path;
  gchar *smart_rec_file_prefix;
  NvDsUriSrcBinSRCont smart_rec_container;
  NvDsUriSrcBinSRMode smart_rec_mode;
  guint smart_rec_def_duration;
  guint smart_rec_cache_size;
  guint gpu_id;
  gint source_id;
  NvDsUriSrcBinRtpProtocol rtp_protocol;
  NvDsUriSrcBinBufferMode buffer_mode;
  guint num_extra_surfaces;
  NvDsUriSrcBinDecSkipFrame skip_frames_type;
  guint cuda_memory_type;
  guint drop_frame_interval;
  gboolean low_latency_mode;
  gboolean extract_sei_type5_data;
  gint rtsp_reconnect_interval_sec_org;
  gint rtsp_reconnect_interval_sec;
  NvDsUriSrcBinLeaky leaky;
  guint max_size_buffers;
  gint init_rtsp_reconnect_interval_sec;
  gint rtsp_reconnect_attempts;
  gint num_rtsp_reconnects;
  guint udp_buffer_size;
  gchar *sensorId; 
  gboolean disable_passthrough;
  gchar *sensorName; 
  gboolean disable_audio;
  gboolean drop_on_latency;
  gboolean ipc_buffer_timestamp_copy;
  gchar *ipc_socket_path;
  gint ipc_connection_attempts;
  guint64 ipc_connection_interval;
  gboolean sensorIdToPadIdMapping;
  gboolean enable_error_propagation;
  gchar* proto_lib;
  gchar* conn_str;
  gchar* topic;
  guint simulate_fps_interval_ms;
  guint64 creation_time_ns; 
  guint64 file_start_time_ns; 
  /* VIA-S-5: publish this source's DECODED frames over IPC (per-source nvunixfdsink,
   * tapped right after the decoder). Socket: /tmp/nvds_ipc_<source_id>.sock */
  gboolean ipc_frame_copy;
  gchar *sensorMetadata; 
} GstDsNvUriSrcConfig;
 
typedef struct
{
  // Struct members to store config / properties for the element
 
  //mandatory configs when using legacy nvstreammux
  gint pipeline_width;
  gint pipeline_height;
  gint batched_push_timeout;
 
  //not mandatory; auto configured
  gint batch_size;
 
  //not mandatory; defaults will be used
  gint buffer_pool_size;
  gint compute_hw;
  gint num_surfaces_per_frame;
  gint interpolation_method;
  guint gpu_id;
  guint nvbuf_memory_type;
  gboolean live_source;
  gboolean enable_padding;
  gboolean attach_sys_ts_as_ntp;
  gchar* config_file_path;
  gboolean sync_inputs;
  guint64 max_latency;
  gboolean frame_num_reset_on_eos;
  gboolean frame_num_reset_on_stream_reset;
 
  guint64 frame_duration;
  guint maxBatchSize;
  gboolean async_process;
  gboolean no_pipeline_eos;
  gboolean extract_sei_type5_data;
  gboolean sort_batch;
  gboolean buffer_cache;
  gint buffer_cache_timeout;
  gboolean extract_sei_sim_time;
  gboolean align_first_buffer;
  guint sync_inputs_ntp;
  gboolean drop_backward_sei;
  /* Forwarded to the internal legacy nvstreammux: drop input buffers on each
   * source until an RTCP Sender Report derived NTP timestamp is available. */
  gboolean drop_until_rtcp_sr;
  /* VIA-S-5: if TRUE, publish each source's DECODED frames over IPC (per-source
   * nvunixfdsink, tapped right after the decoder, before the internal mux).
   * Socket per source: /tmp/nvds_ipc_<sensorId|source_id>.sock */
  gboolean ipc_frame_copy;
} GstDsNvStreammuxConfig;
 
#ifdef __cplusplus
}
#endif
 
#endif