#include <glib/gi18n-lib.h>
+#ifndef HAVE_SHOUT_2_4_6_OR_NEWER
+#define shout_set_metadata_utf8 shout_set_metadata
+#endif
+
GST_DEBUG_CATEGORY_STATIC (shout2_debug);
#define GST_CAT_DEFAULT shout2_debug
-
enum
{
SIGNAL_CONNECTION_PROBLEM, /* FIXME 2.0: remove this */
#define DEFAULT_TIMEOUT 10000
#define DEFAULT_SEND_TITLE_INFO TRUE
-#ifdef SHOUT_FORMAT_WEBM
-#define WEBM_CAPS "; video/webm; audio/webm"
-#else
-#define WEBM_CAPS ""
-#endif
-
-#define SHOUT2SEND_BASIC_CAPS "application/ogg; audio/ogg; video/ogg; "\
- "audio/mpeg, mpegversion = (int) 1, layer = (int) [ 1, 3 ]"
-
-#define SHOUT2SEND_DOC_CAPS SHOUT2SEND_BASIC_CAPS "; video/webm; audio/webm"
-
-#define SHOUT2SEND_CAPS SHOUT2SEND_BASIC_CAPS WEBM_CAPS
+#define SHOUT2SEND_CAPS "application/ogg; audio/ogg; video/ogg; "\
+ "audio/mpeg, mpegversion = (int) 1, layer = (int) [ 1, 3 ]; " \
+ "video/webm; audio/webm"
static GstStaticPadTemplate sink_template = GST_STATIC_PAD_TEMPLATE ("sink",
GST_PAD_SINK,
GstElementClass *gstelement_class;
GstBaseSinkClass *gstbasesink_class;
GstPadTemplate *tmpl;
- GstCaps *doc_caps;
gobject_class = (GObjectClass *) klass;
gstelement_class = (GstElementClass *) klass;
tmpl = gst_static_pad_template_get (&sink_template);
gst_element_class_add_pad_template (gstelement_class, tmpl);
- /* our caps depend on the libshout2 version */
- doc_caps = gst_caps_from_string (SHOUT2SEND_DOC_CAPS);
- gst_pad_template_set_documentation_caps (tmpl, doc_caps);
- gst_clear_caps (&doc_caps);
-
gst_element_class_set_static_metadata (gstelement_class,
"Icecast network sink",
"Sink/Network", "Sends data to an icecast server",
shout2send->timeout = DEFAULT_TIMEOUT;
shout2send->format = -1;
+ shout2send->usage = SHOUT_USAGE_UNKNOWN;
shout2send->tags = gst_tag_list_new_empty ();
shout2send->conn = NULL;
shout2send->connected = FALSE;
set_shout_metadata, shout2send);
if (shout2send->songmetadata && shout2send->connected) {
shout_metadata_t *pmetadata;
+ int shout_ret;
GST_DEBUG_OBJECT (shout2send, "metadata now: %s",
shout2send->songmetadata);
pmetadata = shout_metadata_new ();
- shout_metadata_add (pmetadata, "song", shout2send->songmetadata);
- shout_set_metadata (shout2send->conn, pmetadata);
+ shout_ret =
+ shout_metadata_add (pmetadata, "song", shout2send->songmetadata);
+ if (shout_ret == SHOUTERR_SUCCESS) {
+ shout_ret = shout_set_metadata_utf8 (shout2send->conn, pmetadata);
+ if (shout_ret != SHOUTERR_SUCCESS) {
+ GST_WARNING_OBJECT (shout2send, "Failed to set metadata: %s",
+ shout_get_error (shout2send->conn));
+ }
+ }
shout_metadata_free (pmetadata);
}
}
}
static gboolean
+gst_shout2send_set_meta (GstShout2send * sink, const char *meta,
+ const char *val)
+{
+ GST_DEBUG_OBJECT (sink, "setting %s: %s", meta, val);
+
+ if (shout_set_meta (sink->conn, meta, val) == SHOUTERR_SUCCESS)
+ return TRUE;
+
+ GST_ELEMENT_ERROR (sink, LIBRARY, SETTINGS, (NULL),
+ ("Error setting %s: %s", meta, shout_get_error (sink->conn)));
+
+ return FALSE;
+}
+
+static gboolean
gst_shout2send_start (GstBaseSink * basesink)
{
GstShout2send *sink = GST_SHOUT2SEND (basesink);
(sink->ispublic ? 1 : 0)) != SHOUTERR_SUCCESS)
goto set_failed;
- cur_prop = "streamname";
- GST_DEBUG_OBJECT (sink, "setting %s: %s", cur_prop, sink->streamname);
- if (shout_set_name (sink->conn, sink->streamname) != SHOUTERR_SUCCESS)
- goto set_failed;
+ if (!gst_shout2send_set_meta (sink, SHOUT_META_NAME, sink->streamname))
+ goto set_meta_failed;
- cur_prop = "description";
- GST_DEBUG_OBJECT (sink, "setting %s: %s", cur_prop, sink->description);
- if (shout_set_description (sink->conn, sink->description) != SHOUTERR_SUCCESS)
- goto set_failed;
+ if (!gst_shout2send_set_meta (sink, SHOUT_META_DESCRIPTION,
+ sink->description))
+ goto set_meta_failed;
- cur_prop = "genre";
- GST_DEBUG_OBJECT (sink, "setting %s: %s", cur_prop, sink->genre);
- if (shout_set_genre (sink->conn, sink->genre) != SHOUTERR_SUCCESS)
- goto set_failed;
+ if (!gst_shout2send_set_meta (sink, SHOUT_META_GENRE, sink->genre))
+ goto set_meta_failed;
cur_prop = "mount";
GST_DEBUG_OBJECT (sink, "setting %s: %s", cur_prop, sink->mount);
{
GST_ELEMENT_ERROR (sink, LIBRARY, SETTINGS, (NULL),
("Error setting %s: %s", cur_prop, shout_get_error (sink->conn)));
+ /* fallthrough */
+ }
+set_meta_failed:
+ {
shout_free (sink->conn);
sink->conn = NULL;
return FALSE;
if (shout_set_nonblocking (sink->conn, 1) != SHOUTERR_SUCCESS)
goto could_not_set_nonblocking;
- if (shout_set_format (sink->conn, sink->format) != SHOUTERR_SUCCESS)
- goto could_not_set_format;
+ {
+#ifdef HAVE_SHOUT_2_4_6_OR_NEWER
+ ret =
+ shout_set_content_format (sink->conn, sink->format, sink->usage, NULL);
+#else
+ ret = shout_set_format (sink->conn, sink->format);
+#endif
+
+ if (ret != SHOUTERR_SUCCESS)
+ goto could_not_set_format;
+ }
GST_DEBUG_OBJECT (sink, "connecting");
ret = shout_open (sink->conn);
/* wait for connection or timeout */
-#ifdef SHOUTERR_RETRY
/* starting with libshout 2.4.2, shout_open() has broken API + ABI and
* can also return SHOUTERR_RETRY (a new define) to mean "try again" */
while (ret == SHOUTERR_BUSY || ret == SHOUTERR_RETRY) {
-#else
- while (ret == SHOUTERR_BUSY) {
-#endif
if (gst_util_get_timestamp () - start_ts > sink->timeout * GST_MSECOND) {
goto connection_timeout;
}
GST_DEBUG_OBJECT (sink, "shout metadata now: %s", sink->songmetadata);
pmetadata = shout_metadata_new ();
- shout_metadata_add (pmetadata, "song", sink->songmetadata);
- shout_set_metadata (sink->conn, pmetadata);
+ ret = shout_metadata_add (pmetadata, "song", sink->songmetadata);
+ if (ret == SHOUTERR_SUCCESS) {
+ ret = shout_set_metadata_utf8 (sink->conn, pmetadata);
+ if (ret != SHOUTERR_SUCCESS) {
+ GST_WARNING_OBJECT (sink, "Failed to set metadata: %s",
+ shout_get_error (sink->conn));
+ }
+ }
shout_metadata_free (pmetadata);
}
sink->connected = FALSE;
sink->format = -1;
+ sink->usage = SHOUT_USAGE_UNKNOWN;
return TRUE;
}
if (!strcmp (mimetype, "audio/mpeg")) {
shout2send->format = SHOUT_FORMAT_MP3;
+ shout2send->usage = SHOUT_USAGE_AUDIO;
} else if (g_str_has_suffix (mimetype, "/ogg")) {
shout2send->format = SHOUT_FORMAT_OGG;
-#ifdef SHOUT_FORMAT_WEBM
+ if (g_str_has_prefix (mimetype, "audio/"))
+ shout2send->usage = SHOUT_USAGE_AUDIO;
+ else if (g_str_has_prefix (mimetype, "video/"))
+ shout2send->usage = SHOUT_USAGE_VISUAL | SHOUT_USAGE_AUDIO;
+ else
+ shout2send->usage = SHOUT_USAGE_UNKNOWN;
} else if (g_str_has_suffix (mimetype, "/webm")) {
shout2send->format = SHOUT_FORMAT_WEBM;
-#endif
+ if (g_str_has_prefix (mimetype, "audio/"))
+ shout2send->usage = SHOUT_USAGE_AUDIO;
+ else if (g_str_has_prefix (mimetype, "video/"))
+ shout2send->usage = SHOUT_USAGE_VISUAL | SHOUT_USAGE_AUDIO;
+ else
+ shout2send->usage = SHOUT_USAGE_UNKNOWN;
} else {
ret = FALSE;
}