edge_sink.h

Go to the documentation of this file.

/* SPDX-License-Identifier: LGPL-2.1-only */
#ifndef __GST_EDGE_SINK_H__
#define __GST_EDGE_SINK_H__
 
#include <gst/gst.h>
#include <gst/base/gstbasesink.h>
#include "edge_common.h"
#include <nnstreamer-edge.h>
#include "nnstreamer_log.h"
#include "nnstreamer_plugin_api.h"
#include "tensor_typedef.h"
 
G_BEGIN_DECLS
#define GST_TYPE_EDGESINK \
    (gst_edgesink_get_type())
#define GST_EDGESINK(obj) \
    (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_EDGESINK,GstEdgeSink))
#define GST_EDGESINK_CLASS(klass) \
    (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_EDGESINK,GstEdgeSinkClass))
#define GST_IS_EDGESINK(obj) \
    (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_EDGESINK))
#define GST_IS_EDGESINK_CLASS(klass) \
    (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_EDGESINK))
#define GST_EDGESINK_CAST(obj) ((GstEdgeSink *)(obj))
typedef struct _GstEdgeSink GstEdgeSink;
typedef struct _GstEdgeSinkClass GstEdgeSinkClass;
 
struct _GstEdgeSink
{
  GstBaseSink element;
 
  gchar *host;
  guint16 port;
  gchar *dest_host;
  guint16 dest_port;
  gchar *topic;
 
  nns_edge_connect_type_e connect_type;
  nns_edge_h edge_h;
  gboolean wait_connection;
  guint64 connection_timeout;
 
  gchar *custom_lib;
  gboolean is_connected;
  GMutex lock;
  GCond cond;
};
 
struct _GstEdgeSinkClass
{
  GstBaseSinkClass parent_class;   
};
 
GType gst_edgesink_get_type (void);
 
G_END_DECLS
#endif /* __GST_EDGE_SINK_H__ */