gsttensor_repo.h

Go to the documentation of this file.

 
#ifndef __GST_TENSOR_REPO_H__
#define __GST_TENSOR_REPO_H__
 
#include <glib.h>
#include <gst/gst.h>
 
#include "tensor_common.h"
 
G_BEGIN_DECLS
 
typedef struct
{
  GstBuffer *buffer;
  GstCaps *caps;
  GCond cond_push;
  GCond cond_pull;
  GMutex lock;
  gboolean eos;
  gboolean src_changed;
  guint src_id;
  gboolean sink_changed;
  guint sink_id;
  gboolean pushed;
} GstTensorRepoData;
 
typedef struct
{
  guint num_data;
  GMutex repo_lock;
  GCond repo_cond;
  GHashTable* hash;
  gboolean initialized;
} GstTensorRepo;
 
GstTensorRepoData *
gst_tensor_repo_get_repodata (guint nth);
 
gboolean
gst_tensor_repo_add_repodata (guint myid, gboolean is_sink);
 
gboolean
gst_tensor_repo_set_buffer (guint nth, GstBuffer * buffer, GstCaps * caps);
 
gboolean
gst_tensor_repo_check_eos (guint nth);
 
gboolean
gst_tensor_repo_set_eos (guint nth);
 
gboolean
gst_tensor_repo_set_changed (guint o_nth, guint nth, gboolean is_sink);
 
GstBuffer *
gst_tensor_repo_get_buffer (guint nth, gboolean * eos, guint * newid, GstCaps ** caps);
 
gboolean
gst_tensor_repo_check_changed (guint nth, guint * newid, gboolean is_sink);
 
gboolean
gst_tensor_repo_remove_repodata (guint nth);
 
void
gst_tensor_repo_init (void);
 
gboolean
gst_tensor_repo_wait (void);
 
G_END_DECLS
 
#endif /* __GST_TENSOR_REPO_H__ */