comparison libmpdemux/librtsp/rtsp_session.c @ 18829:317e0fd394c5

added new native rtsp demuxer code for mpeg-ts over rtp (now both real and non-real servers should be handled)

18828:55ebe20fadbc

 * 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.
 */

#include <sys/types.h>
#include "config.h"
#ifndef HAVE_WINSOCK2

#include <stdlib.h>
#include <string.h>
#include <inttypes.h>

#include "mp_msg.h"
#include "rtsp.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_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;
};

//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) {

  rmff_header_t *h;

  rtsp_session = malloc (sizeof (rtsp_session_t));
  rtsp_session->s = NULL;
  rtsp_session->real_session = NULL;
 
//connect:
  *redir = 0;

  /* connect to server */

                      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
  {
    mp_msg (MSGT_OPEN, MSGL_ERR,"rtsp_session: Not a Real server. Server type is '%s'.\n",server);
    rtsp_close(rtsp_session->s);
    free(server);
    free(rtsp_session);
    return NULL;
  }
  free(server);
  
  return rtsp_session;
}

  mp_msg (MSGT_OPEN, MSGL_INFO, "librtsp: %d bytes provided\n", len);
#endif

  return len;
  }

  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);
  free(session);
}

18829:317e0fd394c5

 * 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 <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) {

  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->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;
}

  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);
}