NopSourceSH.h

Go to the documentation of this file.

/* Copyright (C) 2002 Carsten Griwodz
 *
 * You are allowed to use all other parts of the code under the following terms:
 *
 * For non-commercial use, this code may be used in unmodified form
 * provided that this copyright notice and this permission notice appear
 * in supporting documentation.
 *
 * The code may be made subject to the terms of the GNU General Public
 * License, Version 2, and re-distributed under the terms of this license.
 *
 * Commercial use other than under the terms of the GNU General Public
 * License is allowed only after negotiation of conditions with the authors.
 */
#ifndef NOP_SOURCE_STREAM_HANDLER_H
#define NOP_SOURCE_STREAM_HANDLER_H

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

#include "MNTimeval.h"
#include "MNValid.h"
#include "SH.h"
#include "SHEndpoint.h"
#include "SHEndpointSpec.h"
#include "DummyList.h"
#include "var_type.h"

class MNRope;

namespace SH
{

class NopSourceSH;

/**********************************************************************/
/* NopSourceEndpoint                                                 */
/**********************************************************************/

class NopSourceEndpoint
    : public SourceEndpoint
{
public:
    NopSourceEndpoint( NopSourceSH* mySH );
    virtual ~NopSourceEndpoint( );

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

    NopSourceSH* fsh();
};

/**********************************************************************/
/* NopSourceSH                                                       */
/**********************************************************************/

class NopSourceSH
    : public Base
{
public:
    NopSourceSH( SHGraphManager* mgr,
                 u_int32_t       runtimeId,
                 MNSelector&     sel); 

private:

    NopSourceSH( const NopSourceSH& );

    NopSourceSH& operator=( const NopSourceSH& );

public:
    SH_RC pull( DataPtr&   item,
                SourceUnit su,
                size_t     amount );

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

    SourceEndpoint*          _out_ep_a[1];
    NopSourceEndpoint _outEP;

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

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

private:
    u_int32_t _blk_sz;      
    u_int32_t _cnt;         

private:
    void inc_cnt( );
};


}; // namespace SH

#endif /* NOP_SOURCE_STREAM_HANDLER_H */

---