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

midi

开发平台:

Unix_Linux

  1. /*****************************************************************************
  2.  * rawdv.c : raw DV input module for vlc
  3.  *****************************************************************************
  4.  * Copyright (C) 2001-2007 the VideoLAN team
  5.  * $Id: 611be06aece1b9e0a638e3be4cf70c9617a1b105 $
  6.  *
  7.  * Authors: Gildas Bazin <gbazin@netcourrier.com>
  8.  *          Paul Corke <paul dot corke at datatote dot co dot uk>
  9.  *
  10.  * This program is free software; you can redistribute it and/or modify
  11.  * it under the terms of the GNU General Public License as published by
  12.  * the Free Software Foundation; either version 2 of the License, or
  13.  * (at your option) any later version.
  14.  *
  15.  * This program is distributed in the hope that it will be useful,
  16.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  17.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  18.  * GNU General Public License for more details.
  19.  *
  20.  * You should have received a copy of the GNU General Public License
  21.  * along with this program; if not, write to the Free Software
  22.  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
  23.  *****************************************************************************/
  24. /*****************************************************************************
  25.  * Preamble
  26.  *****************************************************************************/
  27. #ifdef HAVE_CONFIG_H
  28. # include "config.h"
  29. #endif
  30. #include <vlc_common.h>
  31. #include <vlc_plugin.h>
  32. #include <vlc_demux.h>
  33. /*****************************************************************************
  34.  * Module descriptor
  35.  *****************************************************************************/
  36. #define HURRYUP_TEXT N_( "Hurry up" )
  37. #define HURRYUP_LONGTEXT N_( "The demuxer will advance timestamps if the " 
  38.                 "input can't keep up with the rate." )
  39. static int  Open ( vlc_object_t * );
  40. static void Close( vlc_object_t * );
  41. vlc_module_begin ()
  42.     set_shortname( "DV" )
  43.     set_description( N_("DV (Digital Video) demuxer") )
  44.     set_capability( "demux", 3 )
  45.     set_category( CAT_INPUT )
  46.     set_subcategory( SUBCAT_INPUT_DEMUX )
  47.     add_bool( "rawdv-hurry-up", 0, NULL, HURRYUP_TEXT, HURRYUP_LONGTEXT, false )
  48.     set_callbacks( Open, Close )
  49.     add_shortcut( "rawdv" )
  50. vlc_module_end ()
  51. /*****************************************************************************
  52.  A little bit of background information (copied over from libdv glossary).
  53.  - DIF block: A block of 80 bytes. This is the basic data framing unit of the
  54.        DVC tape format, analogous to sectors of hard disc.
  55.  - Video Section: Each DIF sequence contains a video section, consisting of
  56.        135 DIF blocks, which are further subdivided into Video Segments.
  57.  - Video Segment: A video segment consists of 5 DIF blocks, each corresponding
  58.        to a single compressed macroblock.
  59. *****************************************************************************/
  60. /*****************************************************************************
  61.  * Constants
  62.  *****************************************************************************/
  63. #define DV_PAL_FRAME_SIZE  144000
  64. #define DV_NTSC_FRAME_SIZE 122000
  65. /*****************************************************************************
  66.  * Definitions of structures used by this plugin
  67.  *****************************************************************************/
  68. typedef struct {
  69.     int8_t sct;      /* Section type (header,subcode,aux,audio,video) */
  70.     int8_t dsn;      /* DIF sequence number (0-12) */
  71.     int    fsc;      /* First (0)/Second channel (1) */
  72.     int8_t dbn;      /* DIF block number (0-134) */
  73. } dv_id_t;
  74. typedef struct {
  75.     int    dsf;      /* DIF sequence flag: 525/60 (0) or 625,50 (1) */
  76.     int8_t apt;
  77.     int    tf1;
  78.     int8_t ap1;
  79.     int    tf2;
  80.     int8_t ap2;
  81.     int    tf3;
  82.     int8_t ap3;
  83. } dv_header_t;
  84. struct demux_sys_t
  85. {
  86.     int    frame_size;
  87.     es_out_id_t *p_es_video;
  88.     es_format_t  fmt_video;
  89.     es_out_id_t *p_es_audio;
  90.     es_format_t  fmt_audio;
  91.     int    i_dsf;
  92.     double f_rate;
  93.     int    i_bitrate;
  94.     /* program clock reference (in units of 90kHz) */
  95.     mtime_t i_pcr;
  96.     bool b_hurry_up;
  97. };
  98. /*****************************************************************************
  99.  * Local prototypes
  100.  *****************************************************************************/
  101. static int Demux( demux_t * );
  102. static int Control( demux_t *, int i_query, va_list args );
  103. static block_t *dv_extract_audio( demux_t *p_demux,
  104.                                   block_t* p_frame_block );
  105. /*****************************************************************************
  106.  * Open: initializes raw DV demux structures
  107.  *****************************************************************************/
  108. static int Open( vlc_object_t * p_this )
  109. {
  110.     demux_t     *p_demux = (demux_t*)p_this;
  111.     demux_sys_t *p_sys;
  112.     const uint8_t *p_peek, *p_peek_backup;
  113.     uint32_t    i_dword;
  114.     dv_header_t dv_header;
  115.     dv_id_t     dv_id;
  116.     /* It isn't easy to recognize a raw DV stream. The chances that we'll
  117.      * mistake a stream from another type for a raw DV stream are too high, so
  118.      * we'll rely on the file extension to trigger this demux. Alternatively,
  119.      * it is possible to force this demux. */
  120.     /* Check for DV file extension */
  121.     if( !demux_IsPathExtension( p_demux, ".dv" ) && !p_demux->b_force )
  122.         return VLC_EGENERIC;
  123.     if( stream_Peek( p_demux->s, &p_peek, DV_PAL_FRAME_SIZE ) <
  124.         DV_NTSC_FRAME_SIZE )
  125.     {
  126.         /* Stream too short ... */
  127.         msg_Err( p_demux, "cannot peek()" );
  128.         return VLC_EGENERIC;
  129.     }
  130.     p_peek_backup = p_peek;
  131.     /* fill in the dv_id_t structure */
  132.     i_dword = GetDWBE( p_peek ); p_peek += 4;
  133.     dv_id.sct = i_dword >> (32 - 3);
  134.     i_dword <<= 8;
  135.     dv_id.dsn = i_dword >> (32 - 4);
  136.     i_dword <<= 4;
  137.     dv_id.fsc = i_dword >> (32 - 1);
  138.     i_dword <<= 4;
  139.     dv_id.dbn = i_dword >> (32 - 8);
  140.     i_dword <<= 8;
  141.     if( dv_id.sct != 0 )
  142.     {
  143.         msg_Warn( p_demux, "not a raw DV stream header" );
  144.         return VLC_EGENERIC;
  145.     }
  146.     /* fill in the dv_header_t structure */
  147.     dv_header.dsf = i_dword >> (32 - 1);
  148.     i_dword <<= 1;
  149.     if( i_dword >> (32 - 1) ) /* incorrect bit */
  150.     {
  151.         msg_Warn( p_demux, "incorrect bit" );
  152.         return VLC_EGENERIC;
  153.     }
  154.     i_dword = GetDWBE( p_peek ); p_peek += 4;
  155.     i_dword <<= 5;
  156.     dv_header.apt = i_dword >> (32 - 3);
  157.     i_dword <<= 3;
  158.     dv_header.tf1 = i_dword >> (32 - 1);
  159.     i_dword <<= 5;
  160.     dv_header.ap1 = i_dword >> (32 - 3);
  161.     i_dword <<= 3;
  162.     dv_header.tf2 = i_dword >> (32 - 1);
  163.     i_dword <<= 5;
  164.     dv_header.ap2 = i_dword >> (32 - 3);
  165.     i_dword <<= 3;
  166.     dv_header.tf3 = i_dword >> (32 - 1);
  167.     i_dword <<= 5;
  168.     dv_header.ap3 = i_dword >> (32 - 3);
  169.     p_peek += 72;                                  /* skip rest of DIF block */
  170.     /* Set p_input field */
  171.     p_demux->pf_demux   = Demux;
  172.     p_demux->pf_control = Control;
  173.     p_demux->p_sys      = p_sys = malloc( sizeof( demux_sys_t ) );
  174.     if( !p_sys )
  175.         return VLC_ENOMEM;
  176.     p_sys->b_hurry_up = var_CreateGetBool( p_demux, "rawdv-hurry-up" );
  177.     msg_Dbg( p_demux, "Realtime DV Source: %s", (p_sys->b_hurry_up)?"Yes":"No" );
  178.     p_sys->i_dsf = dv_header.dsf;
  179.     p_sys->frame_size = dv_header.dsf ? 12 * 150 * 80 : 10 * 150 * 80;
  180.     p_sys->f_rate = dv_header.dsf ? 25 : 29.97;
  181.     p_sys->i_pcr = 1;
  182.     p_sys->p_es_video = NULL;
  183.     p_sys->p_es_audio = NULL;
  184.     p_sys->i_bitrate = 0;
  185.     es_format_Init( &p_sys->fmt_video, VIDEO_ES, VLC_FOURCC('d','v','s','d') );
  186.     p_sys->fmt_video.video.i_width = 720;
  187.     p_sys->fmt_video.video.i_height= dv_header.dsf ? 576 : 480;;
  188.     /* FIXME FIXME */
  189. #if 0
  190.     /* necessary because input_SplitBuffer() will only get
  191.      * INPUT_DEFAULT_BUFSIZE bytes at a time. */
  192.     p_input->i_bufsize = p_sys->frame_size;
  193. #endif
  194.     p_sys->p_es_video = es_out_Add( p_demux->out, &p_sys->fmt_video );
  195.     /* Audio stuff */
  196.     p_peek = p_peek_backup + 80*6+80*16*3 + 3; /* beginning of AAUX pack */
  197.     if( *p_peek == 0x50 )
  198.     {
  199.         es_format_Init( &p_sys->fmt_audio, AUDIO_ES,
  200.                         VLC_FOURCC('a','r','a','w') );
  201.         p_sys->fmt_audio.audio.i_channels = 2;
  202.         switch( (p_peek[4] >> 3) & 0x07 )
  203.         {
  204.         case 0:
  205.             p_sys->fmt_audio.audio.i_rate = 48000;
  206.             break;
  207.         case 1:
  208.             p_sys->fmt_audio.audio.i_rate = 44100;
  209.             break;
  210.         case 2:
  211.         default:
  212.             p_sys->fmt_audio.audio.i_rate = 32000;
  213.             break;
  214.         }
  215.         /* 12 bits non-linear will be converted to 16 bits linear */
  216.         p_sys->fmt_audio.audio.i_bitspersample = 16;
  217.         p_sys->p_es_audio = es_out_Add( p_demux->out, &p_sys->fmt_audio );
  218.     }
  219.     return VLC_SUCCESS;
  220. }
  221. /*****************************************************************************
  222.  * Close: frees unused data
  223.  *****************************************************************************/
  224. static void Close( vlc_object_t *p_this )
  225. {
  226.     demux_t     *p_demux = (demux_t*)p_this;
  227.     demux_sys_t *p_sys  = p_demux->p_sys;
  228.     var_Destroy( p_demux, "rawdv-hurry-up");
  229.     free( p_sys );
  230. }
  231. /*****************************************************************************
  232.  * Demux: reads and demuxes data packets
  233.  *****************************************************************************
  234.  * Returns -1 in case of error, 0 in case of EOF, 1 otherwise
  235.  *****************************************************************************/
  236. static int Demux( demux_t *p_demux )
  237. {
  238.     demux_sys_t *p_sys  = p_demux->p_sys;
  239.     block_t     *p_block;
  240.     bool  b_audio = false;
  241.     if( p_sys->b_hurry_up )
  242.     {
  243.          /* 3 frames */
  244.         p_sys->i_pcr = mdate() + (p_sys->i_dsf ? 120000 : 90000);
  245.     }
  246.     /* Call the pace control */
  247.     es_out_Control( p_demux->out, ES_OUT_SET_PCR, p_sys->i_pcr );
  248.     p_block = stream_Block( p_demux->s, p_sys->frame_size );
  249.     if( p_block == NULL )
  250.     {
  251.         /* EOF */
  252.         return 0;
  253.     }
  254.     if( p_sys->p_es_audio )
  255.     {
  256.         es_out_Control( p_demux->out, ES_OUT_GET_ES_STATE,
  257.                         p_sys->p_es_audio, &b_audio );
  258.     }
  259.     p_block->i_dts =
  260.     p_block->i_pts = p_sys->i_pcr;
  261.     if( b_audio )
  262.     {
  263.         block_t *p_audio_block = dv_extract_audio( p_demux, p_block );
  264.         if( p_audio_block )
  265.         {
  266.             p_audio_block->i_pts =
  267.             p_audio_block->i_dts = p_sys->i_pcr;
  268.             es_out_Send( p_demux->out, p_sys->p_es_audio, p_audio_block );
  269.         }
  270.     }
  271.     es_out_Send( p_demux->out, p_sys->p_es_video, p_block );
  272.     if( !p_sys->b_hurry_up )
  273.     {
  274.         p_sys->i_pcr += ( INT64_C(1000000) / p_sys->f_rate );
  275.     }
  276.     return 1;
  277. }
  278. /*****************************************************************************
  279.  * Control:
  280.  *****************************************************************************/
  281. static int Control( demux_t *p_demux, int i_query, va_list args )
  282. {
  283.     demux_sys_t *p_sys  = p_demux->p_sys;
  284.     /* XXX: DEMUX_SET_TIME is precise here */
  285.     return demux_vaControlHelper( p_demux->s,
  286.                                    0, -1,
  287.                                    p_sys->frame_size * p_sys->f_rate * 8,
  288.                                    p_sys->frame_size, i_query, args );
  289. }
  290. static const uint16_t dv_audio_shuffle525[10][9] = {
  291.   {  0, 30, 60, 20, 50, 80, 10, 40, 70 }, /* 1st channel */
  292.   {  6, 36, 66, 26, 56, 86, 16, 46, 76 },
  293.   { 12, 42, 72,  2, 32, 62, 22, 52, 82 },
  294.   { 18, 48, 78,  8, 38, 68, 28, 58, 88 },
  295.   { 24, 54, 84, 14, 44, 74,  4, 34, 64 },
  296.   {  1, 31, 61, 21, 51, 81, 11, 41, 71 }, /* 2nd channel */
  297.   {  7, 37, 67, 27, 57, 87, 17, 47, 77 },
  298.   { 13, 43, 73,  3, 33, 63, 23, 53, 83 },
  299.   { 19, 49, 79,  9, 39, 69, 29, 59, 89 },
  300.   { 25, 55, 85, 15, 45, 75,  5, 35, 65 },
  301. };
  302. static const uint16_t dv_audio_shuffle625[12][9] = {
  303.   {   0,  36,  72,  26,  62,  98,  16,  52,  88}, /* 1st channel */
  304.   {   6,  42,  78,  32,  68, 104,  22,  58,  94},
  305.   {  12,  48,  84,   2,  38,  74,  28,  64, 100},
  306.   {  18,  54,  90,   8,  44,  80,  34,  70, 106},
  307.   {  24,  60,  96,  14,  50,  86,   4,  40,  76},
  308.   {  30,  66, 102,  20,  56,  92,  10,  46,  82},
  309.   {   1,  37,  73,  27,  63,  99,  17,  53,  89}, /* 2nd channel */
  310.   {   7,  43,  79,  33,  69, 105,  23,  59,  95},
  311.   {  13,  49,  85,   3,  39,  75,  29,  65, 101},
  312.   {  19,  55,  91,   9,  45,  81,  35,  71, 107},
  313.   {  25,  61,  97,  15,  51,  87,   5,  41,  77},
  314.   {  31,  67, 103,  21,  57,  93,  11,  47,  83},
  315. };
  316. static inline uint16_t dv_audio_12to16( uint16_t sample )
  317. {
  318.     uint16_t shift, result;
  319.     sample = (sample < 0x800) ? sample : sample | 0xf000;
  320.     shift = (sample & 0xf00) >> 8;
  321.     if (shift < 0x2 || shift > 0xd) {
  322.         result = sample;
  323.     } else if (shift < 0x8) {
  324.         shift--;
  325.         result = (sample - (256 * shift)) << shift;
  326.     } else {
  327.         shift = 0xe - shift;
  328.         result = ((sample + ((256 * shift) + 1)) << shift) - 1;
  329.     }
  330.     return result;
  331. }
  332. static block_t *dv_extract_audio( demux_t *p_demux,
  333.                                   block_t* p_frame_block )
  334. {
  335.     demux_sys_t *p_sys  = p_demux->p_sys;
  336.     block_t *p_block;
  337.     uint8_t *p_frame, *p_buf;
  338.     int i_audio_quant, i_samples, i_size, i_half_ch;
  339.     const uint16_t (*audio_shuffle)[9];
  340.     int i, j, d, of;
  341.     uint16_t lc;
  342.     /* Beginning of AAUX pack */
  343.     p_buf = p_frame_block->p_buffer + 80*6+80*16*3 + 3;
  344.     if( *p_buf != 0x50 ) return NULL;
  345.     i_audio_quant = p_buf[4] & 0x07; /* 0 - 16bit, 1 - 12bit */
  346.     if( i_audio_quant > 1 )
  347.     {
  348.         msg_Dbg( p_demux, "unsupported quantization for DV audio");
  349.         return NULL;
  350.     }
  351.     i_samples = p_buf[1] & 0x3f; /* samples in this frame - min samples */
  352.     switch( (p_buf[4] >> 3) & 0x07 )
  353.     {
  354.     case 0:
  355.         i_size = p_sys->i_dsf ? 1896 : 1580;
  356.         break;
  357.     case 1:
  358.         i_size = p_sys->i_dsf ? 1742 : 1452;
  359.         break;
  360.     case 2:
  361.     default:
  362.         i_size = p_sys->i_dsf ? 1264 : 1053;
  363.         break;
  364.     }
  365.     i_size = (i_size + i_samples) * 4; /* 2ch, 2bytes */
  366.     p_block = block_New( p_demux, i_size );
  367.     /* for each DIF segment */
  368.     p_frame = p_frame_block->p_buffer;
  369.     audio_shuffle = p_sys->i_dsf ? dv_audio_shuffle625 : dv_audio_shuffle525;
  370.     i_half_ch = (p_sys->i_dsf ? 12 : 10)/2;
  371.     for( i = 0; i < (p_sys->i_dsf ? 12 : 10); i++ )
  372.     {
  373.         p_frame += 6 * 80; /* skip DIF segment header */
  374.         if( i_audio_quant == 1 && i == i_half_ch ) break;
  375.         for( j = 0; j < 9; j++ )
  376.         {
  377.             for( d = 8; d < 80; d += 2 )
  378.             {
  379.                 if( i_audio_quant == 0 )
  380.                 {
  381.                     /* 16bit quantization */
  382.                     of = audio_shuffle[i][j] + (d - 8) / 2 *
  383.                            (p_sys->i_dsf ? 108 : 90);
  384.                     if( of * 2 >= i_size ) continue;
  385.                     /* big endian */
  386.                     p_block->p_buffer[of*2] = p_frame[d+1];
  387.                     p_block->p_buffer[of*2+1] = p_frame[d];
  388.                     if( p_block->p_buffer[of*2+1] == 0x80 &&
  389.                         p_block->p_buffer[of*2] == 0x00 )
  390.                         p_block->p_buffer[of*2+1] = 0;
  391.                 }
  392.                 else
  393.                 {
  394.                     /* 12bit quantization */
  395.                     lc = ((uint16_t)p_frame[d] << 4) |
  396.                          ((uint16_t)p_frame[d+2] >> 4);
  397.                     lc = (lc == 0x800 ? 0 : dv_audio_12to16(lc));
  398.                     of = audio_shuffle[i][j] + (d - 8) / 3 *
  399.                          (p_sys->i_dsf ? 108 : 90);
  400.                     if( of*2 >= i_size ) continue;
  401.                     /* big endian */
  402.                     p_block->p_buffer[of*2] = lc & 0xff;
  403.                     p_block->p_buffer[of*2+1] = lc >> 8;
  404.                     ++d;
  405.                 }
  406.             }
  407.             p_frame += 16 * 80; /* 15 Video DIFs + 1 Audio DIF */
  408.         }
  409.     }
  410.     return p_block;
  411. }