gnunet_gst.c File Reference

FIXME. More...

#include "platform.h"
#include "gnunet_gst_def.h"

Include dependency graph for gnunet_gst.c:

Go to the source code of this file.

Functions
void	dump_buffer (unsigned n, const unsigned char *buf)
void	gg_load_configuration (GNUNET_gstData *d)
static void	write_data (const char *ptr, size_t msg_size)
GstFlowReturn	on_appsink_new_sample (GstElement *element, GNUNET_gstData *d)
void	pl_graph (GstElement *pipeline)
gboolean	gnunet_gst_bus_call (GstBus *bus, GstMessage *msg, gpointer data)
void	state_changed_cb (GstBus *bus, GstMessage *msg, GNUNET_gstData *d)
static void	application_cb (GstBus *bus, GstMessage *msg, GNUNET_gstData *data)
static void	error_cb (GstBus *bus, GstMessage *msg, GNUNET_gstData *data)
static void	eos_cb (GstBus *bus, GstMessage *msg, GNUNET_gstData *data)
void	gg_setup_gst_bus (GNUNET_gstData *d)
int	feed_buffer_to_gst (const char *audio, size_t b_len, GNUNET_gstData *d)
GstElement *	gst_element_factory_make_debug (gchar *factoryname, gchar *name)
	debug making elements More...
void	lf (char *msg)
static void	autoaudiosink_child_added (GstChildProxy *child_proxy, GObject *object, gchar *name, gpointer user_data)
static void	autoaudiosource_child_added (GstChildProxy *child_proxy, GObject *object, gchar *name, gpointer user_data)
GstElement *	get_pipeline (GstElement *element)
static void	decoder_ogg_pad_added (GstElement *element, GstPad *pad, gpointer data)
int	gnunet_read (GNUNET_gstData *d)
static int	stdin_receiver (void *cls, const struct GNUNET_MessageHeader *msg)
	Message callback. More...
GstBin *	get_app (GNUNET_gstData *d, int type)
GstBin *	get_coder (GNUNET_gstData *d, int type)
GstBin *	get_audiobin (GNUNET_gstData *d, int type)

Variables
static struct GNUNET_CONFIGURATION_Handle *	cfg
	Our configuration. More...

Detailed Description

FIXME.

Author

Hark

Definition in file gnunet_gst.c.

Function Documentation

dump_buffer()

void dump_buffer	(	unsigned	n,
		const unsigned char *	buf
	)

Definition at line 35 of file gnunet_gst.c.

{
  const unsigned char *p, *end;
  unsigned i, j;
 
  end = buf + n;
 
  for (i = 0;; i += 16)
  {
    p = buf + i;
    for (j = 0; j < 16; j++)
    {
      fprintf (stderr, "%02X ", p[j]);
      if (p + j >= end)
        goto BREAKOUT;
    }
    fprintf (stderr, " ");
    p = buf + i;
    for (j = 0; j < 16; j++)
    {
      fprintf (stderr, "%c", isprint (p[j]) ? p[j] :
               '.');
      if (p + j >= end)
        goto BREAKOUT;
    }
    fprintf (stderr, "\n");
  }
BREAKOUT:
  return;
}

References end, and p.

Referenced by stdin_receiver().

Here is the caller graph for this function:

gg_load_configuration()

void gg_load_configuration

(

GNUNET_gstData *

d

)

Definition at line 71 of file gnunet_gst.c.

{
  char *audiobackend_string;
 
  cfg = GNUNET_CONFIGURATION_create ();
  GNUNET_CONFIGURATION_load (cfg, "mediahelper.conf");
 
  GNUNET_CONFIGURATION_get_value_string (cfg, "MEDIAHELPER", "JACK_PP_IN",
                                         &d->jack_pp_in);
  GNUNET_CONFIGURATION_get_value_string (cfg, "MEDIAHELPER", "JACK_PP_OUT",
                                         &d->jack_pp_out);
 
  GNUNET_CONFIGURATION_get_value_string (cfg, "MEDIAHELPER", "AUDIOBACKEND",
                                         &audiobackend_string);
 
  // printf("abstring: %s \n", audiobackend_string);
 
  if (0 == strcasecmp (audiobackend_string, "AUTO"))
  {
    d->audiobackend = AUTO;
  }
  else if (0 == strcasecmp (audiobackend_string, "JACK"))
  {
    d->audiobackend = JACK;
  }
  else if (0 == strcasecmp (audiobackend_string, "ALSA"))
  {
    d->audiobackend = ALSA;
  }
  else if (0 == strcasecmp (audiobackend_string, "FAKE"))
  {
    d->audiobackend = FAKE;
  }
  else if (0 == strcasecmp (audiobackend_string, "TEST"))
  {
    d->audiobackend = TEST;
  }
  else
  {
    d->audiobackend = AUTO;
  }
 
  if (GNUNET_CONFIGURATION_get_value_yesno (cfg, "MEDIAHELPER",
                                            "REMOVESILENCE") == GNUNET_YES)
  {
    d->dropsilence = TRUE;
  }
  else
  {
    d->dropsilence = FALSE;
  }
 
  if (GNUNET_CONFIGURATION_get_value_yesno (cfg, "MEDIAHELPER",
                                            "NO_GN_HEADERS") == GNUNET_YES)
  {
    d->pure_ogg = TRUE;
  }
  else
  {
    d->pure_ogg = FALSE;
  }
 
 
  if (GNUNET_CONFIGURATION_get_value_yesno (cfg, "MEDIAHELPER", "USERTP") ==
      GNUNET_YES)
  {
    d->usertp = TRUE;
  }
  else
  {
    d->usertp = FALSE;
  }
 
//  GNUNET_CONFIGURATION_write(cfg, "mediahelper.conf");
}

