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

midi

开发平台:

Unix_Linux

  1. /*****************************************************************************
  2.  * mpjpeg.c: mime multipart jpeg  muxer module for vlc
  3.  *****************************************************************************
  4.  * Copyright (C) 2001, 2002, 2006 the VideoLAN team
  5.  * $Id: 1511373046365afbf98d7e8e9c8a82055706cc28 $
  6.  *
  7.  * Authors: Sigmund Augdal Helberg <dnumgis@videolan.org>
  8.  *
  9.  * This program is free software; you can redistribute it and/or modify
  10.  * it under the terms of the GNU General Public License as published by
  11.  * the Free Software Foundation; either version 2 of the License, or
  12.  * (at your option) any later version.
  13.  *
  14.  * This program is distributed in the hope that it will be useful,
  15.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  17.  * GNU General Public License for more details.
  18.  *
  19.  * You should have received a copy of the GNU General Public License
  20.  * along with this program; if not, write to the Free Software
  21.  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
  22.  *****************************************************************************/
  23. /*****************************************************************************
  24.  * Preamble
  25.  *****************************************************************************/
  26. #ifdef HAVE_CONFIG_H
  27. # include "config.h"
  28. #endif
  29. #include <vlc_common.h>
  30. #include <vlc_plugin.h>
  31. #include <vlc_sout.h>
  32. #include <vlc_block.h>
  33. /*****************************************************************************
  34.  * Module descriptor
  35.  *****************************************************************************/
  36. static int  Open   ( vlc_object_t * );
  37. static void Close  ( vlc_object_t * );
  38. #define SOUT_CFG_PREFIX "sout-mpjpeg-"
  39. vlc_module_begin ()
  40.     set_shortname( "MPJPEG" )
  41.     set_description( N_("Multipart JPEG muxer") )
  42.     set_capability( "sout mux", 5 )
  43.     add_obsolete_string( SOUT_CFG_PREFIX "separator" )
  44.     set_category( CAT_SOUT )
  45.     set_subcategory( SUBCAT_SOUT_MUX )
  46.     set_callbacks( Open, Close )
  47.     add_shortcut( "mpjpeg" )
  48. vlc_module_end ()
  49. /*****************************************************************************
  50.  * Exported prototypes
  51.  *****************************************************************************/
  52. static int Control  ( sout_mux_t *, int, va_list );
  53. static int AddStream( sout_mux_t *, sout_input_t * );
  54. static int DelStream( sout_mux_t *, sout_input_t * );
  55. static int Mux      ( sout_mux_t * );
  56. /* This pseudo-random sequence is unlikely to ever happen */
  57. /* This should be the same as in src/network/httpd.c */
  58. #define BOUNDARY "7b3cc56e5f51db803f790dad720ed50a"
  59. /*****************************************************************************
  60.  * Open:
  61.  *****************************************************************************/
  62. static int Open( vlc_object_t *p_this )
  63. {
  64.     sout_mux_t *p_mux = (sout_mux_t*)p_this;
  65.     msg_Dbg( p_mux, "Multipart jpeg muxer opened" );
  66.     p_mux->pf_control   = Control;
  67.     p_mux->pf_addstream = AddStream;
  68.     p_mux->pf_delstream = DelStream;
  69.     p_mux->pf_mux       = Mux;
  70.     p_mux->p_sys        = NULL;
  71.     return VLC_SUCCESS;
  72. }
  73. /*****************************************************************************
  74.  * Close:
  75.  *****************************************************************************/
  76. static void Close( vlc_object_t * p_this )
  77. {
  78.     /* TODO: send the ending boundary ("rn--"BOUNDARY"--rn"),
  79.      * but is the access_output still useable?? */
  80.     msg_Dbg( p_this, "Multipart jpeg muxer closed" );
  81. }
  82. static int Control( sout_mux_t *p_mux, int i_query, va_list args )
  83. {
  84.     VLC_UNUSED(p_mux);
  85.     bool *pb_bool;
  86.     char **ppsz;
  87.     switch( i_query )
  88.     {
  89.         case MUX_CAN_ADD_STREAM_WHILE_MUXING:
  90.             pb_bool = (bool*)va_arg( args, bool * );
  91.             *pb_bool = true;
  92.             return VLC_SUCCESS;
  93.         case MUX_GET_ADD_STREAM_WAIT:
  94.             pb_bool = (bool*)va_arg( args, bool * );
  95.             *pb_bool = true;
  96.             return VLC_SUCCESS;
  97.         case MUX_GET_MIME:
  98.             ppsz = (char**)va_arg( args, char ** );
  99.             *ppsz = strdup( "multipart/x-mixed-replace; boundary="BOUNDARY );
  100.             return VLC_SUCCESS;
  101.         default:
  102.             return VLC_EGENERIC;
  103.     }
  104. }
  105. static int AddStream( sout_mux_t *p_mux, sout_input_t *p_input )
  106. {
  107.     if( p_mux->i_nb_inputs > 1 )
  108.     {
  109.         msg_Dbg( p_mux, "only 1 input allowed" );
  110.         return VLC_EGENERIC;
  111.     }
  112.     msg_Dbg( p_mux, "adding input" );
  113.     if( p_input->p_fmt->i_codec != VLC_FOURCC('M','J','P','G') &&
  114.         p_input->p_fmt->i_codec != VLC_FOURCC('m','j','p','g') &&
  115.         p_input->p_fmt->i_codec != VLC_FOURCC('j','p','e','g') &&
  116.         p_input->p_fmt->i_codec != VLC_FOURCC('J','P','E','G') &&
  117.         p_input->p_fmt->i_codec != VLC_FOURCC('J','F','I','F') &&
  118.         p_input->p_fmt->i_codec != VLC_FOURCC('J','P','G','L') &&
  119.         p_input->p_fmt->i_codec != VLC_FOURCC('m','j','p','a') )
  120.     {
  121.         return VLC_EGENERIC;
  122.     }
  123.     return VLC_SUCCESS;
  124. }
  125. static int DelStream( sout_mux_t *p_mux, sout_input_t *p_input )
  126. {
  127.     VLC_UNUSED(p_input);
  128.     msg_Dbg( p_mux, "removing input" );
  129.     return VLC_SUCCESS;
  130. }
  131. static int Mux( sout_mux_t *p_mux )
  132. {
  133.     block_fifo_t *p_fifo;
  134.     if( !p_mux->i_nb_inputs ) return VLC_SUCCESS;
  135.     p_fifo = p_mux->pp_inputs[0]->p_fifo;
  136.     while( block_FifoCount( p_fifo ) > 0 )
  137.     {
  138.         static const char psz_hfmt[] = "rn"
  139.             "--"BOUNDARY"rn"
  140.             "Content-Type: image/jpegrn"
  141.             "Content-Length: %zurn"
  142.             "rn";
  143.         block_t *p_data = block_FifoGet( p_fifo );
  144.         block_t *p_header = block_New( p_mux, sizeof( psz_hfmt ) + 20 );
  145.         if( p_header == NULL ) /* uho! */
  146.         {
  147.             block_Release( p_data );
  148.             continue;
  149.         }
  150.         p_header->i_buffer =
  151.             snprintf( (char *)p_header->p_buffer, p_header->i_buffer,
  152.                       psz_hfmt, p_data->i_buffer );
  153.         p_header->i_flags |= BLOCK_FLAG_HEADER;
  154.         sout_AccessOutWrite( p_mux->p_access, p_header );
  155.         sout_AccessOutWrite( p_mux->p_access, p_data );
  156.     }
  157.     return VLC_SUCCESS;
  158. }