rtsp.h

rtsp服务器代码 支持多种文件格式,需要添加信格式,自行书写 loadmedia readmedia freemedia即可

/* * 
 *  $Id: rtsp.h 351 2006-06-01 17:58:07Z 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

/* 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 struct _RTSP_session {
    int cur_state;   /*会话状态*/               
    int session_id; /*会话的ID*/

    RTP_session *rtp_session; /*RTP会话*/

    struct _RTSP_session *next; /*下一个会话的指针，构成链表结构*/
} RTSP_session;

typedef struct _RTSP_buffer {
    tsocket fd;    /*socket文件描述符*/
    unsigned int port;/*端口号*/
  
    char in_buffer[RTSP_BUFFERSIZE];/*接收缓冲区*/
    unsigned int in_size;/*接收缓冲区的大小*/
    char out_buffer[RTSP_BUFFERSIZE+MAX_DESCR_LENGTH];/*发送缓冲区*/
    int out_size;/*发送缓冲区大小*/

    unsigned int rtsp_cseq;/*序列号*/
    char descr[MAX_DESCR_LENGTH];/*描述*/
    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);

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

#endif