ClientSideReflectorGM.h

Go to the documentation of this file.

#ifndef CLIENTSIDEREFLECTORGM_H
#define CLIENTSIDEREFLECTORGM_H

#include "ServerGM.h"
#include "MNRTPSinkSH.h"
#include "MNString.h"
#include "MNRTPutildefs.h"
#include "ServerSideReflectorGM.h"
#include <vector>

class ClientSideReflectorGM : public ServerGM
{
private:
    ServerSideReflectorGM* _serverSideReflectorGM;
    struct Subsession
    {
        
        SH::RTPSinkSH* _rtpSinkSH;
        
        MNSocket* _localDownRTP;
        MNSocket* _localDownRTCP;
        MNSocket* _localUpRTP;
        MNSocket* _localUpRTCP;
        int _distantPortDown;
        int _distantPortUp;
    };
    std::vector<Subsession*> _subsessions;
    
    MediaState _state;
    MNString _server;
    MNString _client;
    MNString _url;
    
    
    
    
public:
    ClientSideReflectorGM( GMUser*              user,
                           MNSelector&          sel,
                           MNString&            url,
                           RTSP::TransportTypes requested_transport = RTSP::RTP_AVP_UDP );

    virtual ~ClientSideReflectorGM();
    virtual void init(int idx);
    void addSubsession();
    void attachToServerSideReflectorGM(int idx);
    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 int open_file( int idx, 
                           const char*       name,
                           int               rtp_pt,
                           SDP::PayloadTypes int_pt,
                           u_int32_t         bw,
                           SDP::RetransTypes int_rt,
                           int               packetsize );
                           
    void setupForNewSession(int idx, u_int32_t bw);
    
    void setupForExistingSession(int idx);
    virtual bool graphManNotify( int idx, SH::Base* caller, SH::Notification attribute, void* msg );
    

    virtual void uninit();
    virtual void start();
    virtual int play( int startp, int stopp );
    virtual int stop( );
    void detach();
    virtual int pause( );
    virtual int jump ( long pos );
    
    virtual void setNptSeek(int npt);
    virtual int  getNptSeconds();
    
    virtual void setRTPTimestamp(int idx, u_int32 rtptime);

private:
    static void deleteSubsession(Subsession* subsession);
    static void uninitSubsession(Subsession* subsession);
    static void startSubsession(Subsession* subsession);
    static void stopSubsession(Subsession* subsession);
    virtual int start_streamer(int idx, int bandwidth );
    void unmatchAllSubsessions();
    
    ClientSideReflectorGM(const ClientSideReflectorGM& gm);
    ClientSideReflectorGM& operator=(const ClientSideReflectorGM& gm);
};

#endif

---