tensor_query_client.h

Go to the documentation of this file.

/* SPDX-License-Identifier: LGPL-2.1-only */
#ifndef __GST_TENSOR_QUERY_CLIENT_H__
#define __GST_TENSOR_QUERY_CLIENT_H__
 
#include <gst/gst.h>
#include <gio/gio.h>
#include <tensor_common.h>
#include <nnstreamer-edge.h>
 
G_BEGIN_DECLS
 
#define GST_TYPE_TENSOR_QUERY_CLIENT \
  (gst_tensor_query_client_get_type())
#define GST_TENSOR_QUERY_CLIENT(obj) \
  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_TENSOR_QUERY_CLIENT,GstTensorQueryClient))
#define GST_TENSOR_QUERY_CLIENT_CLASS(klass) \
  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_TENSOR_QUERY_CLIENT,GstTensorQueryClientClass))
#define GST_IS_TENSOR_QUERY_CLIENT(obj) \
  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_TENSOR_QUERY_CLIENT))
#define GST_IS_TENSOR_QUERY_CLIENT_CLASS(klass) \
  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_TENSOR_QUERY_CLIENT))
#define GST_TENSOR_QUERY_CLIENT_CAST(obj) ((GstTensorQueryClient *)(obj))
 
typedef struct _GstTensorQueryClient GstTensorQueryClient;
typedef struct _GstTensorQueryClientClass GstTensorQueryClientClass;
 
struct _GstTensorQueryClient
{
  GstElement element; 
  GstPad *sinkpad; 
  GstPad *srcpad; 
  gboolean silent; 
  gchar *in_caps_str;
  gboolean is_tensor;
  GstTensorsConfig config;
  guint timeout; 
  /* Query-hybrid feature */
  gchar *topic; 
  gchar *host;
  guint16 port;
  gchar *dest_host;
  guint16 dest_port;
 
  nns_edge_connect_type_e connect_type;
  nns_edge_h edge_h;
  GAsyncQueue *msg_queue;
 
  guint max_request;
  guint requested_num;
};
 
struct _GstTensorQueryClientClass
{
  GstElementClass parent_class; 
};
 
GType gst_tensor_query_client_get_type (void);
 
G_END_DECLS
#endif /* __GST_TENSOR_QUERY_CLIENT_H__ */