mpv/stream/librtsp/rtsp_session.c

319 lines
9.1 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"
#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);
}
if (s->path) free(s->path);
if (s->host) free(s->host);
if (s->mrl) free(s->mrl);
if (s->session) free(s->session);
if (s->user_agent) 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);
}