* gather: try to gather stream with similar properties (eg mp3), wait for

 next commits to be usable.

modules/stream_out/gather.c

+/*****************************************************************************
+ * gather.c
+ *****************************************************************************
+ * Copyright (C) 2001, 2002 VideoLAN
+ * $Id: gather.c,v 1.1 2003/09/07 20:12:44 fenrir Exp $
+ *
+ * Authors: Laurent Aimar <fenrir@via.ecp.fr>
+ *
+ * This program 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.
+ *
+ * This program 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 this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111, USA.
+ *****************************************************************************/
+
+/*****************************************************************************
+ * Preamble
+ *****************************************************************************/
+#include <stdlib.h>
+
+#include <vlc/vlc.h>
+#include <vlc/input.h>
+#include <vlc/sout.h>
+
+/*****************************************************************************
+ * Module descriptor
+ *****************************************************************************/
+static int      Open    ( vlc_object_t * );
+static void     Close   ( vlc_object_t * );
+
+vlc_module_begin();
+    set_description( _("Gather stream") );
+    set_capability( "sout stream", 50 );
+    add_shortcut( "gather" );
+    set_callbacks( Open, Close );
+vlc_module_end();
+
+/*****************************************************************************
+ * Exported prototypes
+ *****************************************************************************/
+static sout_stream_id_t *Add ( sout_stream_t *, sout_format_t * );
+static int               Del ( sout_stream_t *, sout_stream_id_t * );
+static int               Send( sout_stream_t *, sout_stream_id_t *, sout_buffer_t* );
+
+struct sout_stream_id_t
+{
+    vlc_bool_t    b_used;
+
+    sout_format_t fmt;
+    void          *id;
+};
+
+struct sout_stream_sys_t
+{
+    sout_stream_t   *p_out;
+
+    int              i_id;
+    sout_stream_id_t **id;
+};
+
+/*****************************************************************************
+ * Open:
+ *****************************************************************************/
+static int Open( vlc_object_t *p_this )
+{
+    sout_stream_t     *p_stream = (sout_stream_t*)p_this;
+    sout_stream_sys_t *p_sys;
+
+    p_stream->p_sys     = p_sys = malloc( sizeof( sout_stream_sys_t ) );
+    p_sys->p_out        = sout_stream_new( p_stream->p_sout, p_stream->psz_next );
+    if( p_sys->p_out == NULL )
+    {
+        free( p_sys );
+        return VLC_EGENERIC;
+    }
+    p_sys->i_id         = 0;
+    p_sys->id           = NULL;
+
+    p_stream->pf_add    = Add;
+    p_stream->pf_del    = Del;
+    p_stream->pf_send   = Send;
+
+    return VLC_SUCCESS;
+}
+
+/*****************************************************************************
+ * Close:
+ *****************************************************************************/
+static void Close( vlc_object_t * p_this )
+{
+    sout_stream_t     *p_stream = (sout_stream_t*)p_this;
+    sout_stream_sys_t *p_sys = p_stream->p_sys;
+    int i;
+
+    for( i = 0; i < p_sys->i_id; i++ )
+    {
+        p_sys->p_out->pf_del( p_sys->p_out, p_sys->id[i]->id );
+        free( p_sys->id[i] );
+    }
+    free( p_sys->id );
+
+    sout_stream_delete( p_sys->p_out );
+    free( p_sys );
+}
+
+/*****************************************************************************
+ * Add:
+ *****************************************************************************/
+static sout_stream_id_t * Add( sout_stream_t *p_stream, sout_format_t *p_fmt )
+{
+    sout_stream_sys_t *p_sys = p_stream->p_sys;
+    sout_stream_id_t  *id;
+    int i;
+
+    /* search a output compatible */
+    for( i = 0; i < p_sys->i_id; i++ )
+    {
+        id = p_sys->id[i];
+        if( !id->b_used &&
+            id->fmt.i_cat == p_fmt->i_cat &&
+            id->fmt.i_fourcc == p_fmt->i_fourcc &&
+            ( ( id->fmt.i_cat == AUDIO_ES &&
+                id->fmt.i_sample_rate == p_fmt->i_sample_rate &&
+                id->fmt.i_channels == p_fmt->i_channels &&
+                id->fmt.i_block_align == p_fmt->i_block_align ) ||
+              ( id->fmt.i_cat == VIDEO_ES &&
+                id->fmt.i_width == p_fmt->i_width &&
+                id->fmt.i_height == p_fmt->i_height ) ) )
+        {
+            msg_Dbg( p_stream, "reusing already opened output" );
+            id->b_used = VLC_TRUE;
+            return id;
+        }
+    }
+
+    /* destroy all output of the same categorie */
+    for( i = 0; i < p_sys->i_id; i++ )
+    {
+        id = p_sys->id[i];
+        if( !id->b_used && id->fmt.i_cat == p_fmt->i_cat )
+        {
+            TAB_REMOVE( p_sys->i_id, p_sys->id, id );
+            p_sys->p_out->pf_del( p_sys->p_out, id );
+            free( id );
+
+            i = 0;
+            continue;
+        }
+    }
+
+    id = malloc( sizeof( sout_stream_id_t ) );
+    msg_Dbg( p_stream, "creating new output" );
+    memcpy( &id->fmt, p_fmt, sizeof( sout_format_t ) );
+    id->fmt.i_extra_data = 0;
+    id->fmt.p_extra_data = NULL;
+    id->b_used           = VLC_TRUE;
+    id->id               = p_sys->p_out->pf_add( p_sys->p_out, p_fmt );
+    if( id->id == NULL )
+    {
+        free( id );
+        return NULL;
+    }
+    TAB_APPEND( p_sys->i_id, p_sys->id, id );
+
+    return id;
+}
+
+/*****************************************************************************
+ * Del:
+ *****************************************************************************/
+static int Del( sout_stream_t *p_stream, sout_stream_id_t *id )
+{
+    id->b_used = VLC_FALSE;
+    return VLC_SUCCESS;
+}
+
+/*****************************************************************************
+ * Send:
+ *****************************************************************************/
+static int Send( sout_stream_t *p_stream,
+                 sout_stream_id_t *id, sout_buffer_t *p_buffer )
+{
+    sout_stream_sys_t *p_sys = p_stream->p_sys;
+
+    return p_sys->p_out->pf_send( p_sys->p_out, id->id, p_buffer );
+}
+