mqttcommon.h

Go to the documentation of this file.

/* SPDX-License-Identifier: LGPL-2.1-only */
#ifndef __GST_MQTT_COMMON_H__
#define __GST_MQTT_COMMON_H__
#include <stdint.h>
 
#ifndef UNUSED
#define UNUSED(expr) do { (void)(expr); } while (0)
#endif /* UNUSED */
 
#ifndef GST_MQTT_PACKAGE
#define GST_MQTT_PACKAGE "GStreamer MQTT Plugins"
#endif /* GST_MQTT_PACKAGE */
 
#define GST_MQTT_ELEM_NAME_SINK "mqttsink"
#define GST_MQTT_ELEM_NAME_SRC "mqttsrc"
 
#define GST_MQTT_LEN_MSG_HDR          1024
#define GST_MQTT_MAX_LEN_GST_CAPS_STR 512
 
#define GST_MQTT_MAX_NUM_MEMS   16
 
#define GST_US_TO_NS_MULTIPLIER 1000
 
#define DEFAULT_MQTT_CONN_TIMEOUT_SEC 5
 
typedef struct _GstMQTTMessageHdr {
  union {
    struct {
      guint num_mems;
      gsize size_mems[GST_MQTT_MAX_NUM_MEMS];
      gint64 base_time_epoch;
      gint64 sent_time_epoch;
      GstClockTime duration;
      GstClockTime dts;
      GstClockTime pts;
      gchar gst_caps_str[GST_MQTT_MAX_LEN_GST_CAPS_STR];
    };
    guint8 _reserved_hdr[GST_MQTT_LEN_MSG_HDR];
  };
} GstMQTTMessageHdr;
 
typedef int64_t (*mqtt_get_unix_epoch)(uint32_t, char **, uint16_t *);
 
static inline int64_t default_mqtt_get_unix_epoch (uint32_t hnum, char **hnames,
    uint16_t *hports)
{
  UNUSED (hnum);
  UNUSED (hnames);
  UNUSED (hports);
  return g_get_real_time ();
}
 
#endif /* !__GST_MQTT_COMMON_H__ */