rtsp.h

最新版本的开源流媒体服务器

/* * 
 *  $Id: rtsp.h 395 2006-10-05 16:08:10Z shawill $
 *  
 *  This file is part of Fenice
 *
 *  Fenice -- Open Media Server
 *
 *  Copyright (C) 2004 by
 *  	
 *	- Giampaolo Mancini	<[e-mail]>
 *	- Francesco Varano	<[e-mail]>
 *	- Marco Penno		<[e-mail]>
 *	- Federico Ridolfo	<[e-mail]>
 *	- Eugenio Menegatti 	<[e-mail]>
 *	- Stefano Cau
 *	- Giuliano Emma
 *	- Stefano Oldrini
 * 
 *  Fenice 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.
 *
 *  Fenice 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 Fenice; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *  
 * */

#ifndef _RTSPH
#define _RTSPH

#include <time.h>
#include <config.h>
#include <fenice/utils.h>
#include <fenice/socket.h>
#include <fenice/rtp.h>
#include <fenice/rtcp.h>
#include <fenice/mediainfo.h>
#include <fenice/schedule.h>

#define RTSP_BUFFERSIZE 4096
#define INTERLEAVED_BUFFERSIZE 4096

	/* Stati della macchina a stati del server rtsp */
#define INIT_STATE      0
#define READY_STATE     1
#define PLAY_STATE      2

#define RTSP_VER "RTSP/1.0"

#define RTSP_EL "\r\n"
#define RTSP_RTP_AVP "RTP/AVP"

typedef enum _RTSP_proto {
	TCP,
	SCTP
} RTSP_proto;

typedef struct _RTSP_interleaved {
	int rtp_fd; //!< output rtp local socket 
	int rtcp_fd; //!< output rtcp local socket
	union {
		struct {
			uint16 rtp_ch;
			uint16 rtcp_ch;
		} tcp;
		struct {
			uint16 rtp_st;
			uint16 rtcp_st;
		} sctp;
	} proto;
	struct _RTSP_interleaved *next;
} RTSP_interleaved;

typedef struct _RTSP_session {
	//tsocket fd;
	int cur_state;
	int session_id;
	RTP_session *rtp_session;
	struct _RTSP_session *next;
} RTSP_session;

typedef struct _RTSP_buffer {
	tsocket fd;
	RTSP_proto proto;
	unsigned int port;
	// Buffers      
	char in_buffer[RTSP_BUFFERSIZE];
	size_t in_size;
	char out_buffer[RTSP_BUFFERSIZE + MAX_DESCR_LENGTH];
	size_t out_size;
	size_t out_sent;
	/* vars for interleaved data:
	 * interleaved pkts will be present only at the beginning of out_buffer.
	 * this size is used to remenber how much data should be grouped in one
	 * pkt with  MSG_MORE flag.
	 * */
	RTSP_interleaved *interleaved;
	// Run-Time
	unsigned int rtsp_cseq;
	char descr[MAX_DESCR_LENGTH];	// La descrizione
	RTSP_session *session_list;
	struct _RTSP_buffer *next;
} RTSP_buffer;

	// Interfacce

void RTSP_state_machine(RTSP_buffer * rtsp, int method_code);
	//Commuta di stato sulla base di rtsp->current_state e gestisce lo stato stesso.

int RTSP_describe(RTSP_buffer * rtsp);
	//Non alloca nessuna risorsa. Risponde al client con la descrizione SDP della URL.

int RTSP_setup(RTSP_buffer * rtsp, RTSP_session ** new_session);
	//Alloca le risorse di uno stream.

int RTSP_play(RTSP_buffer * rtsp);
	// Riproduce uno stream sulla base dei parametri indicati.

int RTSP_pause(RTSP_buffer * rtsp);
	//Interrompe momentaneamente uno stream.

int RTSP_teardown(RTSP_buffer * rtsp);
	// Termina uno stream

int RTSP_options(RTSP_buffer * rtsp);

int RTSP_handler(RTSP_buffer * rtsp);
	// RTSP input buffer parser routine. Return -1 on error.

	// RTSP parsing helper functions
#define RTSP_not_full 0
#define RTSP_method_rcvd 1
#define RTSP_interlvd_rcvd 2
int RTSP_full_msg_rcvd(RTSP_buffer * rtsp, int *hdr_len, int *body_len);
#define RTSP_msg_len RTSP_full_msg_rcvd
void RTSP_discard_msg(RTSP_buffer * rtsp);
void RTSP_remove_msg(int len, RTSP_buffer * rtsp);
//      void RTSP_msg_len(int *hdr_len,int *body_len,RTSP_buffer *rtsp);        
int RTSP_valid_response_msg(unsigned short *status, char *msg,
			    RTSP_buffer * rtsp);
int RTSP_validate_method(RTSP_buffer * rtsp);
void RTSP_initserver(RTSP_buffer * rtsp, tsocket fd, RTSP_proto proto);

	// DESCRIBE     
int send_describe_reply(RTSP_buffer * rtsp, char *object,
			description_format descr_format, char *descr);

	// REDIRECT 3xx
uint32 send_redirect_3xx(RTSP_buffer *, char *);

	// SETUP
int send_setup_reply(RTSP_buffer * rtsp, RTSP_session * session,
		     SD_descr * descr, RTP_session * sp2);

	// TEARDOWN
int send_teardown_reply(RTSP_buffer * rtsp, long session_id, long cseq);

	// PLAY
int send_play_reply(RTSP_buffer * rtsp, char *object,
		    RTSP_session * rtsp_session);

	// PAUSE
int send_pause_reply(RTSP_buffer * rtsp, RTSP_session * rtsp_session);

	// OPTIONS
int send_options_reply(RTSP_buffer * rtsp, long cseq);

	// messages functions
int max_connection();
char *get_stat(int err);
int send_reply(int err, char *addon, RTSP_buffer * rtsp);
int bwrite(char *buffer, unsigned short len, RTSP_buffer * rtsp);
void add_time_stamp(char *b, int crlf);
// low level funcntions
ssize_t RTSP_send(RTSP_buffer * rtsp);

#endif