removed ctype.h header
[libav.git] / libavformat / rtsp.c
index c173cb8..802591d 100644 (file)
  */
 #include "avformat.h"
 
+#include <unistd.h> /* for select() prototype */
 #include <sys/time.h>
 #include <netinet/in.h>
 #include <sys/socket.h>
-#include <ctype.h>
 #ifndef __BEOS__
 # include <arpa/inet.h>
 #else
 #endif
 
 //#define DEBUG
+//#define DEBUG_RTP_TCP
 
 typedef struct RTSPState {
     URLContext *rtsp_hd; /* RTSP TCP connexion handle */
-    ByteIOContext rtsp_gb;
+    /* XXX: currently we use unbuffered input */
+    //    ByteIOContext rtsp_gb;
     int seq;        /* RTSP command sequence number */
     char session_id[512];
     enum RTSPProtocol protocol;
@@ -50,12 +52,14 @@ typedef struct RTSPStream {
     int sdp_payload_type; /* payload type - only used in SDP */
 } RTSPStream;
 
-/* suppress this hack */
-int rtsp_abort_req = 0;
-
 /* XXX: currently, the only way to change the protocols consists in
    changing this variable */
+#if 1
 int rtsp_default_protocols = (1 << RTSP_PROTOCOL_RTP_TCP) | (1 << RTSP_PROTOCOL_RTP_UDP) | (1 << RTSP_PROTOCOL_RTP_UDP_MULTICAST);
+#else
+/* try it if a proxy is used */
+int rtsp_default_protocols = (1 << RTSP_PROTOCOL_RTP_TCP);
+#endif
 
 /* if non zero, then set a range for RTP ports */
 int rtsp_rtp_port_min = 0;
@@ -345,7 +349,7 @@ static void sdp_parse_line(AVFormatContext *s, SDPParseState *s1,
     }
 }
 
