summaryrefslogtreecommitdiffstats
path: root/stream/librtsp/rtsp.c
diff options
context:
space:
mode:
Diffstat (limited to 'stream/librtsp/rtsp.c')
-rw-r--r--stream/librtsp/rtsp.c729
1 files changed, 0 insertions, 729 deletions
diff --git a/stream/librtsp/rtsp.c b/stream/librtsp/rtsp.c
deleted file mode 100644
index e02ae4c72b..0000000000
--- a/stream/librtsp/rtsp.c
+++ /dev/null
@@ -1,729 +0,0 @@
-/*
- * This file was ported to MPlayer from xine CVS rtsp.c,v 1.9 2003/04/10 02:30:48
- */
-
-/*
- * Copyright (C) 2000-2002 the xine project
- *
- * This file is part of xine, a free video player.
- *
- * xine is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * xine is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program; if not, write to the Free Software
- * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
- *
- *
- * a minimalistic implementation of rtsp protocol,
- * *not* RFC 2326 compilant yet.
- *
- * 2006, Benjamin Zores and Vincent Mussard
- * fixed a lot of RFC compliance issues.
- */
-
-#include <unistd.h>
-#include <stdio.h>
-#include <assert.h>
-#include "config.h"
-#include <string.h>
-#include <sys/stat.h>
-#include <fcntl.h>
-#include <errno.h>
-#include <stdlib.h>
-#include <time.h>
-#include <sys/time.h>
-#include <sys/types.h>
-#include <inttypes.h>
-#if HAVE_WINSOCK2_H
-#include <winsock2.h>
-#else
-#include <sys/socket.h>
-#endif
-#include "mp_msg.h"
-#include "rtsp.h"
-#include "rtsp_session.h"
-#include "osdep/timer.h"
-#include "stream/network.h"
-
-/*
-#define LOG
-*/
-
-/*
- * network utilities
- */
-
-static int write_stream(int s, const char *buf, int len) {
- int total, timeout;
-
- total = 0; timeout = 30;
- while (total < len){
- int n;
-
- n = send (s, &buf[total], len - total, DEFAULT_SEND_FLAGS);
-
- if (n > 0)
- total += n;
- else if (n < 0) {
-#if !HAVE_WINSOCK2_H
- if ((timeout>0) && ((errno == EAGAIN) || (errno == EINPROGRESS))) {
-#else
- if ((timeout>0) && ((errno == EAGAIN) || (WSAGetLastError() == WSAEINPROGRESS))) {
-#endif
- usec_sleep (1000000); timeout--;
- } else
- return -1;
- }
- }
-
- return total;
-}
-
-static ssize_t read_stream(int fd, void *buf, size_t count) {
-
- ssize_t ret, total;
-
- total = 0;
-
- while (total < count) {
-
- ret=recv (fd, ((uint8_t*)buf)+total, count-total, 0);
-
- if (ret<0) {
- if(errno == EAGAIN) {
- fd_set rset;
- struct timeval timeout;
-
- FD_ZERO (&rset);
- FD_SET (fd, &rset);
-
- timeout.tv_sec = 30;
- timeout.tv_usec = 0;
-
- if (select (fd+1, &rset, NULL, NULL, &timeout) <= 0) {
- return -1;
- }
- continue;
- }
-
- mp_msg(MSGT_OPEN, MSGL_ERR, "rtsp: read error.\n");
- return ret;
- } else
- total += ret;
-
- /* end of stream */
- if (!ret) break;
- }
-
- return total;
-}
-
-/*
- * rtsp_get gets a line from stream
- * and returns a null terminated string.
- */
-
-static char *rtsp_get(rtsp_t *s) {
-
- int n=1;
- char *buffer = malloc(BUF_SIZE);
- char *string = NULL;
-
- read_stream(s->s, buffer, 1);
- while (n<BUF_SIZE) {
- read_stream(s->s, &(buffer[n]), 1);
- if ((buffer[n-1]==0x0d)&&(buffer[n]==0x0a)) break;
- n++;
- }
-
- if (n>=BUF_SIZE) {
- mp_msg(MSGT_OPEN, MSGL_FATAL, "librtsp: buffer overflow in rtsp_get\n");
- exit(1);
- }
- string=malloc(n);
- memcpy(string,buffer,n-1);
- string[n-1]=0;
-
-#ifdef LOG
- mp_msg(MSGT_OPEN, MSGL_INFO, "librtsp: << '%s'\n", string);
-#endif
-
-
- free(buffer);
- return string;
-}
-
-/*
- * rtsp_put puts a line on stream
- */
-
-static void rtsp_put(rtsp_t *s, const char *string) {
-
- int len=strlen(string);
- char *buf=malloc(len+2);
-
-#ifdef LOG
- mp_msg(MSGT_OPEN, MSGL_INFO, "librtsp: >> '%s'", string);
-#endif
-
- memcpy(buf,string,len);
- buf[len]=0x0d;
- buf[len+1]=0x0a;
-
- write_stream(s->s, buf, len+2);
-
-#ifdef LOG
- mp_msg(MSGT_OPEN, MSGL_INFO, " done.\n");
-#endif
-
- free(buf);
-}
-
-/*
- * extract server status code
- */
-
-static int rtsp_get_code(const char *string) {
-
- char buf[4];
- int code=0;
-
- if (!strncmp(string, RTSP_PROTOCOL_VERSION, strlen(RTSP_PROTOCOL_VERSION)))
- {
- memcpy(buf, string+strlen(RTSP_PROTOCOL_VERSION)+1, 3);
- buf[3]=0;
- code=atoi(buf);
- } else if (!strncmp(string, RTSP_METHOD_SET_PARAMETER,8))
- {
- return RTSP_STATUS_SET_PARAMETER;
- }
-
- if(code != RTSP_STATUS_OK) mp_msg(MSGT_OPEN, MSGL_INFO, "librtsp: server responds: '%s'\n",string);
-
- return code;
-}
-
-/*
- * send a request
- */
-
-static void rtsp_send_request(rtsp_t *s, const char *type, const char *what) {
-
- char **payload=s->scheduled;
- char *buf;
-
- buf = malloc(strlen(type)+strlen(what)+strlen(RTSP_PROTOCOL_VERSION)+3);
-
- sprintf(buf,"%s %s %s",type, what, RTSP_PROTOCOL_VERSION);
- rtsp_put(s,buf);
- free(buf);
- if (payload)
- while (*payload) {
- rtsp_put(s,*payload);
- payload++;
- }
- rtsp_put(s,"");
- rtsp_unschedule_all(s);
-}
-
-/*
- * schedule standard fields
- */
-
-static void rtsp_schedule_standard(rtsp_t *s) {
-
- char tmp[17];
-
- snprintf(tmp, 17, "CSeq: %u", s->cseq);
- rtsp_schedule_field(s, tmp);
-
- if (s->session) {
- char *buf;
- buf = malloc(strlen(s->session)+15);
- sprintf(buf, "Session: %s", s->session);
- rtsp_schedule_field(s, buf);
- free(buf);
- }
-}
-/*
- * get the answers, if server responses with something != 200, return NULL
- */
-
-static int rtsp_get_answers(rtsp_t *s) {
-
- char *answer=NULL;
- unsigned int answer_seq;
- char **answer_ptr=s->answers;
- int code;
- int ans_count = 0;
-
- answer=rtsp_get(s);
- if (!answer)
- return 0;
- code=rtsp_get_code(answer);
- free(answer);
-
- rtsp_free_answers(s);
-
- do { /* while we get answer lines */
-
- answer=rtsp_get(s);
- if (!answer)
- return 0;
-
- if (!strncasecmp(answer,"CSeq:",5)) {
- sscanf(answer,"%*s %u",&answer_seq);
- if (s->cseq != answer_seq) {
-#ifdef LOG
- mp_msg(MSGT_OPEN, MSGL_WARN, "librtsp: warning: CSeq mismatch. got %u, assumed %u", answer_seq, s->cseq);
-#endif
- s->cseq=answer_seq;
- }
- }
- if (!strncasecmp(answer,"Server:",7)) {
- char *buf = malloc(strlen(answer));
- sscanf(answer,"%*s %s",buf);
- free(s->server);
- s->server=strdup(buf);
- free(buf);
- }
- if (!strncasecmp(answer,"Session:",8)) {
- char *buf = calloc(1, strlen(answer));
- sscanf(answer,"%*s %s",buf);
- if (s->session) {
- if (strcmp(buf, s->session)) {
- mp_msg(MSGT_OPEN, MSGL_WARN, "rtsp: warning: setting NEW session: %s\n", buf);
- free(s->session);
- s->session=strdup(buf);
- }
- } else
- {
-#ifdef LOG
- mp_msg(MSGT_OPEN, MSGL_INFO, "rtsp: setting session id to: %s\n", buf);
-#endif
- s->session=strdup(buf);
- }
- free(buf);
- }
- *answer_ptr=answer;
- answer_ptr++;
- } while ((strlen(answer)!=0) && (++ans_count < MAX_FIELDS));
-
- s->cseq++;
-
- *answer_ptr=NULL;
- rtsp_schedule_standard(s);
-
- return code;
-}
-
-/*
- * send an ok message
- */
-
-int rtsp_send_ok(rtsp_t *s) {
- char cseq[16];
-
- rtsp_put(s, "RTSP/1.0 200 OK");
- sprintf(cseq,"CSeq: %u", s->cseq);
- rtsp_put(s, cseq);
- rtsp_put(s, "");
- return 0;
-}
-
-/*
- * implementation of must-have rtsp requests; functions return
- * server status code.
- */
-
-int rtsp_request_options(rtsp_t *s, const char *what) {
-
- char *buf;
-
- if (what) {
- buf=strdup(what);
- } else
- {
- buf=malloc(strlen(s->host)+16);
- sprintf(buf,"rtsp://%s:%i", s->host, s->port);
- }
- rtsp_send_request(s,RTSP_METHOD_OPTIONS,buf);
- free(buf);
-
- return rtsp_get_answers(s);
-}
-
-int rtsp_request_describe(rtsp_t *s, const char *what) {
-
- char *buf;
-
- if (what) {
- buf=strdup(what);
- } else
- {
- buf=malloc(strlen(s->host)+strlen(s->path)+16);
- sprintf(buf,"rtsp://%s:%i/%s", s->host, s->port, s->path);
- }
- rtsp_send_request(s,RTSP_METHOD_DESCRIBE,buf);
- free(buf);
-
- return rtsp_get_answers(s);
-}
-
-int rtsp_request_setup(rtsp_t *s, const char *what, char *control) {
-
- char *buf = NULL;
-
- if (what)
- buf = strdup (what);
- else
- {
- int len = strlen (s->host) + strlen (s->path) + 16;
- if (control)
- len += strlen (control) + 1;
-
- buf = malloc (len);
- sprintf (buf, "rtsp://%s:%i/%s%s%s", s->host, s->port, s->path,
- control ? "/" : "", control ? control : "");
- }
-
- rtsp_send_request (s, RTSP_METHOD_SETUP, buf);
- free (buf);
- return rtsp_get_answers (s);
-}
-
-int rtsp_request_setparameter(rtsp_t *s, const char *what) {
-
- char *buf;
-
- if (what) {
- buf=strdup(what);
- } else
- {
- buf=malloc(strlen(s->host)+strlen(s->path)+16);
- sprintf(buf,"rtsp://%s:%i/%s", s->host, s->port, s->path);
- }
- rtsp_send_request(s,RTSP_METHOD_SET_PARAMETER,buf);
- free(buf);
-
- return rtsp_get_answers(s);
-}
-
-int rtsp_request_play(rtsp_t *s, const char *what) {
-
- char *buf;
- int ret;
-
- if (what) {
- buf=strdup(what);
- } else
- {
- buf=malloc(strlen(s->host)+strlen(s->path)+16);
- sprintf(buf,"rtsp://%s:%i/%s", s->host, s->port, s->path);
- }
- rtsp_send_request(s,RTSP_METHOD_PLAY,buf);
- free(buf);
-
- ret = rtsp_get_answers (s);
- if (ret == RTSP_STATUS_OK)
- s->server_state = RTSP_PLAYING;
-
- return ret;
-}
-
-int rtsp_request_teardown(rtsp_t *s, const char *what) {
-
- char *buf;
-
- if (what)
- buf = strdup (what);
- else
- {
- buf =
- malloc (strlen (s->host) + strlen (s->path) + 16);
- sprintf (buf, "rtsp://%s:%i/%s", s->host, s->port, s->path);
- }
- rtsp_send_request (s, RTSP_METHOD_TEARDOWN, buf);
- free (buf);
-
- /* after teardown we're done with RTSP streaming, no need to get answer as
- reading more will only result to garbage and buffer overflow */
- return RTSP_STATUS_OK;
-}
-
-/*
- * read opaque data from stream
- */
-
-int rtsp_read_data(rtsp_t *s, char *buffer, unsigned int size) {
-
- int i,seq;
-
- if (size>=4) {
- i=read_stream(s->s, buffer, 4);
- if (i<4) return i;
- if (((buffer[0]=='S')&&(buffer[1]=='E')&&(buffer[2]=='T')&&(buffer[3]=='_')) ||
- ((buffer[0]=='O')&&(buffer[1]=='P')&&(buffer[2]=='T')&&(buffer[3]=='I'))) // OPTIONS
- {
- char *rest=rtsp_get(s);
- if (!rest)
- return -1;
-
- seq=-1;
- do {
- free(rest);
- rest=rtsp_get(s);
- if (!rest)
- return -1;
- if (!strncasecmp(rest,"CSeq:",5))
- sscanf(rest,"%*s %u",&seq);
- } while (strlen(rest)!=0);
- free(rest);
- if (seq<0) {
-#ifdef LOG
- mp_msg(MSGT_OPEN, MSGL_WARN, "rtsp: warning: CSeq not recognized!\n");
-#endif
- seq=1;
- }
- /* let's make the server happy */
- rtsp_put(s, "RTSP/1.0 451 Parameter Not Understood");
- rest=malloc(17);
- sprintf(rest,"CSeq: %u", seq);
- rtsp_put(s, rest);
- free(rest);
- rtsp_put(s, "");
- i=read_stream(s->s, buffer, size);
- } else
- {
- i=read_stream(s->s, buffer+4, size-4);
- i+=4;
- }
- } else
- i=read_stream(s->s, buffer, size);
-#ifdef LOG
- mp_msg(MSGT_OPEN, MSGL_INFO, "librtsp: << %d of %d bytes\n", i, size);
-#endif
-
- return i;
-}
-
-/*
- * connect to a rtsp server
- */
-
-//rtsp_t *rtsp_connect(const char *mrl, const char *user_agent) {
-rtsp_t *rtsp_connect(int fd, char* mrl, char *path, char *host, int port, char *user_agent) {
-
- rtsp_t *s;
- int i;
-
- if (fd < 0) {
- mp_msg(MSGT_OPEN, MSGL_ERR, "rtsp: failed to connect to '%s'\n", host);
- return NULL;
- }
-
- s = malloc(sizeof(rtsp_t));
-
- for (i=0; i<MAX_FIELDS; i++) {
- s->answers[i]=NULL;
- s->scheduled[i]=NULL;
- }
-
- s->s = fd;
- s->server=NULL;
- s->server_state=0;
- s->server_caps=0;
-
- s->cseq=0;
- s->session=NULL;
-
- if (user_agent)
- s->user_agent=strdup(user_agent);
- else
- s->user_agent=strdup("User-Agent: RealMedia Player Version 6.0.9.1235 (linux-2.0-libc6-i386-gcc2.95)");
-
- s->mrl = strdup(mrl);
- s->host = strdup(host);
- s->port = port;
- s->path = strdup(path);
- while (*path == '/')
- path++;
- if ((s->param = strchr(s->path, '?')) != NULL)
- s->param++;
- //mp_msg(MSGT_OPEN, MSGL_INFO, "path=%s\n", s->path);
- //mp_msg(MSGT_OPEN, MSGL_INFO, "param=%s\n", s->param ? s->param : "NULL");
-
- s->server_state=RTSP_CONNECTED;
-
- /* now let's send an options request. */
- rtsp_schedule_field(s, "CSeq: 1");
- rtsp_schedule_field(s, s->user_agent);
- rtsp_schedule_field(s, "ClientChallenge: 9e26d33f2984236010ef6253fb1887f7");
- rtsp_schedule_field(s, "PlayerStarttime: [28/03/2003:22:50:23 00:00]");
- rtsp_schedule_field(s, "CompanyID: KnKV4M4I/B2FjJ1TToLycw==");
- rtsp_schedule_field(s, "GUID: 00000000-0000-0000-0000-000000000000");
- rtsp_schedule_field(s, "RegionData: 0");
- rtsp_schedule_field(s, "ClientID: Linux_2.4_6.0.9.1235_play32_RN01_EN_586");
- /*rtsp_schedule_field(s, "Pragma: initiate-session");*/
- rtsp_request_options(s, NULL);
-
- return s;
-}
-
-
-/*
- * search in answers for tags. returns a pointer to the content
- * after the first matched tag. returns NULL if no match found.
- */
-
-char *rtsp_search_answers(rtsp_t *s, const char *tag) {
-
- char **answer;
- char *ptr;
-
- if (!s->answers) return NULL;
- answer=s->answers;
-
- while (*answer) {
- if (!strncasecmp(*answer,tag,strlen(tag))) {
- ptr=strchr(*answer,':');
- if (!ptr) return NULL;
- ptr++;
- while(*ptr==' ') ptr++;
- return ptr;
- }
- answer++;
- }
-
- return NULL;
-}
-
-/*
- * session id management
- */
-
-void rtsp_set_session(rtsp_t *s, const char *id) {
-
- free(s->session);
-
- s->session=strdup(id);
-
-}
-
-char *rtsp_get_session(rtsp_t *s) {
-
- return s->session;
-
-}
-
-char *rtsp_get_mrl(rtsp_t *s) {
-
- return s->mrl;
-
-}
-
-char *rtsp_get_param(rtsp_t *s, const char *p) {
- int len;
- char *param;
- if (!s->param)
- return NULL;
- if (!p)
- return strdup(s->param);
- len = strlen(p);
- param = s->param;
- while (param && *param) {
- char *nparam = strchr(param, '&');
- if (strncmp(param, p, len) == 0 && param[len] == '=') {
- param += len + 1;
- len = nparam ? nparam - param : strlen(param);
- nparam = malloc(len + 1);
- memcpy(nparam, param, len);
- nparam[len] = 0;
- return nparam;
- }
- param = nparam ? nparam + 1 : NULL;
- }
- return NULL;
-}
-
-/*
- * schedules a field for transmission
- */
-
-void rtsp_schedule_field(rtsp_t *s, const char *string) {
-
- int i=0;
-
- if (!string) return;
-
- while(s->scheduled[i]) {
- i++;
- }
- s->scheduled[i]=strdup(string);
-}
-
-/*
- * removes the first scheduled field which prefix matches string.
- */
-
-void rtsp_unschedule_field(rtsp_t *s, const char *string) {
-
- char **ptr=s->scheduled;
-
- if (!string) return;
-
- while(*ptr) {
- if (!strncmp(*ptr, string, strlen(string)))
- break;
- else
- ptr++;
- }
- free(*ptr);
- ptr++;
- do {
- *(ptr-1)=*ptr;
- } while(*ptr);
-}
-
-/*
- * unschedule all fields
- */
-
-void rtsp_unschedule_all(rtsp_t *s) {
-
- char **ptr;
-
- if (!s->scheduled) return;
- ptr=s->scheduled;
-
- while (*ptr) {
- free(*ptr);
- *ptr=NULL;
- ptr++;
- }
-}
-/*
- * free answers
- */
-
-void rtsp_free_answers(rtsp_t *s) {
-
- char **answer;
-
- if (!s->answers) return;
- answer=s->answers;
-
- while (*answer) {
- free(*answer);
- *answer=NULL;
- answer++;
- }
-}
generated by cgit v1.2.3 (git 2.25.1) at 2024-05-03 13:03:02 +0000