DynMultiplierSH.h

Go to the documentation of this file.

#ifndef DYN_MULTIPLIER_SH_H
#define DYN_MULTIPLIER_SH_H

#include <sys/types.h>
#include <list>

#include "SH.h"
#include "SHEndpoint.h"
#include "SHEndpointSpec.h"
#include "var_type.h"

class MNRTP;
class MNUDPSocket;
class MNRTPCodecBase;
class MNRope;

namespace SH
{

class DynMultiplierSH;
class DynMultiplierSinkEndpointSpec;
class DynMultiplierSourceEndpointSpec;
class DynMultiplierSinkEndpoint;
class DynMultiplierSourceEndpoint;

/**********************************************************************/
/* DynMultiplierSinkEndpoint                                     */
/**********************************************************************/

class DynMultiplierSinkEndpoint
    : public SinkEndpoint
{
public:
    DynMultiplierSinkEndpoint( DynMultiplierSH* mySH );
    virtual ~DynMultiplierSinkEndpoint( );

    virtual SH_RC push( DataPtr item );

    DynMultiplierSH* dsh();
};

/**********************************************************************/
/* DynMultiplierSourceEndpoint                                         */
/**********************************************************************/

class DynMultiplierSourceEndpoint
    : public SourceEndpoint
{
public:
    DynMultiplierSourceEndpoint( DynMultiplierSH* mySH );
    virtual ~DynMultiplierSourceEndpoint( );

    virtual SH_RC pull( DataPtr& item,
                        SourceUnit su = UnitDefault,
                        size_t amount = 0 );

    DynMultiplierSH* dsh();
};

/**********************************************************************/
/* DynMultiplierSH                                                    */
/**********************************************************************/

class DynMultiplierSH
    : public Base
{

public:
    SH_RC push_decode( DataPtr  item );
    SH_RC pull_decode( DataPtr& item );

public:
    DynMultiplierSH( SHGraphManager* mgr,
                        u_int32_t       runtimeId,
                        MNSelector&     sel );

private:

    DynMultiplierSH( const DynMultiplierSH& );

    DynMultiplierSH& operator=( const DynMultiplierSH& );
    void increaseNumberOfSourceEndpoints();
    void decreaseNumberOfSourceEndpoints();

    /******************************************************************/
    /* functions required for Status                                  */
    /******************************************************************/
protected:
    friend class DynMultiplierSinkEndpoint;
    friend class DynMultiplierSourceEndpoint;

    virtual void pushReport( ReportPtr report, Direction d );

    //SinkEndpoint*                    _in_ep_a[1];
    //SourceEndpoint*                  _out_ep_a[2];
    //DynMultiplierSinkEndpoint   _inEP;
    //DynMultiplierSourceEndpoint _outEP1;
    //DynMultiplierSourceEndpoint _outEP2;
    
    SinkEndpoint*                               _in_ep_a[1];
    SourceEndpoint**                            _out_ep_a;
    DynMultiplierSinkEndpoint                   _inEP;
    std::list<DynMultiplierSourceEndpoint*>     _outEPList;
    
    int _numSources;
    

public:
    virtual SinkEndpoint**   getSinkSpecs();
    virtual SourceEndpoint** getSourceSpecs();
    
    virtual bool isConnected() const  ;
    
    int getConnectedCount();
    
    bool unmatch(SH::Base* sh);
};


}; // namespace SH

#endif /* DYN_MULTIPLIER_SH_H*/

---