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.c318
1 files changed, 0 insertions, 318 deletions
diff --git a/stream/librtsp/rtsp_session.c b/stream/librtsp/rtsp_session.c
deleted file mode 100644
index 625727288c..0000000000
--- a/stream/librtsp/rtsp_session.c
+++ /dev/null
@@ -1,318 +0,0 @@
-/*
- * 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"
-#if !HAVE_WINSOCK2_H
-#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 "rtsp.h"
-#include "rtsp_rtp.h"
-#include "rtsp_session.h"
-#include "stream/network.h"
-#include "stream/url.h"
-#include "stream/rtp.h"
-#include "stream/realrtsp/real.h"
-#include "stream/realrtsp/rmff.h"
-#include "stream/realrtsp/asmrp.h"
-#include "stream/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;
-};
-
-/*
- * closes an rtsp connection
- */
-
-static void rtsp_close(rtsp_t *s) {
-
- if (s->server_state)
- {
- if (s->server_state == RTSP_PLAYING)
- rtsp_request_teardown (s, NULL);
- closesocket (s->s);
- }
-
- free(s->path);
- free(s->host);
- free(s->mrl);
- free(s->session);
- free(s->user_agent);
- free(s->server);
- rtsp_free_answers(s);
- rtsp_unschedule_all(s);
- free(s);
-}
-
-//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, char *user, char *pass) {
-
- rtsp_session_t *rtsp_session = NULL;
- char *server;
- char *mrl_line = NULL;
-
- 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 ... */
-
- rmff_header_t *h=real_setup_and_get_header(rtsp_session->s, bandwidth, user, pass);
- if (!h || !h->streams[0]) {
- rmff_free_header(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 ();
- if(!strncmp(h->streams[0]->mime_type, "application/vnd.rn-rmadriver", h->streams[0]->mime_type_size) ||
- !strncmp(h->streams[0]->mime_type, "application/smil", h->streams[0]->mime_type_size)) {
- rtsp_session->real_session->header_len = 0;
- rtsp_session->real_session->recv_size = 0;
- rtsp_session->real_session->rdt_rawdata = 1;
- mp_msg(MSGT_OPEN, MSGL_V, "smil-over-realrtsp playlist, switching to raw rdt mode\n");
- } else {
- rtsp_session->real_session->header_len =
- rmff_dump_header (h, (char *) rtsp_session->real_session->header, RTSP_HEADER_SIZE);
-
- if (rtsp_session->real_session->header_len < 0) {
- mp_msg (MSGT_OPEN, MSGL_ERR,"rtsp_session: error while dumping RMFF headers, session can not be established.\n");
- free_real_rtsp_session(rtsp_session->real_session);
- rtsp_close(rtsp_session->s);
- free (server);
- free (mrl_line);
- free(rtsp_session);
- return NULL;
- }
-
- 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;
- rmff_free_header(h);
- } else /* not a Real server : try RTP instead */
- {
- char *public = NULL;
-
- /* look for the Public: field in response to RTSP OPTIONS */
- if (!(public = rtsp_search_answers (rtsp_session->s, RTSP_OPTIONS_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))
- {
- 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;
- }
-
- 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(this->real_session->rdteof)
- return -1;
- if (len < 0) return 0;
- if (this->real_session->recv_size < 0) return -1;
- 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), this->real_session->rdt_rawdata);
- if (this->real_session->recv_size < 0) {
- this->real_session->rdteof = 1;
- this->real_session->recv_size = 0;
- }
- 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-05-03 16:00:28 +0000