PullResizeSH.h

Go to the documentation of this file.

/* copyright (C) 2003 Jens Zechlin */
#ifndef PullResizeSH_SH
#define PullResizeSH_SH

#include <sys/types.h>
#include <limits.h>
#include "config.h"

#include "sh/SH.h"
#include "sh/SHGraphManager.h"
#include "sh/SHEndpoint.h"
#include "sh/SHEndpointSpec.h"

#include "MNRope.h"

 
namespace SH
{

class PullResizeSH;


/**********************************************************************/
/* PullResizeSHEndpoint                                         */
/**********************************************************************/

class PullResizeSourceEndpoint
    : public SourceEndpoint
{
public:
    PullResizeSourceEndpoint( PullResizeSH* mySH );
    virtual SH_RC pull( DataPtr&   item,
                        SourceUnit su = UnitDefault,
                        size_t     amount=0 );

    virtual ~PullResizeSourceEndpoint( );

};

class PullResizeSinkEndpoint
    : public SinkEndpoint
{
public:
    PullResizeSinkEndpoint( PullResizeSH* mySH );
    virtual ~PullResizeSinkEndpoint( );

};

/**********************************************************************/
/* MpeglibSinkSH                                                     */
/**********************************************************************/

class PullResizeSH
    : public Base {
private:
    MNRope *prevRope;
    
public:
    PullResizeSH( SHGraphManager* mgr,
                    u_int32_t       runtimeId,
                    MNSelector&     sel );

    virtual ~PullResizeSH();

private:
    PullResizeSH( const PullResizeSH& );

    PullResizeSH& operator=( const PullResizeSH& );
    
    //int readStartCode(InputStream* input, unsigned int* startCode);
    
    SHGraphManager* myGraphManager;
    int pull( MNRope*& rope, size_t amount );

public:
    virtual SH_RC initSH();
    virtual SH_RC uninitSH();

    virtual SH_RC startStreaming();
    virtual SH_RC stopStreaming();

    virtual void pushReport( Report* report, Direction d );
    

    /******************************************************************/
    /* functions required for SH::Spec                                */
    /******************************************************************/
protected:
    friend class PullResizeSinkEndpoint;
    friend class PullResizeSourceEndpoint;

    SinkEndpoint*          in_ep_a[1];
    SourceEndpoint*          out_ep_a[1];
    PullResizeSinkEndpoint    inEP;
    PullResizeSourceEndpoint    outEP;

    
public:
    virtual SinkEndpoint**   getSinkSpecs();
    virtual SourceEndpoint** getSourceSpecs();

    /******************************************************************/
    /* functions required for SHStatus                                */
    /******************************************************************/
    virtual bool isConnected() const;
   
};


}; // namespace SH

#endif /* PullResizeSH */

---