References ALSA, AUTO, cfg, d, FAKE, GNUNET_CONFIGURATION_create(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_CONFIGURATION_get_value_yesno(), GNUNET_CONFIGURATION_load(), GNUNET_YES, JACK, and TEST.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

write_data()

static void write_data ( const char *  ptr, size_t  msg_size  )

static

Definition at line 149 of file gnunet_gst.c.

{
  ssize_t ret;
  size_t off;
 
  off = 0;
  while (off < msg_size)
  {
    ret = write (1, &ptr[off], msg_size - off);
    if (0 >= ret)
    {
      if (-1 == ret)
        GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, "write");
//      quit (2);
    }
    off += ret;
  }
}

References GNUNET_ERROR_TYPE_ERROR, GNUNET_log_strerror, and ret.

Referenced by on_appsink_new_sample().

Here is the caller graph for this function:

on_appsink_new_sample()

GstFlowReturn on_appsink_new_sample	(	GstElement *	element,
		GNUNET_gstData *	d
	)

Definition at line 170 of file gnunet_gst.c.

{
  // size of message including gnunet header
  size_t msg_size;
 
  GstSample *s;
  GstBuffer *b;
  GstMapInfo map;
 
/*
   const GstStructure *si;
   char *si_str;
   GstCaps *s_caps;
   char *caps_str;
 */if (gst_app_sink_is_eos (GST_APP_SINK (element)))
    return GST_FLOW_OK;
 
  // pull sample from appsink
  s = gst_app_sink_pull_sample (GST_APP_SINK (element));
 
  if (s == NULL)
    return GST_FLOW_OK;
 
  if (! GST_IS_SAMPLE (s))
    return GST_FLOW_OK;
 
  b = gst_sample_get_buffer (s);
 
  GST_WARNING ("caps are %" GST_PTR_FORMAT, gst_sample_get_caps (s));
 
 
  gst_buffer_map (b, &map, GST_MAP_READ);
 
  size_t len;
  len = map.size;
  if (len > UINT16_MAX - sizeof(struct AudioMessage))
  {
    // this should never happen?
    printf ("GSTREAMER sample too big! \n");
    exit (20);
    len = UINT16_MAX - sizeof(struct AudioMessage);
  }
 
  msg_size = sizeof(struct AudioMessage) + len;
 
  // copy the data into audio_message
  GNUNET_memcpy (((char *) &(d->audio_message)[1]), map.data, len);
  (d->audio_message)->header.size = htons ((uint16_t) msg_size);
  if (d->pure_ogg)
    // write the audio_message without the gnunet headers
    write_data ((const char *) &(d->audio_message)[1], len);
  else
    write_data ((const char *) d->audio_message, msg_size);
 
  gst_sample_unref (s);
  return GST_FLOW_OK;
}

References d, GNUNET_memcpy, AudioMessage::header, map, GNUNET_MessageHeader::size, GNUNET_CONTAINER_MultiPeerMap::size, and write_data().

Referenced by get_app().

Here is the call graph for this function:

Here is the caller graph for this function:

pl_graph()

void pl_graph

(

GstElement *

pipeline

)

Definition at line 233 of file gnunet_gst.c.

{
#ifdef IS_SPEAKER
  gst_debug_bin_to_dot_file_with_ts (GST_BIN (pipeline),
                                     GST_DEBUG_GRAPH_SHOW_ALL,
                                     "playback_helper.dot");
#endif
#ifdef IS_MIC
  gst_debug_bin_to_dot_file_with_ts (GST_BIN (pipeline),
                                     GST_DEBUG_GRAPH_SHOW_ALL,
                                     "record_helper.dot");
#endif
 
 
  //  load_configuration();
}

