DummyLayerSourceSH.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 DUMMY_LAYER_SOURCE_STREAM_HANDLER_H
#define DUMMY_LAYER_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 "var_type.h"

class MNRope;

namespace SH
{

class DummyLayerSourceSH;
class DummyListBase;

/**********************************************************************/
/* DummyLayerSourceEndpoint                                                 */
/**********************************************************************/

class DummyLayerSourceEndpoint
    : public SourceEndpoint
{
    DECLARE_VALID

public:
    DummyLayerSourceEndpoint( DummyLayerSourceSH* mySH );
    virtual ~DummyLayerSourceEndpoint( );

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

    DummyLayerSourceSH* fsh();
};

/**********************************************************************/
/* DummyLayerSourceSH                                                       */
/**********************************************************************/

class DummyLayerSourceSH
    : public Base
{
    DECLARE_VALID

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

    virtual ~DummyLayerSourceSH();

    struct DummyHeader
    {
        u_int32_t sequence_number;
            u_int32_t priority;

            DummyHeader( u_int32_t seq, u_int32_t pri );
    };

    SH_RC getPos ( long &pos );

private:

    DummyLayerSourceSH( const DummyLayerSourceSH& );

    DummyLayerSourceSH& operator=( const DummyLayerSourceSH& );

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

    virtual SH_RC startStreaming();

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

    /******************************************************************/
    /* additional attributes for the set() functions                  */
    /******************************************************************/
public:
    SA_FILE_NAME              _filename;
    SA_FILESRC_START_POS      _start_pos;
    SA_FILESRC_STOP_POS       _stop_pos;
    SA_PUSH_PULL_INITIAL_FILL _initial_fill;

    // Attributes haved been moved to SH.h

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

    SourceEndpoint*          _out_ep_a[1];
    DummyLayerSourceEndpoint _outEP;

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

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

private:
    bool      _initialized; 
    u_int64_t _bytes_read;  
    u_int64_t _bytes_sent;  
    u_int32_t _cnt;         
    u_int32_t _null_cnt;    

    u_int32_t _duration;    
    u_int32_t _blk_sz;      
    u_int32_t _bw;          

    DummyListBase* _entries;

private:
    void compress_queue( );

    bool refill_queue( );

    void inc_cnt( );

#ifndef NDEBUG
    void inc_null_cnt( );
#else
    inline void inc_null_cnt( ) const { }
#endif
};


}; // namespace SH

#endif /* DUMMY_LAYER_SOURCE_STREAM_HANDLER_H */

---