diff options
| author | Johan Hedberg <johan.hedberg@nokia.com> | 2007-08-12 21:34:50 +0000 |
|---|---|---|
| committer | Johan Hedberg <johan.hedberg@nokia.com> | 2007-08-12 21:34:50 +0000 |
| commit | f817fefff69cc44d5a2e1ba7d8ed9976fe3b4235 (patch) | |
| tree | ea7d54290d6a8cd20708cd094473947086f4111a /audio/sink.c | |
| parent | fb58bd1b24d257ea884aa5d67f8e5a6362aafa94 (diff) | |
Implement proper acceptor side functionality
Diffstat (limited to 'audio/sink.c')
| -rw-r--r-- | audio/sink.c | 32 |
1 files changed, 29 insertions, 3 deletions
diff --git a/audio/sink.c b/audio/sink.c index f8d56793..be762e39 100644 --- a/audio/sink.c +++ b/audio/sink.c @@ -53,6 +53,7 @@ struct sink { uint8_t state; struct pending_connect *c; DBusConnection *conn; + gboolean initiator; }; static void pending_connect_free(struct pending_connect *c) @@ -87,9 +88,13 @@ void stream_state_changed(struct avdtp_stream *stream, avdtp_state_t old_state, avdtp_unref(sink->session); sink->session = NULL; } + sink->stream = NULL; c = sink->c; break; case AVDTP_STATE_CONFIGURED: + if (!sink->initiator) + break; + cmd_err = avdtp_open(sink->session, stream); if (cmd_err < 0) { error("Error on avdtp_open %s (%d)", strerror(-cmd_err), @@ -163,11 +168,10 @@ failed: if (new_state == AVDTP_STATE_IDLE) { avdtp_unref(sink->session); sink->session = NULL; + sink->stream = NULL; } } - - static void discovery_complete(struct avdtp *session, GSList *seps, int err, void *user_data) { @@ -205,6 +209,8 @@ static void discovery_complete(struct avdtp *session, GSList *seps, int err, goto failed; } + sink->initiator = TRUE; + avdtp_stream_set_cb(session, sink->stream, stream_state_changed, dev); return; @@ -299,7 +305,7 @@ static DBusHandlerResult sink_is_connected(DBusConnection *conn, if (!reply) return DBUS_HANDLER_RESULT_NEED_MEMORY; - connected = (sink->state != AVDTP_STATE_IDLE); + connected = (sink->state >= AVDTP_STATE_CONFIGURED); dbus_message_append_args(reply, DBUS_TYPE_BOOLEAN, &connected, DBUS_TYPE_INVALID); @@ -456,3 +462,23 @@ avdtp_state_t sink_get_state(void *device) return sink->state; } + +gboolean sink_new_stream(struct avdtp *session, struct avdtp_stream *stream, + void *dev) +{ + struct sink *sink = ((struct device *) (dev))->sink; + + if (sink->stream) + return FALSE; + + if (!sink->session) + sink->session = avdtp_ref(session); + + sink->stream = stream; + sink->initiator = FALSE; + + avdtp_stream_set_cb(session, stream, stream_state_changed, dev); + + return TRUE; +} + |