References pipeline.

Referenced by main(), and state_changed_cb().

Here is the caller graph for this function:

gnunet_gst_bus_call()

gboolean gnunet_gst_bus_call	(	GstBus *	bus,
		GstMessage *	msg,
		gpointer	data
	)

Definition at line 252 of file gnunet_gst.c.

{
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Bus message\n");
  switch (GST_MESSAGE_TYPE (msg))
  {
  case GST_MESSAGE_EOS:
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "End of stream\n");
    exit (10);
    break;
 
  case GST_MESSAGE_ERROR:
    {
      gchar  *debug;
      GError *error;
 
      gst_message_parse_error (msg, &error, &debug);
      g_free (debug);
 
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  "Error: %s\n",
                  error->message);
      g_error_free (error);
 
      exit (10);
      break;
    }
 
  default:
    break;
  }
 
  return TRUE;
}

References find_typedefs::debug, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_log, and msg.

state_changed_cb()

void state_changed_cb	(	GstBus *	bus,
		GstMessage *	msg,
		GNUNET_gstData *	d
	)

Definition at line 291 of file gnunet_gst.c.

{
  GstState old_state, new_state, pending_state;
 
  gst_message_parse_state_changed (msg, &old_state, &new_state,
                                   &pending_state);
  switch (new_state)
  {
  case GST_STATE_READY:
//      printf("ready.... \n");
    // pl_graph(GST_ELEMENT(d->pipeline));
    break;
 
  case GST_STATE_PLAYING:
 
    // GST_LOG ("caps are %" GST_PTR_FORMAT, caps);
 
    //     printf("Playing.... \n");
    pl_graph (GST_ELEMENT (d->pipeline));
    break;
 
  case GST_STATE_VOID_PENDING:
    //   printf("void_pending.... \n");
    // pl_graph(GST_ELEMENT(d->pipeline));
    break;
 
  case GST_STATE_NULL:
    //  printf("null.... \n");
    // pl_graph(GST_ELEMENT(d->pipeline));
    break;
 
  case GST_STATE_PAUSED:
    //     printf("paused.... \n");
    // pl_graph(GST_ELEMENT(d->pipeline));
    break;
  }
}

References d, msg, and pl_graph().

Referenced by gg_setup_gst_bus().

Here is the call graph for this function:

Here is the caller graph for this function:

application_cb()

static void application_cb ( GstBus *  bus, GstMessage *  msg, GNUNET_gstData *  data  )

static

Definition at line 331 of file gnunet_gst.c.

{
  // printf("application cb");
  return;
}

Referenced by gg_setup_gst_bus().

Here is the caller graph for this function:

error_cb()

static void error_cb ( GstBus *  bus, GstMessage *  msg, GNUNET_gstData *  data  )

static

Definition at line 339 of file gnunet_gst.c.

{
  // printf("error cb");
  return;
}

Referenced by gg_setup_gst_bus().

Here is the caller graph for this function:

eos_cb()

static void eos_cb ( GstBus *  bus, GstMessage *  msg, GNUNET_gstData *  data  )

static

Definition at line 347 of file gnunet_gst.c.

{
  // printf("eos cb");
  return;
}

Referenced by gg_setup_gst_bus().

Here is the caller graph for this function:

gg_setup_gst_bus()

void gg_setup_gst_bus

(

GNUNET_gstData *

d

)

Definition at line 355 of file gnunet_gst.c.

{
  GstBus *bus;
 
  bus = gst_element_get_bus (GST_ELEMENT (d->pipeline));
  gst_bus_add_signal_watch (bus);
  g_signal_connect (G_OBJECT (bus), "message::error", (GCallback) error_cb,
                    d);
  g_signal_connect (G_OBJECT (bus), "message::eos", (GCallback) eos_cb,
                    d);
  g_signal_connect (G_OBJECT (bus), "message::state-changed",
                    (GCallback) state_changed_cb, d);
  g_signal_connect (G_OBJECT (bus), "message::application",
                    (GCallback) application_cb, d);
  g_signal_connect (G_OBJECT (bus), "message::about-to-finish",
                    (GCallback) application_cb, d);
  gst_object_unref (bus);
}

References application_cb(), d, eos_cb(), error_cb(), and state_changed_cb().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

feed_buffer_to_gst()

int feed_buffer_to_gst	(	const char *	audio,
		size_t	b_len,
		GNUNET_gstData *	d
	)

Definition at line 496 of file gnunet_gst.c.