-int sdp_parse(AVFormatContext *s, const char *content)
+static int sdp_parse(AVFormatContext *s, const char *content)
 {
     const char *p;
     int letter;
@@ -365,7 +369,7 @@ int sdp_parse(AVFormatContext *s, const char *content)
         p++;
         /* get the content */
         q = buf;
-        while (*p != '\n' && *p != '\0') {
+        while (*p != '\n' && *p != '\r' && *p != '\0') {
             if ((q - buf) < sizeof(buf) - 1)
                 *q++ = *p;
             p++;
@@ -427,10 +431,11 @@ static void rtsp_parse_transport(RTSPHeader *reply, const char *p)
         get_word_sep(profile, sizeof(profile), "/;,", &p);
         lower_transport[0] = '\0';
         if (*p == '/') {
+            p++;
             get_word_sep(lower_transport, sizeof(lower_transport), 
                          ";,", &p);
         }
-        if (!strcmp(lower_transport, "TCP"))
+        if (!strcasecmp(lower_transport, "TCP"))
             th->protocol = RTSP_PROTOCOL_RTP_TCP;
         else
             th->protocol = RTSP_PROTOCOL_RTP_UDP;
@@ -510,6 +515,31 @@ void rtsp_parse_line(RTSPHeader *reply, const char *buf)
     }
 }
 
+/* skip a RTP/TCP interleaved packet */
+static void rtsp_skip_packet(AVFormatContext *s)
+{
+    RTSPState *rt = s->priv_data;
+    int ret, len, len1;
+    uint8_t buf[1024];
+
+    ret = url_read(rt->rtsp_hd, buf, 3);
+    if (ret != 3)
+        return;
+    len = (buf[1] << 8) | buf[2];
+#ifdef DEBUG
+    printf("skipping RTP packet len=%d\n", len);
+#endif
+    /* skip payload */
+    while (len > 0) {
+        len1 = len;
+        if (len1 > sizeof(buf))
+            len1 = sizeof(buf);
+        ret = url_read(rt->rtsp_hd, buf, len1);
+        if (ret != len1)
+            return;
+        len -= len1;
+    }
+}
 
 static void rtsp_send_cmd(AVFormatContext *s, 
                           const char *cmd, RTSPHeader *reply, 
@@ -526,13 +556,13 @@ static void rtsp_send_cmd(AVFormatContext *s,
 
     rt->seq++;
     pstrcpy(buf, sizeof(buf), cmd);
-    snprintf(buf1, sizeof(buf1), "CSeq: %d\n", rt->seq);
+    snprintf(buf1, sizeof(buf1), "CSeq: %d\r\n", rt->seq);
     pstrcat(buf, sizeof(buf), buf1);
     if (rt->session_id[0] != '\0' && !strstr(cmd, "\nIf-Match:")) {
-        snprintf(buf1, sizeof(buf1), "Session: %s\n", rt->session_id);
+        snprintf(buf1, sizeof(buf1), "Session: %s\r\n", rt->session_id);
         pstrcat(buf, sizeof(buf), buf1);
     }
-    pstrcat(buf, sizeof(buf), "\n");
+    pstrcat(buf, sizeof(buf), "\r\n");
 #ifdef DEBUG
     printf("Sending:\n%s--\n", buf);
 #endif
@@ -544,11 +574,14 @@ static void rtsp_send_cmd(AVFormatContext *s,
     for(;;) {
         q = buf;
         for(;;) {
-            if (url_read(rt->rtsp_hd, &ch, 1) == 0)
+            if (url_read(rt->rtsp_hd, &ch, 1) != 1)
                 break;
             if (ch == '\n')
                 break;
-            if (ch != '\r') {
+            if (ch == '$') {
+                /* XXX: only parse it if first char on line ? */
+                rtsp_skip_packet(s);
+            } else if (ch != '\r') {
                 if ((q - buf) < sizeof(buf) - 1)
                     *q++ = ch;
             }
@@ -609,8 +642,6 @@ static int rtsp_read_header(AVFormatContext *s,
     RTSPStream *rtsp_st;
     int protocol_mask;
 
-    rtsp_abort_req = 0;
-    
     /* extract hostname and port */
     url_split(NULL, 0,
               host, sizeof(host), &port, path, sizeof(path), s->filename);
@@ -626,8 +657,8 @@ static int rtsp_read_header(AVFormatContext *s,
     
     /* describe the stream */
     snprintf(cmd, sizeof(cmd), 
-             "DESCRIBE %s RTSP/1.0\n"
-             "Accept: application/sdp\n",
+             "DESCRIBE %s RTSP/1.0\r\n"
+             "Accept: application/sdp\r\n",
              s->filename);
     rtsp_send_cmd(s, cmd, reply, &content);
     if (!content) {
@@ -708,10 +739,9 @@ static int rtsp_read_header(AVFormatContext *s,
                      sizeof(transport) - strlen(transport) - 1,
                      "RTP/AVP/UDP;multicast");
         }
-        
         snprintf(cmd, sizeof(cmd), 
-                 "SETUP %s RTSP/1.0\n"
-                 "Transport: %s\n",
+                 "SETUP %s RTSP/1.0\r\n"
+                 "Transport: %s\r\n",
                  rtsp_st->control_url, transport);
         rtsp_send_cmd(s, cmd, reply, NULL);
         if (reply->status_code != RTSP_STATUS_OK ||
@@ -794,7 +824,8 @@ static int rtsp_read_header(AVFormatContext *s,
                          
     /* start playing */
     snprintf(cmd, sizeof(cmd), 
-             "PLAY %s RTSP/1.0\n",
+             "PLAY %s RTSP/1.0\r\n"
+             "Range: npt=0-\r\n",
              s->filename);
     rtsp_send_cmd(s, cmd, reply, NULL);
     if (reply->status_code != RTSP_STATUS_OK) {
@@ -802,6 +833,7 @@ static int rtsp_read_header(AVFormatContext *s,
         goto fail;
     }
 
+#if 0
     /* open TCP with bufferized input */
     if (rt->protocol == RTSP_PROTOCOL_RTP_TCP) {
         if (url_fdopen(&rt->rtsp_gb, rt->rtsp_hd) < 0) {
@@ -809,6 +841,7 @@ static int rtsp_read_header(AVFormatContext *s,
             goto fail;
         }
     }
+#endif
 
     return 0;
  fail:
@@ -830,33 +863,46 @@ static int tcp_read_packet(AVFormatContext *s,
                            AVPacket *pkt)
 {
     RTSPState *rt = s->priv_data;
-    ByteIOContext *rtsp_gb = &rt->rtsp_gb;
-    int c, id, len, i, ret;
+    int id, len, i, ret;
     AVStream *st;
     RTSPStream *rtsp_st;
-    char buf[RTP_MAX_PACKET_LENGTH];
+    uint8_t buf[RTP_MAX_PACKET_LENGTH];
 
+#ifdef DEBUG_RTP_TCP
+    printf("tcp_read_packet:\n");
+#endif
  redo:
     for(;;) {
-        c = url_fgetc(rtsp_gb);
-        if (c == URL_EOF)
+        ret = url_read(rt->rtsp_hd, buf, 1);
+#ifdef DEBUG_RTP_TCP
+        printf("ret=%d c=%02x [%c]\n", ret, buf[0], buf[0]);
+#endif
+        if (ret != 1)
             return AVERROR_IO;
-        if (c == '$')
+        if (buf[0] == '$')
             break;
     }
-    id = get_byte(rtsp_gb);
-    len = get_be16(rtsp_gb);
+    ret = url_read(rt->rtsp_hd, buf, 3);
+    if (ret != 3)
+        return AVERROR_IO;
+    id = buf[0];
+    len = (buf[1] << 8) | buf[2];
+#ifdef DEBUG_RTP_TCP
+    printf("id=%d len=%d\n", id, len);
+#endif
     if (len > RTP_MAX_PACKET_LENGTH || len < 12)
         goto redo;
     /* get the data */
-    get_buffer(rtsp_gb, buf, len);
-    
+    ret = url_read(rt->rtsp_hd, buf, len);
+    if (ret != len)
+        return AVERROR_IO;
+        
     /* find the matching stream */
     for(i = 0; i < s->nb_streams; i++) {
         st = s->streams[i];
         rtsp_st = st->priv_data;
-        if (i >= rtsp_st->interleaved_min && 
-            i <= rtsp_st->interleaved_max) 
+        if (id >= rtsp_st->interleaved_min && 
+            id <= rtsp_st->interleaved_max) 
             goto found;
     }
     goto redo;
@@ -881,7 +927,7 @@ static int udp_read_packet(AVFormatContext *s,
     struct timeval tv;
 
     for(;;) {
-        if (rtsp_abort_req)
+        if (url_interrupt_cb())
             return -EIO;
         FD_ZERO(&rfds);
         fd_max = -1;
@@ -897,7 +943,7 @@ static int udp_read_packet(AVFormatContext *s,
         }
         /* XXX: also add proper API to abort */
         tv.tv_sec = 0;
-        tv.tv_usec = 500000;
+        tv.tv_usec = 100 * 1000;
         n = select(fd_max + 1, &rfds, NULL, NULL, &tv);
         if (n > 0) {
             for(i = 0; i < s->nb_streams; i++) {
@@ -936,6 +982,52 @@ static int rtsp_read_packet(AVFormatContext *s,
     return ret;
 }
 
+/* pause the stream */
+int rtsp_pause(AVFormatContext *s)
+{
+    RTSPState *rt;
+    RTSPHeader reply1, *reply = &reply1;
+    char cmd[1024];
+
+    if (s->iformat != &rtsp_demux)
+        return -1;
+    
+    rt = s->priv_data;
+    
+    snprintf(cmd, sizeof(cmd), 
+             "PAUSE %s RTSP/1.0\r\n",
+             s->filename);
+    rtsp_send_cmd(s, cmd, reply, NULL);
+    if (reply->status_code != RTSP_STATUS_OK) {
+        return -1;
+    } else {
+        return 0;
+    }
+}
+
+/* resume the stream */
+int rtsp_resume(AVFormatContext *s)
+{
+    RTSPState *rt;
+    RTSPHeader reply1, *reply = &reply1;
+    char cmd[1024];
+
+    if (s->iformat != &rtsp_demux)
+        return -1;
+    
+    rt = s->priv_data;
+    
+    snprintf(cmd, sizeof(cmd), 
+             "PLAY %s RTSP/1.0\r\n",
+             s->filename);
+    rtsp_send_cmd(s, cmd, reply, NULL);
+    if (reply->status_code != RTSP_STATUS_OK) {
+        return -1;
+    } else {
+        return 0;
+    }
+}
+
 static int rtsp_read_close(AVFormatContext *s)
 {
     RTSPState *rt = s->priv_data;
@@ -945,13 +1037,14 @@ static int rtsp_read_close(AVFormatContext *s)
     int i;
     char cmd[1024];
 
+#if 0
     /* NOTE: it is valid to flush the buffer here */
     if (rt->protocol == RTSP_PROTOCOL_RTP_TCP) {
         url_fclose(&rt->rtsp_gb);
     }
-
+#endif
     snprintf(cmd, sizeof(cmd), 
-             "TEARDOWN %s RTSP/1.0\n",
+             "TEARDOWN %s RTSP/1.0\r\n",
              s->filename);
     rtsp_send_cmd(s, cmd, reply, NULL);
 
@@ -973,7 +1066,7 @@ static int rtsp_read_close(AVFormatContext *s)
     return 0;
 }
 
-static AVInputFormat rtsp_demux = {
+AVInputFormat rtsp_demux = {
     "rtsp",
     "RTSP input format",
     sizeof(RTSPState),