RtspPlayer.h

Go to the documentation of this file.

/*
 * Copyright (C) 2000 KOM/Darmstadt University of Technology
 *
 * 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, 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 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 RTSP_PLAYER_H
#define RTSP_PLAYER_H

#include "MNRTSPClient.h"
#include "MNSelector.h"
#include "MNMutex.h"
#include "MNSem.h"
#include "MNThread.h"

class Url;
class MNPipeNotifier;
class PlayerGM;

/***********************************************************************
 * RtspPlayer. 
 * This class can be understood as the interface to mplayer. It refers
 * to RTSP functionality of MNRTSPClient on one hand and to the GraphManager
 * (to control RTP handling) on the other hand.
 ***********************************************************************/

class RtspPlayer : public MNRTSPClient
                 , public MNThread
{
    Url*        _url;
    PlayerGM*   _gm;

    bool        _initialized;
    bool        _open;
    bool        _playing;

    MNMutex     _mutex;
    MNSem       _cond;
    bool        _pending;
    char*       _error_msg;
    bool        _closed;
    int         _ownSessionsSetup;
public:
    RtspPlayer( MNSelector& sel );
    virtual ~RtspPlayer( );

    virtual void run( );

    void call( );
    bool send_describe( const char* url );
    bool send_setup( );
    bool send_play( int from, int to );
    bool send_pause();
    bool send_resume(int pos);
    void call_stop( int pos );
    bool call_close( );
    void call_uninit( );

    bool wait_describe_response( );
    bool wait_setup_response( );
    bool wait_play_response( );
    bool wait_pause_response( );
    bool wait_resume_response( );
    bool wait_stop_response( );

    const char* getLastError() const;

    bool call_set_notify( bool trigger );

    bool is_multiplexed_stream( );
    SDP::PayloadTypes get_internal_pt( );
    SDP::PayloadTypes get_internal_pt( int idx );
    int get_rtp_pt(int idx);

    const char* getConfig(int idx, int pt);

    unsigned int getConfigSize(int idx, int pt);

    unsigned getRate(int idx, int pt);

    unsigned getNumChannels(int idx, int pt);

    int checkBuffer( );
    int fillBuffer( unsigned char* buffer, int length );
    int checkBuffer( int idx);
    int fillBuffer( int idx, unsigned char* buffer, int length );

    bool hasBeenSynchronized(int idx);
    void getPT(int idx, struct timeval& resPT);

    int getSessionsSetup();

    SDP::MNMediaType getMediaType(int idx);

private:
    bool private_open( );

    void finalAnswer( const char* file, int line, const char* text );

protected:
    virtual void init_stage_2( );

    virtual void open_stage_2( );

    virtual void play_stage_2( );

    virtual void pause_stage_2( );

    virtual void stop_stage_2( );

    virtual void init_stage_2_failed( const char* file,
                                      int         line,
                                      const char* text );

    virtual void open_stage_2_failed( const char* file,
                                      int         line,
                                      const char* text );
    
    virtual void play_stage_2_failed( const char* file,
                                      int         line,
                                      const char* text );

    virtual void pause_stage_2_failed( const char* file,
                                       int line,
                                       const char* text);

    virtual void stop_stage_2_failed( const char* file,
                                      int         line,
                                      const char* text );

    virtual void unknown_stage_2( const char* file,
                                  int         line,
                                  const char* text );
};

#endif /* RTSP_PLAYER_H */

---