summaryrefslogtreecommitdiffstats
path: root/stream/librtsp/rtsp_session.c
diff options
context:
space:
mode:
Diffstat (limited to 'stream/librtsp/rtsp_session.c')
-rw-r--r--stream/librtsp/rtsp_session.c269
1 files changed, 269 insertions, 0 deletions
diff --git a/stream/librtsp/rtsp_session.c b/stream/librtsp/rtsp_session.c
new file mode 100644
index 0000000000..fc8aa807f8
--- /dev/null
+++ b/stream/librtsp/rtsp_session.c
@@ -0,0 +1,269 @@
+/*
+ * This file was ported to MPlayer from xine CVS rtsp_session.c,v 1.9 2003/02/11 16:20:40
+ */
+
+/*
+ * 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
+ *
+ *
+ * high level interface to rtsp servers.
+ *
+ * 2006, Benjamin Zores and Vincent Mussard
+ * Support for MPEG-TS streaming through RFC compliant RTSP servers
+ */
+
+#include <sys/types.h>
+#include "config.h"
+#ifndef HAVE_WINSOCK2
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <netdb.h>
+#else
+#include <winsock2.h>
+#endif
+#include <unistd.h>
+#include <stdio.h>
+#include <fcntl.h>
+#include <stdlib.h>
+#include <string.h>
+#include <inttypes.h>
+
+#include "mp_msg.h"
+#include "../rtp.h"
+#include "rtsp.h"
+#include "rtsp_rtp.h"
+#include "rtsp_session.h"
+#include "../realrtsp/real.h"
+#include "../realrtsp/rmff.h"
+#include "../realrtsp/asmrp.h"
+#include "../realrtsp/xbuffer.h"
+
+/*
+#define LOG
+*/
+
+#define RTSP_OPTIONS_PUBLIC "Public"
+#define RTSP_OPTIONS_SERVER "Server"
+#define RTSP_OPTIONS_LOCATION "Location"
+#define RTSP_OPTIONS_REAL "RealChallenge1"
+#define RTSP_SERVER_TYPE_REAL "Real"
+#define RTSP_SERVER_TYPE_HELIX "Helix"
+#define RTSP_SERVER_TYPE_UNKNOWN "unknown"
+
+struct rtsp_session_s {
+ rtsp_t *s;
+ struct real_rtsp_session_t* real_session;
+ struct rtp_rtsp_session_t* rtp_session;
+};
+
+//rtsp_session_t *rtsp_session_start(char *mrl) {
+rtsp_session_t *rtsp_session_start(int fd, char **mrl, char *path, char *host, int port, int *redir, uint32_t bandwidth) {
+
+ rtsp_session_t *rtsp_session = NULL;
+ char *server;
+ char *mrl_line = NULL;
+ rmff_header_t *h;
+
+ rtsp_session = malloc (sizeof (rtsp_session_t));
+ rtsp_session->s = NULL;
+ rtsp_session->real_session = NULL;
+ rtsp_session->rtp_session = NULL;
+
+//connect:
+ *redir = 0;
+
+ /* connect to server */
+ rtsp_session->s=rtsp_connect(fd,*mrl,path,host,port,NULL);
+ if (!rtsp_session->s)
+ {
+ mp_msg (MSGT_OPEN, MSGL_ERR,"rtsp_session: failed to connect to server %s\n", path);
+ free(rtsp_session);
+ return NULL;
+ }
+
+ /* looking for server type */
+ if (rtsp_search_answers(rtsp_session->s,RTSP_OPTIONS_SERVER))
+ server=strdup(rtsp_search_answers(rtsp_session->s,RTSP_OPTIONS_SERVER));
+ else {
+ if (rtsp_search_answers(rtsp_session->s,RTSP_OPTIONS_REAL))
+ server=strdup(RTSP_SERVER_TYPE_REAL);
+ else
+ server=strdup(RTSP_SERVER_TYPE_UNKNOWN);
+ }
+ if (strstr(server,RTSP_SERVER_TYPE_REAL) || strstr(server,RTSP_SERVER_TYPE_HELIX))
+ {
+ /* we are talking to a real server ... */
+
+ h=real_setup_and_get_header(rtsp_session->s, bandwidth);
+ if (!h) {
+ /* got an redirect? */
+ if (rtsp_search_answers(rtsp_session->s, RTSP_OPTIONS_LOCATION))
+ {
+ free(mrl_line);
+ mrl_line=strdup(rtsp_search_answers(rtsp_session->s, RTSP_OPTIONS_LOCATION));
+ mp_msg (MSGT_OPEN, MSGL_INFO,"rtsp_session: redirected to %s\n", mrl_line);
+ rtsp_close(rtsp_session->s);
+ free(server);
+ free(*mrl);
+ free(rtsp_session);
+ /* tell the caller to redirect, return url to redirect to in mrl */
+ *mrl = mrl_line;
+ *redir = 1;
+ return NULL;
+// goto connect; /* *shudder* i made a design mistake somewhere */
+ } else
+ {
+ mp_msg (MSGT_OPEN, MSGL_ERR,"rtsp_session: session can not be established.\n");
+ rtsp_close(rtsp_session->s);
+ free (server);
+ free(rtsp_session);
+ return NULL;
+ }
+ }
+
+ rtsp_session->real_session = init_real_rtsp_session ();
+ rtsp_session->real_session->header_len =
+ rmff_dump_header (h, (char *) rtsp_session->real_session->header, 1024);
+
+ rtsp_session->real_session->recv =
+ xbuffer_copyin (rtsp_session->real_session->recv, 0,
+ rtsp_session->real_session->header,
+ rtsp_session->real_session->header_len);
+
+ rtsp_session->real_session->recv_size =
+ rtsp_session->real_session->header_len;
+ rtsp_session->real_session->recv_read = 0;
+ } else /* not a Real server : try RTP instead */
+ {
+ char *public = NULL;
+
+ /* look for the Public: field in response to RTSP OPTIONS */
+ public = strdup (rtsp_search_answers (rtsp_session->s,
+ RTSP_OPTIONS_PUBLIC));
+ if (!public)
+ {
+ rtsp_close (rtsp_session->s);
+ free (server);
+ free (mrl_line);
+ free (rtsp_session);
+ return NULL;
+ }
+
+ /* check for minimalistic RTSP RFC compliance */
+ if (!strstr (public, RTSP_METHOD_DESCRIBE)
+ || !strstr (public, RTSP_METHOD_SETUP)
+ || !strstr (public, RTSP_METHOD_PLAY)
+ || !strstr (public, RTSP_METHOD_TEARDOWN))
+ {
+ free (public);
+ mp_msg (MSGT_OPEN, MSGL_ERR,
+ "Remote server does not meet minimal RTSP 1.0 compliance.\n");
+ rtsp_close (rtsp_session->s);
+ free (server);
+ free (mrl_line);
+ free (rtsp_session);
+ return NULL;
+ }
+
+ free (public);
+ rtsp_session->rtp_session = rtp_setup_and_play (rtsp_session->s);
+
+ /* neither a Real or an RTP server */
+ if (!rtsp_session->rtp_session)
+ {
+ mp_msg (MSGT_OPEN, MSGL_ERR, "rtsp_session: unsupported RTSP server. ");
+ mp_msg (MSGT_OPEN, MSGL_ERR, "Server type is '%s'.\n", server);
+ rtsp_close (rtsp_session->s);
+ free (server);
+ free (mrl_line);
+ free (rtsp_session);
+ return NULL;
+ }
+ }
+ free(server);
+
+ return rtsp_session;
+}
+
+int rtsp_session_read (rtsp_session_t *this, char *data, int len) {
+
+ if (this->real_session) {
+ int to_copy=len;
+ char *dest=data;
+ char *source =
+ (char *) (this->real_session->recv + this->real_session->recv_read);
+ int fill = this->real_session->recv_size - this->real_session->recv_read;
+
+ if (len < 0) return 0;
+ while (to_copy > fill) {
+
+ memcpy(dest, source, fill);
+ to_copy -= fill;
+ dest += fill;
+ this->real_session->recv_read = 0;
+ this->real_session->recv_size =
+ real_get_rdt_chunk (this->s, (char **)&(this->real_session->recv));
+ if (this->real_session->recv_size < 0)
+ return -1;
+ source = (char *) this->real_session->recv;
+ fill = this->real_session->recv_size;
+
+ if (this->real_session->recv_size == 0) {
+#ifdef LOG
+ mp_msg (MSGT_OPEN, MSGL_INFO, "librtsp: %d of %d bytes provided\n", len-to_copy, len);
+#endif
+ return len-to_copy;
+ }
+ }
+
+ memcpy(dest, source, to_copy);
+ this->real_session->recv_read += to_copy;
+
+#ifdef LOG
+ mp_msg (MSGT_OPEN, MSGL_INFO, "librtsp: %d bytes provided\n", len);
+#endif
+
+ return len;
+ }
+ else if (this->rtp_session)
+ {
+ int l = 0;
+
+ l = read_rtp_from_server (this->rtp_session->rtp_socket, data, len);
+ /* send RTSP and RTCP keepalive */
+ rtcp_send_rr (this->s, this->rtp_session);
+
+ if (l == 0)
+ rtsp_session_end (this);
+
+ return l;
+ }
+
+ return 0;
+}
+
+void rtsp_session_end(rtsp_session_t *session) {
+
+ rtsp_close(session->s);
+ if (session->real_session)
+ free_real_rtsp_session (session->real_session);
+ if (session->rtp_session)
+ rtp_session_free (session->rtp_session);
+ free(session);
+}
generated by cgit v1.2.3 (git 2.25.1) at 2024-04-26 08:08:32 +0000