diff --git a/audio/avdtp.c b/audio/avdtp.c
index c7e5f87..76526b6 100644
--- a/audio/avdtp.c
+++ b/audio/avdtp.c
guint idle_timer;
gboolean delay_reporting;
uint16_t delay; /* AVDTP 1.3 Delay Reporting feature */
+ gboolean starting; /* only valid while sep state == OPEN */
};
/* Structure describing an AVDTP connection between two devices */
avdtp_delay_report(session, stream, stream->delay);
break;
case AVDTP_STATE_OPEN:
+ stream->starting = FALSE;
if (old_state > AVDTP_STATE_OPEN && session->auto_dc)
stream->idle_timer = g_timeout_add_seconds(STREAM_TIMEOUT,
stream_timeout,
stream = sep->stream;
- if (sep->state != AVDTP_STATE_OPEN) {
+ /* Also reject start cmd if we already initiated start */
+ if (sep->state != AVDTP_STATE_OPEN ||
+ stream->starting == TRUE) {
err = AVDTP_BAD_STATE;
goto failed;
}
+ stream->starting = TRUE;
if (sep->ind && sep->ind->start) {
if (!sep->ind->start(session, sep, stream, &err,
AVDTP_START, NULL, 0);
failed:
+ DBG("Rejecting (%d)", err);
memset(&rej, 0, sizeof(rej));
rej.acp_seid = failed_seid;
rej.error = err;
break;
case AVDTP_START:
error("Start: %s (%d)", strerror(err), err);
- if (lsep && lsep->cfm && lsep->cfm->start)
+ if (lsep && lsep->cfm && lsep->cfm->start) {
lsep->cfm->start(session, lsep, stream, &averr,
lsep->user_data);
+ if (stream)
+ stream->starting = FALSE;
+ }
break;
case AVDTP_SUSPEND:
error("Suspend: %s (%d)", strerror(err), err);
return FALSE;
error("START request rejected: %s (%d)",
avdtp_strerror(&err), err.err.error_code);
- if (sep && sep->cfm && sep->cfm->start)
+ if (sep && sep->cfm && sep->cfm->start) {
sep->cfm->start(session, sep, stream, &err,
sep->user_data);
+ stream->starting = FALSE;
+ }
return TRUE;
case AVDTP_SUSPEND:
if (!stream_rej_to_err(buf, size, &err, &acp_seid))
int avdtp_start(struct avdtp *session, struct avdtp_stream *stream)
{
struct start_req req;
+ int ret;
if (!g_slist_find(session->streams, stream))
return -EINVAL;
return -EINVAL;
}
+ if (stream->starting == TRUE) {
+ DBG("stream already started");
+ return -EINVAL;
+ }
+
memset(&req, 0, sizeof(req));
req.first_seid.seid = stream->rseid;
- return send_request(session, FALSE, stream, AVDTP_START,
+ ret = send_request(session, FALSE, stream, AVDTP_START,
&req, sizeof(req));
+ if (ret == 0)
+ stream->starting = TRUE;
+
+ return ret;
}
int avdtp_close(struct avdtp *session, struct avdtp_stream *stream,