diff --git a/libavformat/rtsp.c b/libavformat/rtsp.c index 4cbfd7e49a357de7be89336b94157623ce64072a..320d45ce7f12d870592577b6ff51df3fd35600c1 100644 --- a/libavformat/rtsp.c +++ b/libavformat/rtsp.c @@ -700,6 +700,9 @@ void rtsp_parse_line(RTSPMessageHeader *reply, const char *buf) } else if (av_stristart(p, "Server:", &p)) { skip_spaces(&p); av_strlcpy(reply->server, p, sizeof(reply->server)); + } else if (av_stristart(p, "Notice:", &p) || + av_stristart(p, "X-Notice:", &p)) { + reply->notice = strtol(p, NULL, 10); } } @@ -823,6 +826,17 @@ rtsp_read_reply (AVFormatContext *s, RTSPMessageHeader *reply, else av_free(content); + /* EOS */ + if (reply->notice == 2101 /* End-of-Stream Reached */ || + reply->notice == 2104 /* Start-of-Stream Reached */ || + reply->notice == 2306 /* Continuous Feed Terminated */) + rt->state = RTSP_STATE_IDLE; + else if (reply->notice >= 4400 && reply->notice < 5500) + return AVERROR(EIO); /* data or server error */ + else if (reply->notice == 2401 /* Ticket Expired */ || + (reply->notice >= 5500 && reply->notice < 5600) /* end of term */ ) + return AVERROR(EPERM); + return 0; } @@ -1314,6 +1328,8 @@ static int tcp_read_packet(AVFormatContext *s, RTSPStream **prtsp_st, if (ret == 1) /* received '$' */ break; /* XXX: parse message */ + if (rt->state != RTSP_STATE_PLAYING) + return 0; } ret = url_read_complete(rt->rtsp_hd, buf, 3); if (ret != 3) @@ -1399,6 +1415,8 @@ static int udp_read_packet(AVFormatContext *s, RTSPStream **prtsp_st, rtsp_read_reply(s, &reply, NULL, 0); /* XXX: parse message */ + if (rt->state != RTSP_STATE_PLAYING) + return 0; } } } @@ -1506,6 +1524,8 @@ static int rtsp_read_packet(AVFormatContext *s, } if (len < 0) return len; + if (len == 0) + return AVERROR_EOF; if (rt->transport == RTSP_TRANSPORT_RDT) ret = ff_rdt_parse_packet(rtsp_st->transport_priv, pkt, buf, len); else diff --git a/libavformat/rtsp.h b/libavformat/rtsp.h index 0772f74cac5bc3181937545f5fba86816e628880..e88d365a10e83a8d3a435608db535934a0092798 100644 --- a/libavformat/rtsp.h +++ b/libavformat/rtsp.h @@ -140,6 +140,11 @@ typedef struct RTSPMessageHeader { * this, sent dummy requests (e.g. OPTIONS) with intervals smaller * than this value. */ int timeout; + + /** The "Notice" or "X-Notice" field value. See + * http://tools.ietf.org/html/draft-stiemerling-rtsp-announce-00 + * for a complete list of supported values. */ + int notice; } RTSPMessageHeader; /**