Mercurial > mplayer.hg
view stream/librtsp/rtsp_session.c @ 20966:dc1a02e98cb6
clarify syncpoint placement recommanditions
(note i would also like to add a "there MUST be 1 syncpoint per second" rule)
author | michael |
---|---|
date | Fri, 17 Nov 2006 13:32:45 +0000 |
parents | b8f069b793c2 |
children | 7c5e893dff54 |
line wrap: on
line source
/* * 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 (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); }