TranscodingGM.h

Go to the documentation of this file.

/* Copyright (C) 2002 Jens Zechlin */


#ifndef MN_TranscodingGM_H
#define MN_TranscodingGM_H

#include <sys/types.h>
#include "var_type.h"

#include "MNSem.h"
#include "MNMutex.h"

#include "MNRTPutildefs.h"

#include "ServerGM.h"
#include "SubGraphSH.h"
#include "PullResizeSH.h"
#include "SubGraphFactory.h"

namespace SH
{
    class PushPullSH;
    class RTPDecoderSH;
    class RTPEncoderSH;
    class RTPSourceSH;
    class RTPSinkSH;
    class SubGraphSH;
    class PullResizeSH;
};

class TranscodingGM : public ServerGM{
    
    
    
    class SelectorThread : public MNThread, public MNSelector{
        bool _running;  
    public:    
        SelectorThread();
        ~SelectorThread();
        void run();
        void stop();
    };

   // struct timeval* _tv;
 
    SH::RTPSourceSH*    rtpSourceSH;         // SH* 
    SH::RTPDecoderSH*   decoderSH;
    SH::PushPullSH*     preBufferSH;
    
    //SH::MpegSysDemuxSH*      mpegSysDemuxSH;
    SH::SubGraphSH*         subGraphSH;
    SubGraphFactory     subGraphFactory;
    
    SH::PushPullSH*     postBufferSH;
    SH::PullResizeSH*   pullResizeSH;
    SH::RTPEncoderSH*   encoderSH;
    SH::RTPSinkSH*      rtpSinkSH;

    MediaState          streamer_state;
    MNSem               eof_sig;
    MNMutex             eof_lock;  
    
    SelectorThread      rtpEncThread;
    SelectorThread      subGraphThread;
    
    MNString            client; 
    MNString            server;

    MNSocket*           local_down_rtp;
    MNSocket*           local_down_rtcp;
    MNSocket*           local_up_rtp;
    MNSocket*           local_up_rtcp;
    int                 DistantPortDown;
    int                 DistantPortUp;
    bool                initialized;
    int                 requested_transport;
    bool                runningEmpty;
    bool                gotEOF;
    MNTimer _timer;

public:
    TranscodingGM( GMUser* user, MNSelector& sel, RTSP::TransportTypes _requested_transport = RTSP::RTP_AVP_UDP );
    virtual ~TranscodingGM();
 
    virtual void init(int idx);
    virtual void uninit();
    virtual void set_hostnames( const MNString& Client, const MNString& Server );
    virtual void set_ports( int idx, 
                            MNSocket*    locDownRtp,
                            MNSocket*    locDownRtcp,
                            int          distDown,
                            MNSocket*    locUpRtp,
                            MNSocket*    locUpRtcp,
                            int          distUp );
    virtual void start();
    virtual bool graphManNotify( int idx, SH::Base* caller, SH::Notification attribute, void* msg );
    virtual bool synchronousGet( GetValue what, u_int32& outVar );
private:
    virtual int start_streamer( int /*idx*/, int /*bandwidth*/){
        return 0;
    }
    

public:
    virtual int open_file( int idx,
                           const char* name ,
                           int rtp_pt,
                           SDP::PayloadTypes int_pt,
                           u_int32 bw,
                           SDP::RetransTypes int_rt,
                           int packetsize );
    virtual int play( int startp, int stopp );
    virtual int stop( );
    virtual int pause( );
    virtual int jump ( long pos );
    void set_write_to_file( bool yes );
}; 


#endif /* MN_LCRTPFileRecorderGM_H */

---