summaryrefslogtreecommitdiffstats
path: root/binding/afm-mediaplayer-binding.c
diff options
context:
space:
mode:
authorMatt Ranostay <matt.ranostay@konsulko.com>2018-12-18 16:15:39 -0800
committerMatt Ranostay <matt.ranostay@konsulko.com>2018-12-19 22:10:34 -0800
commit83c16f45d11aa226cdd5479e25f012a589523ce9 (patch)
tree3474a2d39e228ec93c4150e96d69dab46124525b /binding/afm-mediaplayer-binding.c
parent27eaf032ab679bc077a3ee9a143f03417d97c4b0 (diff)
binding: mediaplayer: allow open/close of mediaplayer roles
When streams are paused or stopped the mediaplayer role needs to be released to allow playback from other applications (i.e. radio) Change-Id: Idd324d0695bfaa35401f05a95380d56df848009e Signed-off-by: Matt Ranostay <matt.ranostay@konsulko.com>
Diffstat (limited to 'binding/afm-mediaplayer-binding.c')
-rw-r--r--binding/afm-mediaplayer-binding.c111
1 files changed, 70 insertions, 41 deletions
diff --git a/binding/afm-mediaplayer-binding.c b/binding/afm-mediaplayer-binding.c
index 7358f95..960749c 100644
--- a/binding/afm-mediaplayer-binding.c
+++ b/binding/afm-mediaplayer-binding.c
@@ -50,6 +50,7 @@ typedef struct _CustomData {
long int volume;
gint64 position;
gint64 duration;
+ afb_api_t api;
/* avrcp */
gboolean avrcp_connected;
@@ -61,6 +62,55 @@ CustomData data = {
.duration = GST_CLOCK_TIME_NONE,
};
+static void mediaplayer_set_role_state(afb_api_t api, int state)
+{
+ json_object *jsonData = json_object_new_object(), *response;
+
+ switch (state) {
+ case GST_STATE_PAUSED:
+ case GST_STATE_NULL:
+ gst_element_set_state(data.playbin, state);
+ json_object_object_add(jsonData, "action", json_object_new_string("close"));
+ afb_api_call_sync(api, "ahl-4a", "multimedia", jsonData, NULL, NULL, NULL);
+
+ data.playing = FALSE;
+
+ break;
+ case GST_STATE_PLAYING:
+ {
+ json_object *val = NULL;
+ int ret;
+
+ json_object_object_add(jsonData, "action", json_object_new_string("open"));
+
+ ret = afb_api_call_sync(api, "ahl-4a", "multimedia", jsonData, &response, NULL, NULL);
+ if (ret)
+ return;
+
+ ret = json_object_object_get_ex(response, "device_uri", &val);
+ if (ret && json_object_get_string_len(val)) {
+ const char *jres_pcm = json_object_get_string(val);
+ g_object_set(data.alsa_sink, "device", jres_pcm, NULL);
+
+ data.playing = TRUE;
+
+ AFB_DEBUG("GSTREAMER alsa_sink.device = \"%s\"", jres_pcm);
+ } else {
+ AFB_ERROR("GSTREAMER Failed to call ahl-4a/multimedia!");
+ }
+
+ json_object_put(response);
+
+ gst_element_set_state(data.playbin, GST_STATE_PLAYING);
+ }
+ break;
+ default:
+ AFB_ERROR("GSTREAMER Failed to parse state");
+ }
+
+ gst_element_set_state(data.playbin, state);
+}
+
static json_object *populate_json(struct playlist_item *track)
{
json_object *jresp = json_object_new_object();
@@ -147,7 +197,7 @@ static gboolean populate_from_json(struct playlist_item *item, json_object *jdic
return TRUE;
}
-static int set_media_uri(struct playlist_item *item)
+static int set_media_uri(struct playlist_item *item, int state)
{
if (!item || !item->media_path)
{
@@ -164,11 +214,15 @@ static int set_media_uri(struct playlist_item *item)
data.position = GST_CLOCK_TIME_NONE;
data.duration = GST_CLOCK_TIME_NONE;
- if (data.playing) {
+ if (state) {
g_object_set(data.playbin, "audio-sink", data.alsa_sink, NULL);
AFB_DEBUG("GSTREAMER playbin.audio-sink = alsa-sink");
- gst_element_set_state(data.playbin, GST_STATE_PLAYING);
+ if (!data.playing)
+ mediaplayer_set_role_state(data.api, GST_STATE_PLAYING);
+ else
+ gst_element_set_state(data.playbin, GST_STATE_PLAYING);
+
AFB_DEBUG("GSTREAMER playbin.state = GST_STATE_PLAYING");
} else {
g_object_set(data.playbin, "audio-sink", data.fake_sink, NULL);
@@ -223,7 +277,7 @@ static void populate_playlist(json_object *jquery)
if (current_track == NULL) {
current_track = g_list_first(playlist);
if (current_track && current_track->data)
- set_media_uri(current_track->data);
+ set_media_uri(current_track->data, FALSE);
}
}
@@ -323,8 +377,7 @@ static int seek_track(int cmd)
return -EINVAL;
}
- data.playing = TRUE;
- ret = set_media_uri(item->data);
+ ret = set_media_uri(item->data, TRUE);
if (ret < 0)
return -EINVAL;
@@ -378,6 +431,7 @@ static void gstreamer_controls(afb_req_t request)
const char *value = afb_req_value(request, "value");
const char *position = afb_req_value(request, "position");
int cmd = get_command_index(value);
+ afb_api_t api = afb_req_get_api(request);
json_object *jresp = NULL;
errno = 0;
@@ -385,12 +439,11 @@ static void gstreamer_controls(afb_req_t request)
switch (cmd) {
case PLAY_CMD: {
GstElement *obj = NULL;
- data.playing = TRUE;
g_object_get(data.playbin, "audio-sink", &obj, NULL);
if (obj == data.fake_sink) {
if (current_track && current_track->data)
- set_media_uri(current_track->data);
+ set_media_uri(current_track->data, TRUE);
else {
afb_req_fail(request, "failed", "No playlist");
return;
@@ -399,7 +452,7 @@ static void gstreamer_controls(afb_req_t request)
g_object_set(data.playbin, "audio-sink", data.alsa_sink, NULL);
AFB_DEBUG("GSTREAMER playbin.audio-sink = alsa-sink");
- gst_element_set_state(data.playbin, GST_STATE_PLAYING);
+ mediaplayer_set_role_state(api, GST_STATE_PLAYING);
AFB_DEBUG("GSTREAMER playbin.state = GST_STATE_PLAYING");
}
@@ -408,7 +461,7 @@ static void gstreamer_controls(afb_req_t request)
break;
}
case PAUSE_CMD:
- gst_element_set_state(data.playbin, GST_STATE_PAUSED);
+ mediaplayer_set_role_state(api, GST_STATE_PAUSED);
AFB_DEBUG("GSTREAMER playbin.state = GST_STATE_PAUSED");
data.playing = FALSE;
@@ -444,8 +497,7 @@ static void gstreamer_controls(afb_req_t request)
list = find_media_index(playlist, idx);
if (list != NULL) {
struct playlist_item *item = list->data;
- data.playing = TRUE;
- set_media_uri(item);
+ set_media_uri(item, TRUE);
current_track = list;
} else {
afb_req_fail(request, "failed", "couldn't find index");
@@ -481,7 +533,7 @@ static void gstreamer_controls(afb_req_t request)
break;
}
case STOP_CMD:
- gst_element_set_state(data.playbin, GST_STATE_NULL);
+ mediaplayer_set_role_state(api, GST_STATE_NULL);
AFB_DEBUG("GSTREAMER playbin.state = GST_STATE_NULL");
break;
default:
@@ -723,16 +775,14 @@ static gboolean handle_message(GstBus *bus, GstMessage *msg, CustomData *data)
if (ret < 0) {
if (!data->loop) {
- data->playing = FALSE;
+ mediaplayer_set_role_state(data->api, GST_STATE_NULL);
data->one_time = TRUE;
}
current_track = playlist;
if (current_track != NULL)
- set_media_uri(current_track->data);
- } else if (data->playing) {
- gst_element_set_state(data->playbin, GST_STATE_PLAYING);
+ set_media_uri(current_track->data, data->loop);
}
pthread_mutex_unlock(&mutex);
@@ -757,7 +807,6 @@ static gboolean position_event(CustomData *data)
if (data->one_time) {
data->one_time = FALSE;
- data->playing = FALSE;
json_object *jresp = json_object_new_object();
json_object_object_add(jresp, "status",
@@ -813,6 +862,7 @@ static void gstreamer_init(afb_api_t api)
gst_init(NULL, NULL);
+ data.api = api;
data.playbin = gst_element_factory_make("playbin", "playbin");
if (!data.playbin) {
AFB_ERROR("GST Pipeline: Failed to create 'playbin' element!");
@@ -833,26 +883,6 @@ static void gstreamer_init(afb_api_t api)
exit(1);
}
-#ifdef HAVE_4A_FRAMEWORK
- json_object *jsonData = json_object_new_object();
- json_object_object_add(jsonData, "action", json_object_new_string("open"));
- ret = afb_api_call_sync(api, "ahl-4a", "multimedia", jsonData, &response, NULL, NULL);
-
- if (!ret) {
- json_object *val = NULL;
- gboolean ret;
- ret = json_object_object_get_ex(response, "device_uri", &val);
- if (ret) {
- char* jres_pcm = json_object_get_string(val);
- g_object_set(data.alsa_sink, "device", jres_pcm, NULL);
- AFB_DEBUG("GSTREAMER alsa_sink.device = \"%s\"", jres_pcm);
- }
- }
- else {
- AFB_ERROR("GSTREAMER Failed to call ahl-4a/multimedia!");
- }
-#endif
-
g_object_set(data.playbin, "audio-sink", data.fake_sink, NULL);
AFB_DEBUG("GSTREAMER playbin.audio-sink = fake-sink");
@@ -913,7 +943,7 @@ static void onevent(afb_api_t api, const char *event, struct json_object *object
if (current_track && current_track->data == item) {
current_track = NULL;
data.one_time = TRUE;
- gst_element_set_state(data.playbin, GST_STATE_NULL);
+ mediaplayer_set_role_state(api, GST_STATE_NULL);
AFB_DEBUG("GSTREAMER playbin.state = GST_STATE_NULL");
}
@@ -934,8 +964,7 @@ static void onevent(afb_api_t api, const char *event, struct json_object *object
data.avrcp_connected = state;
if (state) {
- data.playing = FALSE;
- gst_element_set_state(data.playbin, GST_STATE_PAUSED);
+ mediaplayer_set_role_state(api, GST_STATE_PAUSED);
} else {
json_object *jresp = populate_json_metadata();
json_object_object_add(jresp, "status",