rtmp_amf_flv.h
上传用户:kjfoods
上传日期:2020-07-06
资源大小:29949k
文件大小:5k
源码类别:

midi

开发平台:

Unix_Linux

  1. /*****************************************************************************
  2.  * rtmp_amf_flv.h: RTMP, AMF and FLV over RTMP implementation.
  3.  *****************************************************************************
  4.  * Copyright (C) URJC - LADyR - Luis Lopez Fernandez
  5.  *
  6.  * Author: Miguel Angel Cabrera Moya
  7.  *
  8.  * This program is free software; you can redistribute it and/or modify
  9.  * it under the terms of the GNU General Public License as published by
  10.  * the Free Software Foundation; either version 2 of the License, or
  11.  * (at your option) any later version.
  12.  *
  13.  * This program is distributed in the hope that it will be useful,
  14.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  15.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16.  * GNU General Public License for more details.
  17.  *
  18.  * You should have received a copy of the GNU General Public License
  19.  * along with this program; if not, write to the Free Software
  20.  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
  21.  *****************************************************************************/
  22. /*****************************************************************************
  23.  * Local prototypes (continued from access.c)
  24.  *****************************************************************************/
  25. typedef struct rtmp_packet_t rtmp_packet_t;
  26. typedef struct rtmp_body_t rtmp_body_t;
  27. typedef struct rtmp_control_thread_t rtmp_control_thread_t;
  28. typedef void (*rtmp_handler_t)( rtmp_control_thread_t *p_thread, rtmp_packet_t *rtmp_packet );
  29. struct rtmp_packet_t
  30. {
  31.     int length_header;
  32.     int stream_index;
  33.     uint32_t timestamp;
  34.     uint32_t timestamp_relative;
  35.     int32_t length_encoded;
  36.     int32_t length_body;
  37.     uint8_t content_type;
  38.     uint32_t src_dst;
  39.     rtmp_body_t *body;
  40. };
  41. struct rtmp_body_t
  42. {
  43.     int32_t length_body; /* without interchunk headers */
  44.     int32_t length_buffer;
  45.     uint8_t *body;
  46. };
  47. struct rtmp_control_thread_t
  48. {
  49.     VLC_COMMON_MEMBERS
  50.     int fd;
  51.     vlc_url_t url;
  52.     char *psz_application;
  53.     char *psz_media;
  54.     block_fifo_t *p_fifo_input;
  55.     block_fifo_t *p_empty_blocks;
  56.     vlc_mutex_t lock;
  57.     vlc_cond_t  wait;
  58.     int result_connect;
  59. int result_publish;
  60.     int result_play;
  61. int result_stop;
  62.     double stream_client_id;
  63.     double stream_server_id;
  64.     char *psz_publish;
  65.     /* Rebuild FLV variables (access) */
  66.     int has_audio;
  67.     int has_video;
  68.     int metadata_received;
  69.     uint8_t metadata_stereo;
  70.     uint8_t metadata_samplesize;
  71.     uint32_t metadata_samplerate;
  72.     uint8_t metadata_audiocodecid;
  73.     uint8_t metadata_videocodecid;
  74.     uint8_t metadata_frametype;
  75.     int first_media_packet;
  76.     uint32_t flv_tag_previous_tag_size;
  77.     /* Vars for rebuilding FLV (access_output) */
  78.     rtmp_body_t *flv_body;
  79.     uint8_t flv_content_type;
  80.     uint32_t flv_length_body;
  81.     uint32_t flv_timestamp;
  82.     /* vars for channel state */
  83.     uint32_t chunk_size_recv;
  84.     uint32_t chunk_size_send;
  85.     rtmp_packet_t rtmp_headers_recv[64]; /* RTMP_HEADER_STREAM_MAX */
  86.     rtmp_packet_t rtmp_headers_send[64];
  87.     rtmp_handler_t rtmp_handler[21]; /* index by RTMP_CONTENT_TYPE */
  88.     /* Pointer to base module object (later needs to casted) */
  89.     void *p_base_object;
  90. };
  91. struct access_sys_t
  92. {
  93.     int active;
  94.     /* vars for reading from fifo */
  95.     block_t *flv_packet;
  96.     int read_packet;
  97.     /* thread for filtering and handling control messages */
  98.     rtmp_control_thread_t *p_thread;
  99. };
  100. /*****************************************************************************
  101.  * RTMP header:
  102.  ******************************************************************************/
  103. int rtmp_handshake_active( vlc_object_t *p_this, int fd );
  104. int rtmp_handshake_passive( vlc_object_t *p_this, int fd );
  105. int rtmp_connect_active( rtmp_control_thread_t *p_thread );
  106. int rtmp_connect_passive( rtmp_control_thread_t *p_thread );
  107. //int rtmp_seek( access_t *p_access, int64_t i_pos ); TODO
  108. //
  109. rtmp_packet_t *rtmp_build_bytes_read( rtmp_control_thread_t *p_thread, uint32_t reply );
  110. rtmp_packet_t *rtmp_build_publish_start( rtmp_control_thread_t *p_thread );
  111. rtmp_packet_t *rtmp_build_flv_over_rtmp( rtmp_control_thread_t *p_thread, block_t *p_buffer );
  112. rtmp_packet_t *rtmp_read_net_packet( rtmp_control_thread_t *p_thread );
  113. uint8_t *rtmp_encode_packet( rtmp_control_thread_t *p_thread, rtmp_packet_t *rtmp_packet );
  114. void rtmp_init_handler( rtmp_handler_t *rtmp_handler );
  115. /*****************************************************************************
  116.  * FLV header:
  117.  ******************************************************************************/
  118. block_t *flv_get_metadata( access_t *p_access );
  119. block_t *flv_insert_header( access_t *p_access, block_t *first_packet );
  120. /*****************************************************************************
  121.  * RTMP body header:
  122.  ******************************************************************************/
  123. rtmp_body_t *rtmp_body_new( int length_buffer );
  124. void rtmp_body_reset( rtmp_body_t * );