{
  GstBuffer *b;
  gchar *bufspace;
  GstFlowReturn flow;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Feeding %u bytes to GStreamer\n",
              (unsigned int) b_len);
 
  bufspace = g_memdup (audio, b_len);
  b = gst_buffer_new_wrapped (bufspace, b_len);
  if (NULL == b)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Failed to wrap a buffer\n");
    g_free (bufspace);
    return GNUNET_SYSERR;
  }
  if (GST_APP_SRC (d->appsrc) == NULL)
    exit (10);
  flow = gst_app_src_push_buffer (GST_APP_SRC (d->appsrc), b);
  /* They all return GNUNET_OK, because currently player stops when
   * data stops coming. This might need to be changed for the player
   * to also stop when pipeline breaks.
   */
  switch (flow)
  {
  case GST_FLOW_OK:
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Fed %u bytes to the pipeline\n",
                (unsigned int) b_len);
    break;
 
  case GST_FLOW_FLUSHING:
    /* buffer was dropped, because pipeline state is not PAUSED or PLAYING */
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "Dropped a buffer\n");
    break;
 
  case GST_FLOW_EOS:
    /* end of stream */
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "EOS\n");
    break;
 
  default:
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                "Unexpected push result\n");
    break;
  }
  return GNUNET_OK;
}

References d, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_INFO, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_OK, and GNUNET_SYSERR.

Referenced by gnunet_read(), and stdin_receiver().

Here is the caller graph for this function:

gst_element_factory_make_debug()

GstElement * gst_element_factory_make_debug	(	gchar *	factoryname,
		gchar *	name
	)

debug making elements

Definition at line 555 of file gnunet_gst.c.

{
  GstElement *element;
 
  element = gst_element_factory_make (factoryname, name);
 
  if (element == NULL)
  {
    printf ("\n Failed to create element - type: %s name: %s \n", factoryname,
            name);
    exit (10);
    return element;
  }
  else
  {
    return element;
  }
}

References gst_element_factory_make, and name.

lf()

void lf

(

char *

msg

)

Definition at line 587 of file gnunet_gst.c.

{
  printf ("linking elements failed: %s", msg);
  exit (10);
}

References msg.

Referenced by get_audiobin(), and handle_helper_local_finished().

Here is the caller graph for this function:

autoaudiosink_child_added()

static void autoaudiosink_child_added ( GstChildProxy *  child_proxy, GObject *  object, gchar *  name, gpointer  user_data  )

static

Definition at line 598 of file gnunet_gst.c.

{
  if (GST_IS_AUDIO_BASE_SRC (object))
    g_object_set (object,
                  "buffer-time", (gint64) BUFFER_TIME,
                  "latency-time", (gint64) LATENCY_TIME,
                  NULL);
}

References BUFFER_TIME, and LATENCY_TIME.

Referenced by get_audiobin().

Here is the caller graph for this function:

autoaudiosource_child_added()

static void autoaudiosource_child_added ( GstChildProxy *  child_proxy, GObject *  object, gchar *  name, gpointer  user_data  )

static

Definition at line 615 of file gnunet_gst.c.

{
  if (GST_IS_AUDIO_BASE_SRC (object))
    g_object_set (object, "buffer-time", (gint64) BUFFER_TIME, "latency-time",
                  (gint64) LATENCY_TIME, NULL);
}

References BUFFER_TIME, and LATENCY_TIME.

Referenced by get_audiobin().

Here is the caller graph for this function:

get_pipeline()

GstElement * get_pipeline

(

GstElement *

element

)

Definition at line 625 of file gnunet_gst.c.

{
  GstPipeline *p;
 
  p = GST_PIPELINE (gst_object_get_parent (GST_OBJECT (element)));
 
  return GST_ELEMENT (p);
}

References p.

decoder_ogg_pad_added()

static void decoder_ogg_pad_added ( GstElement *  element, GstPad *  pad, gpointer  data  )

static

Definition at line 636 of file gnunet_gst.c.

{
  GstPad *sinkpad;
  GstElement *decoder = (GstElement *) data;
 
  printf ("==== ogg pad added callback \n");
  /* We can now link this pad with the opus-decoder sink pad */
//  pl_graph(get_pipeline(element));
  sinkpad = gst_element_get_static_pad (decoder, "sink");
 
  gst_pad_link (pad, sinkpad);
  gst_element_link_many (element, decoder, NULL);
  gst_object_unref (sinkpad);
}

References data, and decoder.

Referenced by get_coder().

Here is the caller graph for this function:

gnunet_read()

int gnunet_read

(

GNUNET_gstData *

d

)

Definition at line 655 of file gnunet_gst.c.

