LCRTPFileRecorderGM.h

Go to the documentation of this file.

/* Copyright (C) 2000 KOM/Darmstadt University of Technology
 *
 * You are allowed to use all other parts of the code under the following terms:
 *
 * For non-commercial use, code may be used in unmodified form provided
 * that this copyright notice and this permission notice appear in
 * supporting documentation.
 *
 * This software is provided "as is" and without any express or implied
 * warranties, including, without limitation, the implied warranty of
 * fitness for a particular purpose.
 *
 * The code may be subjected to the GNU General Public License, Version 2,
 * and re-distributed under the terms of this license.
 * As a special exception, permission is granted to link this code
 * with the Qt library and distribute executables, as long as you
 * follow the requirements of the GNU GPL in regard to all of the
 * software in the executable aside from Qt.
 *
 * Commercial use other than under the terms of the GNU General Public
 * License is allowed only after express negotiation of conditions
 * with the authors.
 */
#ifndef MN_LCRTPFileRecorderGM_H
#define MN_LCRTPFileRecorderGM_H

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

#include "ServerGM.h"
#include "MNFileSinkSH.h"
#include "MNSem.h"
#include "MNMutex.h"
#include "MNRTPutildefs.h"
 
namespace SH
{
    class Base;
    class RTPDecoderSH;
    class FileSinkSH;
};
 
class LCRTPFileRecorderGM : public ServerGM
{
    struct timeval* _tv;
 
    SH::FileSinkSH*     _fsh;
    SH::RTPDecoderSH* _dsh;
    SH::Base*           _ssh;
 
    MediaState _streamer_state;
    MNSem      _eof_sig;
    MNMutex    _eof_lock;  
    MNString   _server;
 
    // int _LocalPortUp;
    MNSocket*    _local_upstream_rtp;
    MNSocket*    _local_upstream_rtcp;
    int          _DistantPortUp;

public:
    LCRTPFileRecorderGM( GMUser* user, MNSelector& sel );
 
    virtual ~LCRTPFileRecorderGM();
 
    virtual void init(int idx);

    virtual void uninit();
 
    virtual void start();

    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 bool graphManNotify( int idx, 
                                 SH::Base* caller,
                                 SH::Notification attribute,
                                 void* msg );
private:
    virtual int start_streamer( int idx, int bandwidth );

public:
    virtual int open_file( int idx,
                           const char*       name,
                           int               rtp_pt,
                           SDP::PayloadTypes int_pt,
                           u_int32           bandwidth,
                           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_repeat_times( u_int32 lc_max_loop );

    void set_listpacket_timeout( u_int32 secs );

    void set_endpacket_timeout( u_int32 secs );
}; 


#endif /* MN_LCRTPFileRecorderGM_H */

---