mpv/stream/librtsp/rtsp_session.c

273 lines
7.7 KiB
C

/*
* 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 "../url.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, char *user, char *pass) {
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, user, pass);
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 */
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));
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);
}