mirror of https://github.com/mpv-player/mpv
271 lines
7.6 KiB
C
271 lines
7.6 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) {
|
|
|
|
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);
|
|
}
|