tensor_query_serversrc.h

Go to the documentation of this file.

/* SPDX-License-Identifier: LGPL-2.1-only */
#ifndef __GST_TENSOR_QUERY_SERVERSRC_H__
#define __GST_TENSOR_QUERY_SERVERSRC_H__
 
#include <gst/base/gstbasesrc.h>
#include <gst/base/gstpushsrc.h>
#include <tensor_meta.h>
#include "tensor_query_server.h"
 
G_BEGIN_DECLS
#define GST_TYPE_TENSOR_QUERY_SERVERSRC \
  (gst_tensor_query_serversrc_get_type())
#define GST_TENSOR_QUERY_SERVERSRC(obj) \
  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_TENSOR_QUERY_SERVERSRC,GstTensorQueryServerSrc))
#define GST_TENSOR_QUERY_SERVERSRC_CLASS(klass) \
  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_TENSOR_QUERY_SERVERSRC,GstTensorQueryServerSrcClass))
#define GST_IS_TENSOR_QUERY_SERVERSRC(obj) \
  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_TENSOR_QUERY_SERVERSRC))
#define GST_IS_TENSOR_QUERY_SERVERSRC_CLASS(klass) \
  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_TENSOR_QUERY_SERVERSRC))
#define GST_TENSOR_QUERY_SERVERSRC_CAST(obj) ((GstTensorQueryServerSrc *)(obj))
typedef struct _GstTensorQueryServerSrc GstTensorQueryServerSrc;
typedef struct _GstTensorQueryServerSrcClass GstTensorQueryServerSrcClass;
 
struct _GstTensorQueryServerSrc
{
  GstPushSrc element; /* parent object */
  guint src_id;
  gboolean configured;
 
  gchar *host;
  guint16 port;
  gchar *dest_host;
  guint16 dest_port;
  guint timeout;
 
  /* Query-hybrid feature */
  gchar *topic; 
  nns_edge_connect_type_e connect_type;
  GAsyncQueue *msg_queue;
  gboolean playing;
};
 
struct _GstTensorQueryServerSrcClass
{
  GstPushSrcClass parent_class; 
};
 
GType gst_tensor_query_serversrc_get_type (void);
 
G_END_DECLS
#endif /* __GST_TENSOR_QUERY_SERVERSRC_H__ */