Mercurial > mplayer.hg
diff stream/librtsp/rtsp_session.c @ 19271:64d82a45a05d
introduce new 'stream' directory for all stream layer related components and split them from libmpdemux
author | ben |
---|---|
date | Mon, 31 Jul 2006 17:39:17 +0000 |
parents | libmpdemux/librtsp/rtsp_session.c@317e0fd394c5 |
children | 81b239327a3e |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/stream/librtsp/rtsp_session.c Mon Jul 31 17:39:17 2006 +0000 @@ -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); +}