{
  char readbuf[MAXLINE];
  int ret;
 
  printf ("read \n");
  ret = read (0, readbuf, sizeof(readbuf));
  if (0 > ret)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                _ ("Read error from STDIN: %d %s\n"),
                ret, strerror (errno));
    return FAIL;
  }
  // toff += ret;
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Received %d bytes of audio data\n",
              (int) ret);
  if (0 == ret)
    return FAIL;
  // #ifdef DEBUG_READ_PURE_OGG
 
  if (d->pure_ogg)
  {
    feed_buffer_to_gst (readbuf, ret, d);
  }
  else
  {
    // #endif
    GNUNET_MST_from_buffer (d->stdin_mst,
                            readbuf,
                            ret,
                            GNUNET_NO,
                            GNUNET_NO);
  }
  return 0;
}

References _, d, FAIL, feed_buffer_to_gst(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_MST_from_buffer(), GNUNET_NO, MAXLINE, and ret.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

stdin_receiver()

static int stdin_receiver ( void *  cls, const struct GNUNET_MessageHeader *  msg  )

static

Message callback.

Parameters

msg	message we received.

Returns

GNUNET_OK on success, GNUNET_NO to stop further processing due to disconnect (no error) GNUNET_SYSERR to stop further processing due to error

Definition at line 703 of file gnunet_gst.c.

{
  struct AudioMessage *audio;
  size_t b_len;
 
  printf ("stdin receiver \n ");
  dump_buffer (sizeof(msg),
               (const unsigned char *) msg);
 
  switch (ntohs (msg->type))
  {
  case GNUNET_MESSAGE_TYPE_CONVERSATION_AUDIO:
    audio = (struct AudioMessage *) msg;
 
    b_len = ntohs (audio->header.size) - sizeof(struct AudioMessage);
    printf ("feeding buffer to gst \n ");
    feed_buffer_to_gst ((const char *) &audio[1], b_len, cls);
    break;
 
  default:
    printf ("No audio message: %u \n ", ntohs (msg->type));
    break;
  }
  return GNUNET_OK;
}

References dump_buffer(), feed_buffer_to_gst(), GNUNET_MESSAGE_TYPE_CONVERSATION_AUDIO, GNUNET_OK, AudioMessage::header, msg, GNUNET_MessageHeader::size, and GNUNET_MessageHeader::type.

Referenced by get_app().

Here is the call graph for this function:

Here is the caller graph for this function:

get_app()

GstBin * get_app	(	GNUNET_gstData *	d,
		int	type
	)

Definition at line 732 of file gnunet_gst.c.

{
  GstBin *bin;
  GstPad *pad, *ghostpad;
 
  if (type == SOURCE)
  {
    bin = GST_BIN (gst_bin_new ("Gnunet appsrc"));
 
 
    GNUNET_assert (GNUNET_OK ==
                   GNUNET_log_setup ("gnunet-helper-audio-playback",
                                     "WARNING",
                                     NULL));
 
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Audio playback starts\n");
    printf (" creating appsrc \n ");
    // d->audio_message.header.type = htons (GNUNET_MESSAGE_TYPE_CONVERSATION_AUDIO);
 
// d->audio_message = GNUNET_malloc (UINT16_MAX);
//  d->audio_message = (AudioMessage*)malloc(sizeof(struct AudioMessage));
//  d->audio_message = GNUNET_malloc(sizeof(struct AudioMessage));
 
 
    // d->audio_message.header.type = htons (GNUNET_MESSAGE_TYPE_CONVERSATION_AUDIO);
 
 
    d->stdin_mst = GNUNET_MST_create (&stdin_receiver, d);
 
    if (d->stdin_mst == NULL)
      printf ("stdin_mst = NULL");
 
    d->appsrc = gst_element_factory_make ("appsrc", "appsrc");
 
    gst_bin_add_many (bin, d->appsrc, NULL);
//    gst_element_link_many ( encoder, muxer, NULL);
 
    pad = gst_element_get_static_pad (d->appsrc, "src");
    ghostpad = gst_ghost_pad_new ("src", pad);
  }
  if (type == SINK)
  {
    bin = GST_BIN (gst_bin_new ("Gnunet appsink"));
 
 
    GNUNET_assert (GNUNET_OK ==
                   GNUNET_log_setup ("gnunet-helper-audio-record",
                                     "WARNING",
                                     NULL));
 
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Audio source starts\n");
 
    d->appsink = gst_element_factory_make ("appsink", "appsink");
 
    // Move this out of here!
    d->audio_message = GNUNET_malloc (UINT16_MAX);
    (d->audio_message)->header.type = htons (
      GNUNET_MESSAGE_TYPE_CONVERSATION_AUDIO);
    g_object_set (G_OBJECT (d->appsink), "emit-signals", TRUE, "sync", TRUE,
                  NULL);
 
    g_signal_connect (d->appsink, "new-sample",
                      G_CALLBACK (on_appsink_new_sample), &d);
 
    gst_bin_add_many (bin, d->appsink, NULL);
//    gst_element_link_many ( encoder, muxer, NULL);
 
    pad = gst_element_get_static_pad (d->appsink, "sink");
    ghostpad = gst_ghost_pad_new ("sink", pad);
  }
 
  /* set the bin pads */
  gst_pad_set_active (ghostpad, TRUE);
  gst_element_add_pad (GST_ELEMENT (bin), ghostpad);
 
  gst_object_unref (pad);
 
  return bin;
}

References d, GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_log_setup(), GNUNET_malloc, GNUNET_MESSAGE_TYPE_CONVERSATION_AUDIO, GNUNET_MST_create(), GNUNET_OK, gst_element_factory_make, AudioMessage::header, on_appsink_new_sample(), SINK, SOURCE, stdin_receiver(), type, and GNUNET_MessageHeader::type.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

get_coder()

GstBin * get_coder	(	GNUNET_gstData *	d,
		int	type
	)

Definition at line 816 of file gnunet_gst.c.

{
  GstBin *bin;
  GstPad *srcpad, *sinkpad, *srcghostpad, *sinkghostpad;
  GstCaps *rtpcaps;
  GstElement *encoder, *muxer, *decoder, *demuxer, *jitterbuffer,
             *rtpcapsfilter;
 
  if (d->usertp == TRUE)
  {
    /*
     * application/x-rtp, media=(string)audio, clock-rate=(int)48000, encoding-name=(string)OPUS, sprop-maxcapturerate=(string)48000, sprop-stereo=(string)0, payload=(int)96, encoding-params=(string)2, ssrc=(uint)630297634, timestamp-offset=(uint)678334141, seqnum-offset=(uint)16938 */
/*
    rtpcaps = gst_caps_new_simple ("application/x-rtp",
          "media", G_TYPE_STRING, "audio",
          "clock-rate", G_TYPE_INT, SAMPLING_RATE,
          "encoding-name", G_TYPE_STRING, "OPUS",
          "payload", G_TYPE_INT, 96,
          "sprop-stereo", G_TYPE_STRING, "0",
          "encoding-params", G_TYPE_STRING, "2",
          NULL);
 */ rtpcaps = gst_caps_new_simple ("application/x-rtp",
                                   "media", G_TYPE_STRING, "audio",
                                   "clock-rate", G_TYPE_INT, SAMPLING_RATE,
                                   "encoding-name", G_TYPE_STRING, "OPUS",
                                   "payload", G_TYPE_INT, 96,
                                   "sprop-stereo", G_TYPE_STRING, "0",
                                   "encoding-params", G_TYPE_STRING, "2",
                                   NULL);
 
 
    rtpcapsfilter = gst_element_factory_make ("capsfilter", "rtpcapsfilter");
 
    g_object_set (G_OBJECT (rtpcapsfilter),
                  "caps", rtpcaps,
                  NULL);
    gst_caps_unref (rtpcaps);
  }
 
 
  if (type == ENCODER)
  {
    bin = GST_BIN (gst_bin_new ("Gnunet audioencoder"));
 
    encoder = gst_element_factory_make ("opusenc", "opus-encoder");
    if (d->usertp == TRUE)
    {
      muxer = gst_element_factory_make ("rtpopuspay", "rtp-payloader");
    }
    else
    {
      muxer = gst_element_factory_make ("oggmux", "ogg-muxer");
    }
    g_object_set (G_OBJECT (encoder),
                  /*      "bitrate", 64000, */
                  /*      "bandwidth", OPUS_BANDWIDTH_FULLBAND, */
                  "inband-fec", INBAND_FEC_MODE,
                  "packet-loss-percentage", PACKET_LOSS_PERCENTAGE,
                  "max-payload-size", MAX_PAYLOAD_SIZE,
                  "audio", TRUE,  /* VoIP, not audio */
                  "frame-size", OPUS_FRAME_SIZE,
                  NULL);
 
    if (d->usertp != TRUE)
    {
      g_object_set (G_OBJECT (muxer),
                    "max-delay", OGG_MAX_DELAY,
                    "max-page-delay", OGG_MAX_PAGE_DELAY,
                    NULL);
    }
 
    gst_bin_add_many (bin, encoder, muxer, NULL);
    gst_element_link_many (encoder, muxer, NULL);
    sinkpad = gst_element_get_static_pad (encoder, "sink");
    sinkghostpad = gst_ghost_pad_new ("sink", sinkpad);
 
    srcpad = gst_element_get_static_pad (muxer, "src");
    srcghostpad = gst_ghost_pad_new ("src", srcpad);
  }
  if (type == DECODER)
  {
    bin = GST_BIN (gst_bin_new ("Gnunet audiodecoder"));
 
    // decoder
    if (d->usertp == TRUE)
    {
      demuxer = gst_element_factory_make ("rtpopusdepay", "ogg-demuxer");
      jitterbuffer = gst_element_factory_make ("rtpjitterbuffer",
                                               "rtpjitterbuffer");
    }
    else
    {
      demuxer = gst_element_factory_make ("oggdemux", "ogg-demuxer");
    }
    decoder = gst_element_factory_make ("opusdec", "opus-decoder");
 
    if (d->usertp == TRUE)
    {
      gst_bin_add_many (bin, rtpcapsfilter, jitterbuffer, demuxer, decoder,
                        NULL);
      gst_element_link_many (rtpcapsfilter, jitterbuffer, demuxer, decoder,
                             NULL);
      sinkpad = gst_element_get_static_pad (rtpcapsfilter, "sink");
    }
    else
    {
      gst_bin_add_many (bin, demuxer, decoder, NULL);
 
      g_signal_connect (demuxer,
                        "pad-added",
                        G_CALLBACK (decoder_ogg_pad_added),
                        decoder);
 
      sinkpad = gst_element_get_static_pad (demuxer, "sink");
    }
    sinkghostpad = gst_ghost_pad_new ("sink", sinkpad);
 
    srcpad = gst_element_get_static_pad (decoder, "src");
    srcghostpad = gst_ghost_pad_new ("src", srcpad);
  }
 
  // add pads to the bin
  gst_pad_set_active (sinkghostpad, TRUE);
  gst_element_add_pad (GST_ELEMENT (bin), sinkghostpad);
 
  gst_pad_set_active (srcghostpad, TRUE);
  gst_element_add_pad (GST_ELEMENT (bin), srcghostpad);
 
 
  return bin;
}

References d, decoder, DECODER, decoder_ogg_pad_added(), demuxer, ENCODER, gst_element_factory_make, INBAND_FEC_MODE, MAX_PAYLOAD_SIZE, OGG_MAX_DELAY, OGG_MAX_PAGE_DELAY, OPUS_FRAME_SIZE, PACKET_LOSS_PERCENTAGE, SAMPLING_RATE, and type.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

get_audiobin()

GstBin * get_audiobin	(	GNUNET_gstData *	d,
		int	type
	)

Definition at line 950 of file gnunet_gst.c.

{
  GstBin *bin;
  GstElement *sink, *source, *queue, *conv, *resampler, *removesilence, *filter;
  GstPad *pad, *ghostpad;
  GstCaps *caps;
 
  if (type == SINK)
  {
    bin = GST_BIN (gst_bin_new ("Gnunet audiosink"));
 
    /* Create all the elements */
    if (d->dropsilence == TRUE)
    {
      queue = gst_element_factory_make ("queue", "queue");
      removesilence = gst_element_factory_make ("removesilence",
                                                "removesilence");
    }
 
    conv = gst_element_factory_make ("audioconvert", "converter");
    resampler = gst_element_factory_make ("audioresample", "resampler");
 
    if (d->audiobackend == AUTO)
    {
      sink = gst_element_factory_make ("autoaudiosink", "audiosink");
      g_signal_connect (sink, "child-added", G_CALLBACK (
                          autoaudiosink_child_added), NULL);
    }
 
    if (d->audiobackend == ALSA)
    {
      sink = gst_element_factory_make ("alsaaudiosink", "audiosink");
    }
 
    if (d->audiobackend == JACK)
    {
      sink = gst_element_factory_make ("jackaudiosink", "audiosink");
 
      g_object_set (G_OBJECT (sink), "client-name", "gnunet", NULL);
 
      if (g_object_class_find_property
            (G_OBJECT_GET_CLASS (sink), "port-pattern"))
      {
//        char *portpattern = "system";
 
        g_object_set (G_OBJECT (sink), "port-pattern", d->jack_pp_out,
                      NULL);
      }
    }
 
    if (d->audiobackend == FAKE)
    {
      sink = gst_element_factory_make ("fakesink", "audiosink");
    }
 
    g_object_set (sink,
                  "buffer-time", (gint64) BUFFER_TIME,
                  "latency-time", (gint64) LATENCY_TIME,
                  NULL);
 
    if (d->dropsilence == TRUE)
    {
      // Do not remove silence by default
      g_object_set (removesilence, "remove", FALSE, NULL);
      g_object_set (queue, "max-size-buffers", 12, NULL);
      /*
         g_signal_connect (source,
         "need-data",
         G_CALLBACK(appsrc_need_data),
         NULL);
 
         g_signal_connect (source,
         "enough-data",
         G_CALLBACK(appsrc_enough_data),
         NULL);
       *//*
      g_signal_connect (queue,
          "notify::current-level-bytes",
          G_CALLBACK(queue_current_level),
          NULL);
 
      g_signal_connect (queue,
          "underrun",
          G_CALLBACK(queue_underrun),
          NULL);
 
      g_signal_connect (queue,
          "running",
          G_CALLBACK(queue_running),
          NULL);
 
      g_signal_connect (queue,
          "overrun",
          G_CALLBACK(queue_overrun),
          NULL);
 
      g_signal_connect (queue,
          "pushing",
          G_CALLBACK(queue_pushing),
          NULL);
 */ }
 
 
    gst_bin_add_many (bin, conv, resampler, sink, NULL);
    gst_element_link_many (conv, resampler, sink, NULL);
 
    if (d->dropsilence == TRUE)
    {
      gst_bin_add_many (bin, queue, removesilence, NULL);
 
      if (! gst_element_link_many (queue, removesilence, conv, NULL))
        lf ("queue, removesilence, conv ");
 
      pad = gst_element_get_static_pad (queue, "sink");
    }
    else
    {
      pad = gst_element_get_static_pad (conv, "sink");
    }
 
    ghostpad = gst_ghost_pad_new ("sink", pad);
  }
  else
  {
    // SOURCE
 
    bin = GST_BIN (gst_bin_new ("Gnunet audiosource"));
 
    //    source = gst_element_factory_make("audiotestsrc", "audiotestsrcbla");
 
    if (d->audiobackend == AUTO)
    {
      source = gst_element_factory_make ("autoaudiosrc", "audiosource");
    }
    if (d->audiobackend == ALSA)
    {
      source = gst_element_factory_make ("alsasrc", "audiosource");
    }
    if (d->audiobackend == JACK)
    {
      source = gst_element_factory_make ("jackaudiosrc", "audiosource");
    }
    if (d->audiobackend == TEST)
    {
      source = gst_element_factory_make ("audiotestsrc", "audiosource");
    }
 
    filter = gst_element_factory_make ("capsfilter", "filter");
    conv = gst_element_factory_make ("audioconvert", "converter");
    resampler = gst_element_factory_make ("audioresample", "resampler");
 
    if (d->audiobackend == AUTO)
    {
      g_signal_connect (source, "child-added", G_CALLBACK (
                          autoaudiosource_child_added), NULL);
    }
    else
    {
      if (GST_IS_AUDIO_BASE_SRC (source))
        g_object_set (source, "buffer-time", (gint64) BUFFER_TIME,
                      "latency-time", (gint64) LATENCY_TIME, NULL);
      if (d->audiobackend == JACK)
      {
        g_object_set (G_OBJECT (source), "client-name", "gnunet", NULL);
        if (g_object_class_find_property
              (G_OBJECT_GET_CLASS (source), "port-pattern"))
        {
          char *portpattern = "moc";
 
          g_object_set (G_OBJECT (source), "port-pattern", portpattern,
                        NULL);
        }
      }
    }
 
    caps = gst_caps_new_simple ("audio/x-raw",
                                /*  "format", G_TYPE_STRING, "S16LE", */
                                /*    "rate", G_TYPE_INT, SAMPLING_RATE,*/
                                "channels", G_TYPE_INT, OPUS_CHANNELS,
                                /*    "layout", G_TYPE_STRING, "interleaved",*/
                                NULL);
 
    g_object_set (G_OBJECT (filter),
                  "caps", caps,
                  NULL);
    gst_caps_unref (caps);
 
    gst_bin_add_many (bin, source, filter, conv, resampler, NULL);
    gst_element_link_many (source, filter, conv, resampler, NULL);
 
    pad = gst_element_get_static_pad (resampler, "src");
 
 
    /* pads */
    ghostpad = gst_ghost_pad_new ("src", pad);
  }
 
  /* set the bin pads */
  gst_pad_set_active (ghostpad, TRUE);
  gst_element_add_pad (GST_ELEMENT (bin), ghostpad);
 
  gst_object_unref (pad);
 
  return bin;
}

References ALSA, AUTO, autoaudiosink_child_added(), autoaudiosource_child_added(), BUFFER_TIME, conv, d, FAKE, filter, gst_element_factory_make, JACK, LATENCY_TIME, lf(), OPUS_CHANNELS, queue(), resampler, sink, SINK, source, TEST, and type.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

cfg

struct GNUNET_CONFIGURATION_Handle* cfg

static

Our configuration.

Definition at line 31 of file gnunet_gst.c.

Referenced by gg_load_configuration().