OStreamOnDemandSMS.cpp

Go to the documentation of this file.

/*
 *  Copyright (C) Massimo Cora' 2006 <maxcvs@email.it>
 *
 *  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 Library 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-1307, USA.
 */


#include "OStreamOnDemandSMS.hh"



OStreamOnDemandSMS::OStreamOnDemandSMS( UsageEnvironment& env, bool reuseFirstSource, 
                                                                           BaseInputVideo *input_video,
                                                                           int encoding_type,
                                                                           int audio_port,
                                                                           int stream_id ) 
                                   : OnDemandServerMediaSubsession( env, reuseFirstSource ),
                                        _encoding_type( encoding_type ),
                                        _input_video( input_video ),
                                        _stream_id( stream_id ),
                                        _audio_port( audio_port )
{
        
}

OStreamOnDemandSMS *
OStreamOnDemandSMS::createNew( UsageEnvironment& env, bool reuseFirstSource, BaseInputVideo *input_video,
                                                           int audio_port, int encoding_type, int stream_id /* = 0 */ ) 
{
        return new OStreamOnDemandSMS( env, reuseFirstSource, input_video, audio_port, encoding_type, stream_id );
}

OStreamOnDemandSMS::~OStreamOnDemandSMS()
{
        DEBUG_PRINT ("deletion!!!!!! OStreamOnDemandSMS::~OStreamOnDemandSMS()");
        // WARNING !
        // _rtp_sink_inst and _video_source_inst will be responsible of their destroying
}

FramedSource* OStreamOnDemandSMS::createNewStreamSource( unsigned /*clientSessionId*/,
                                                                                                                                         unsigned& estBitrate ) 
{
        FramedSource *framed_source;
        estBitrate = 64; // kbps, estimate

        
        
        switch ( _encoding_type ) {
                case OSTREAM_ENCODING_MJPEG:
                        framed_source = MJPEGVideoSource::createNew( envir(), _input_video, _stream_id );
                        break;
                
                case OSTREAM_ENCODING_H263P:
                        framed_source = H263plusVideoSource::createNew( envir(), _input_video, _stream_id );
                        break;
                
                case OSTREAM_ENCODING_MP3:
                        {
//                              FramedSource *as_mp3 = MP3FileSource::createNew( envir(), "/mnt/win/tmp/test.mp3");
//                              FramedSource *as_mp3 = MP3FileSource::createNew( envir(), "e:\\tmp\\test.mp3");

                                // grab from microphone
                                FramedSource *as_pcm = AudioInputDevice::createNew( envir(), _audio_port, 16, 2, 44100, 20);
                                FramedSource *as_mp3 = MP3FromPCM::createNew( envir(), as_pcm );
#ifdef STREAM_USING_MP3_ADU
                                FramedSource *as_adu = ADUFromMP3Source::createNew( envir(), as_mp3 );
                                framed_source = as_adu;
#else
                                framed_source = as_mp3;
#endif
                        }
                        break;

                default:
                        framed_source = NULL;
                        break;
        }
        
        return framed_source;
}
  

//--------------------------------------------------------------------------
//

RTPSink* OStreamOnDemandSMS::createNewRTPSink(Groupsock* rtpGroupsock,
                                    unsigned char rtpPayloadTypeIfDynamic,
                                        FramedSource* inputSource) 
{
        RTPSink* rtp_sink;
        // ugly but we need rtpGroupsock, which we cannot have outsite OStreamOnDemandSMS
        switch ( _encoding_type ) {
                case OSTREAM_ENCODING_MJPEG:
                        DEBUG_PRINT("case OSTREAM_ENCODING_MJPEG:\n");
                        rtp_sink = JPEGVideoRTPSink::createNew( envir(), rtpGroupsock );
                        break;
                
                case OSTREAM_ENCODING_H263P:
                        DEBUG_PRINT("case OSTREAM_ENCODING_H263P:\n");
                        rtp_sink = H263plusVideoRTPSink::createNew( envir(), rtpGroupsock, 96 );
                        break;

                case OSTREAM_ENCODING_MP3:
                        DEBUG_PRINT("case OSTREAM_ENCODING_MP3\n");
#ifdef STREAM_USING_MP3_ADU
                        rtp_sink = MP3ADURTPSink::createNew( envir(), rtpGroupsock, 97 );
#else
                        rtp_sink = MPEG1or2AudioRTPSink::createNew( envir(), rtpGroupsock );
#endif
                        break;

                default:
                        rtp_sink = NULL;
                        break;
        }
        
        return rtp_sink;
}

---