tensor_query_server.h

Go to the documentation of this file.

/* SPDX-License-Identifier: LGPL-2.1-only */
#ifndef __GST_TENSOR_QUERY_SERVER_H__
#define __GST_TENSOR_QUERY_SERVER_H__
 
#include <gst/gst.h>
#include <tensor_common.h>
#include <nnstreamer-edge.h>
#include "tensor_meta.h"
 
G_BEGIN_DECLS
#define DEFAULT_SERVER_ID 0
#define DEFAULT_QUERY_INFO_TIMEOUT 5
 
typedef struct
{
  gchar *host;
  guint16 port;
  gchar *dest_host;
  guint16 dest_port;
  gchar *topic;
 
  /* nns-edge callback info */
  nns_edge_event_cb cb;
  void *pdata;
} GstTensorQueryEdgeInfo;
 
typedef struct
{
  guint id;
  gboolean configured;
  GMutex lock;
  GCond cond;
 
  nns_edge_h edge_h;
} GstTensorQueryServer;
 
gboolean gst_tensor_query_server_add_data (const guint id);
 
gboolean gst_tensor_query_server_prepare (const guint id,
    nns_edge_connect_type_e connect_type, GstTensorQueryEdgeInfo *edge_info);
 
void gst_tensor_query_server_remove_data (const guint id);
 
gboolean gst_tensor_query_server_wait_sink (const guint id);
 
gboolean gst_tensor_query_server_send_buffer (const guint id, GstBuffer *buffer);
 
void gst_tensor_query_server_set_configured (const guint id);
 
void gst_tensor_query_server_set_caps (const guint id, const gchar *caps_str);
 
void gst_tensor_query_server_release_edge_handle (const guint id);
 
G_END_DECLS
#endif /* __GST_TENSOR_QUERY_CLIENT_H__ */