bluetooth/gst: Replace buffer accumulation in adapter with direct pull

Bluetooth codecs should always have fixed in/output and are hence able
to have their results directly read from the codec, instead of
accumulating in a buffer asynchronously that is subsequently only read
in the transcode callback.  The Bluetooth backends calling encode/decode
also expect these fixed buffer sizes.

src/modules/bluetooth/a2dp-codec-gst.c

@@ -39,31 +39,11 @@ static void app_sink_eos(GstAppSink *appsink, gpointer userdata) {
     pa_log_debug("Sink got EOS");
 }
 
-/* Called from the GStreamer streaming thread */
-static GstFlowReturn app_sink_new_sample(GstAppSink *appsink, gpointer userdata) {
-    struct gst_info *info = (struct gst_info *) userdata;
-    GstSample *sample = NULL;
-    GstBuffer *buf;
-
-    sample = gst_app_sink_pull_sample(GST_APP_SINK(info->app_sink));
-    if (!sample)
-        return GST_FLOW_OK;
-
-    buf = gst_sample_get_buffer(sample);
-    gst_buffer_ref(buf);
-    gst_adapter_push(info->sink_adapter, buf);
-    gst_sample_unref(sample);
-
-    return GST_FLOW_OK;
-}
-
 static void gst_deinit_common(struct gst_info *info) {
     if (!info)
         return;
     if (info->app_sink)
         gst_object_unref(info->app_sink);
-    if (info->sink_adapter)
-        g_object_unref(info->sink_adapter);
     if (info->bin)
         gst_object_unref(info->bin);
 }
@@ -82,7 +62,6 @@ bool gst_init_common(struct gst_info *info) {
     g_object_set(appsink, "sync", FALSE, "async", FALSE, "enable-last-sample", FALSE, NULL);
 
     callbacks.eos = app_sink_eos;
-    callbacks.new_sample = app_sink_new_sample;
     gst_app_sink_set_callbacks(GST_APP_SINK(appsink), &callbacks, info, NULL);
 
     adapter = gst_adapter_new();
@@ -92,7 +71,6 @@ bool gst_init_common(struct gst_info *info) {
     pa_assert(bin);
 
     info->app_sink = appsink;
-    info->sink_adapter = adapter;
     info->bin = bin;
 
     return true;
@@ -231,10 +209,11 @@ common_fail:
 
 size_t gst_transcode_buffer(void *codec_info, const uint8_t *input_buffer, size_t input_size, uint8_t *output_buffer, size_t output_size, size_t *processed) {
     struct gst_info *info = (struct gst_info *) codec_info;
-    gsize available, transcoded;
+    gsize transcoded;
     GstBuffer *in_buf;
     GstFlowReturn ret;
     size_t written = 0;
+    GstSample *sample;
 
     pa_assert(info->pad_sink);
 
@@ -248,17 +227,22 @@ size_t gst_transcode_buffer(void *codec_info, const uint8_t *input_buffer, size_
         goto fail;
     }
 
-    available = gst_adapter_available(info->sink_adapter);
+    sample = gst_app_sink_try_pull_sample(GST_APP_SINK(info->app_sink), 0);
 
-    if (available) {
-        transcoded = PA_MIN(available, output_size);
+    if (sample) {
+        in_buf = gst_sample_get_buffer(sample);
 
-        gst_adapter_copy(info->sink_adapter, output_buffer, 0, transcoded);
-        gst_adapter_flush(info->sink_adapter, transcoded);
+        transcoded = gst_buffer_get_size(in_buf);
+        pa_assert(transcoded <= output_size);
+
+        GstMapInfo map_info;
+        pa_assert_se(gst_buffer_map(in_buf, &map_info, GST_MAP_READ));
+        memcpy(output_buffer, map_info.data, transcoded);
+        gst_buffer_unmap(in_buf, &map_info);
 
         written += transcoded;
     } else
-        pa_log_debug("No transcoded data available in adapter");
+        pa_log_warn("No transcoded data available in adapter");
 
     *processed = input_size;
 
@@ -278,9 +262,6 @@ void gst_codec_deinit(void *codec_info) {
         gst_object_unref(info->bin);
     }
 
-    if (info->sink_adapter)
-        g_object_unref(info->sink_adapter);
-
     if (info->pad_sink)
         gst_object_unref(GST_OBJECT(info->pad_sink));
 

src/modules/bluetooth/a2dp-codec-gst.h

@@ -46,7 +46,6 @@ struct gst_info {
     /* The appsink element that accumulates encoded/decoded buffers */
     GstElement *app_sink;
     GstElement *bin;
-    GstAdapter *sink_adapter;
     /* The sink pad to push to-be-encoded/decoded buffers into */
     GstPad *pad_sink;