diff options
Diffstat (limited to 'audio/gsta2dpsink.c')
-rw-r--r-- | audio/gsta2dpsink.c | 49 |
1 files changed, 17 insertions, 32 deletions
diff --git a/audio/gsta2dpsink.c b/audio/gsta2dpsink.c index 0e8c8e02..1bb88b36 100644 --- a/audio/gsta2dpsink.c +++ b/audio/gsta2dpsink.c @@ -141,8 +141,8 @@ struct rtp_payload { #error "Unknown byte order" #endif -#define IS_SBC(n) (strcmp(n, "audio/x-sbc") == 0) -#define IS_MPEG(n) (strcmp(n, "audio/mpeg") == 0) +#define IS_SBC(n) (strcmp((n), "audio/x-sbc") == 0) +#define IS_MPEG(n) (strcmp((n), "audio/mpeg") == 0) enum { PROP_0, @@ -218,7 +218,7 @@ static void gst_a2dp_sink_finalize(GObject *object) GstA2dpSink *self = GST_A2DP_SINK(object); if (self->data) - gst_a2dp_sink_stop (GST_BASE_SINK (self)); + gst_a2dp_sink_stop(GST_BASE_SINK(self)); if (self->device) g_free(self->device); @@ -285,7 +285,7 @@ static gint gst_a2dp_sink_bluetooth_recvmsg_fd(GstA2dpSink *sink) ret = recvmsg(g_io_channel_unix_get_fd(sink->server), &msgh, 0); if (ret < 0) { err = errno; - GST_ERROR_OBJECT(sink, "Unable to receive fd: %s (%d)", + GST_ERROR_OBJECT(sink, "Unable to receive fd: %s (%d)", strerror(err), err); return -err; } @@ -305,7 +305,7 @@ static gint gst_a2dp_sink_bluetooth_recvmsg_fd(GstA2dpSink *sink) return -EINVAL; } -static int gst_a2dp_sink_bluetooth_a2dp_init(GstA2dpSink *sink, +static int gst_a2dp_sink_bluetooth_a2dp_init(GstA2dpSink *sink, struct ipc_codec_sbc *sbc) { struct bluetooth_a2dp *a2dp = &sink->data->a2dp; @@ -403,21 +403,6 @@ static gboolean gst_a2dp_sink_init_pkt_conf(GstA2dpSink *sink, value = gst_structure_get_value(structure, "blocks"); sbc->blocks = g_value_get_int(value); -/* FIXME how can I obtain the bitpool ? - if (strcmp(id, "bitpool") == 0) { - if (snd_config_get_string(n, &bitpool) < 0) { - SNDERR("Invalid type for %s", id); - return -EINVAL; - } - - sbc->bitpool = atoi(bitpool); - continue; - } - - SNDERR("Unknown field %s", id); - return -EINVAL; - } -*/ sbc->bitpool = 32; pkt->length = sizeof(*cfg) + sizeof(*sbc); @@ -438,7 +423,7 @@ static gboolean gst_a2dp_sink_conf_resp(GstA2dpSink *sink) memset(buf, 0, sizeof(buf)); - io_error = g_io_channel_read(sink->server, (gchar*)buf, + io_error = g_io_channel_read(sink->server, (gchar *) buf, sizeof(*pkt) + sizeof(*cfg), &ret); if (io_error != G_IO_ERROR_NONE && ret > 0) { GST_ERROR_OBJECT(sink, "Error ocurred while receiving \ @@ -476,14 +461,14 @@ static gboolean gst_a2dp_sink_conf_recv_dev_conf(GstA2dpSink *sink) struct ipc_data_cfg *cfg = (void *) pkt->data; struct ipc_codec_sbc *sbc = (void *) cfg->data; - io_error = g_io_channel_read(sink->server, (gchar*) sbc, + io_error = g_io_channel_read(sink->server, (gchar *) sbc, sizeof(*sbc), &ret); if (io_error != G_IO_ERROR_NONE) { GST_ERROR_OBJECT(sink, "Error while reading data from socket \ - %s (%d)", strerror(errno), errno); + %s (%d)", strerror(errno), errno); return FALSE; } else if (ret == 0) { - GST_ERROR_OBJECT(sink, "Read 0 bytes from socket"); + GST_ERROR_OBJECT(sink, "Read 0 bytes from socket"); return FALSE; } @@ -491,8 +476,8 @@ static gboolean gst_a2dp_sink_conf_recv_dev_conf(GstA2dpSink *sink) GST_DEBUG_OBJECT(sink, "OK - %d bytes received", sink->total); if (pkt->length != (sink->total - sizeof(struct ipc_packet))) { - GST_ERROR_OBJECT(sink, "Error while configuring device: \ - packet size doesn't match"); + GST_ERROR_OBJECT(sink, "Error while configuring device: " + "packet size doesn't match"); return FALSE; } @@ -524,14 +509,14 @@ static gboolean gst_a2dp_sink_conf_recv_stream_fd(GstA2dpSink *sink) return FALSE; if (!sink->stream) { - GST_ERROR_OBJECT(sink, "Error while configuring device: \ - could not acquire audio socket"); + GST_ERROR_OBJECT(sink, "Error while configuring device: " + "could not acquire audio socket"); return FALSE; } /* It is possible there is some outstanding data in the pipe - we have to empty it */ - while (TRUE) { + while (1) { err = g_io_channel_read(sink->stream, (gchar *) sink->data->buffer, (gsize) sink->data->cfg.pkt_len, @@ -589,7 +574,7 @@ static gboolean server_callback(GIOChannel *chan, gst_a2dp_sink_conf_recv_data(sink); else GST_WARNING_OBJECT(sink, "Unexpected data received"); - break; + break; case G_IO_HUP: return FALSE; break; @@ -661,7 +646,7 @@ static gboolean gst_a2dp_sink_send_conf_pkt(GstA2dpSink *sink, GstCaps *caps) sink->con_state = CONFIGURING_INIT; - io_error = g_io_channel_write(sink->server, (gchar*)pkt, + io_error = g_io_channel_write(sink->server, (gchar *) pkt, sizeof(*pkt) + pkt->length, &bytes_sent); if (io_error != G_IO_ERROR_NONE) { GST_ERROR_OBJECT(sink, "Error ocurred while sending \ @@ -735,7 +720,7 @@ static int gst_a2dp_sink_avdtp_write(GstA2dpSink *sink) header->timestamp = htonl(a2dp->nsamples); header->ssrc = htonl(1); - while (TRUE) { + while (1) { err = g_io_channel_write(sink->stream, (const char *) a2dp->buffer, (gsize) a2dp->count, (gsize *) &ret); |