OStreamReceiver.hh

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.
 */

#ifndef _OSTREAMRECEIVER_H_
#define _OSTREAMRECEIVER_H_

#include <liveMedia.hh>
#include <BasicUsageEnvironment.hh>

#include "OStreamBufferedSink.hh"

typedef enum  {

        ERROR_NORMAL_STATUS = 0,
        ERROR_FAILED_SDP_DESCRIPTION,
        ERROR_FAILED_FILE_SINK_CREATION,
        ERROR_FAILED_TO_CREATE_RECEIVER,
        ERROR_FAILED_CREATE_RTSP_CLIENT,
        ERROR_FAILED_CREATE_MEDIASESSION,
        ERROR_FAILED_SETUP_STREAMS,
        ERROR_UNKOWN_ERROR
} ostream_receiver_error_codes;


class OStreamReceiver
{
public:

        OStreamReceiver( const char* dest_rtsp_url,
                                         on_packet_video_received_cb* f_on_packet_video_received_cb,
                                         const void *video_callback_data,
                                         on_packet_audio_received_cb* f_on_packet_audio_received_cb,
                                         const void *audio_callback_data,
                                         const char* receiving_iface = "0.0.0.0",
                                         unsigned int sink_buffer_size = 200000 );
        
        virtual ~OStreamReceiver();

        int isReadyToStream();
        
        int startReceiving();
        
        void stopReceiving();
        
        static void subsessionAfterPlaying( void* mediaSubSess );
        static void subsessionByeHandler( void* mediaSubSess );
        static void startPlayingStreams( void* OStreamReceiverClassPointer );
        static void checkForPacketArrival(void* OStreamReceiverClassPointer );

private:        // functions

        bool createRTSPClient();
        
        bool createMediaSession();
        
        int getSDPDescriptionFromURL( char const* url );
        
        void setupStreams();
        
        bool clientStartPlayingSession();
        bool clientSetupSubsession( void* mediaSubSess );
        void closeMediaSinks();
        
        void shutdown();

        on_packet_video_received_cb* f_on_packet_video_received_cb;
        
        on_packet_audio_received_cb* f_on_packet_audio_received_cb;

private:        // data

        int _error_status;
        
        double _end_time;
        
        char* _sdp_description;
        
        const char* _client_protocol_name;
        
        char _watch_variable;
        
        unsigned int _sink_buffer_size;
        
        const void *_callback_video_data_client;
        
        const void *_callback_audio_data_client;
        
        char *_receiving_iface;

        UsageEnvironment* _env;
        TaskScheduler* _scheduler;
        RTSPClient* _rtsp_client;
        TaskToken _arrival_check_timer_task;
        
        MediaSession* _media_session;
};


#endif  //_OSTREAMRECEIVER_H_

---