DummyLayerSinkSH.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_SINK_SH
#define DUMMY_LAYER_SINK_SH

#include <sys/types.h>

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

namespace SH
{

class DummyLayerSinkSH;
class DummyLayerSinkEndpoint;
class DummyLayerSinkSourceEndpoint;

/**********************************************************************/
/* DummyLayerSinkEndpoint                                           */
/**********************************************************************/

class DummyLayerSinkEndpoint
    : public SinkEndpoint
{
public:
    DummyLayerSinkEndpoint( DummyLayerSinkSH* mySH );
    virtual ~DummyLayerSinkEndpoint( );

    virtual SH_RC push( DataPtr item );

    DummyLayerSinkSH* dsh();
};

/**********************************************************************/
/* DummyLayerSinkSH                                                     */
/**********************************************************************/

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

private:

    DummyLayerSinkSH( const DummyLayerSinkSH& );

    DummyLayerSinkSH& operator=( const DummyLayerSinkSH& );

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

    SH_RC push( DataPtr item );

    SA_FILE_NAME            _log_name;
    SA_RTP_INT_PAYLOAD_TYPE _int_pt;

    /******************************************************************/
    /* functions required for SHStatus                                */
    /******************************************************************/
protected:
    friend class DummyLayerSinkEndpoint;

    virtual void pushReport( ReportPtr report, Direction d );

    SinkEndpoint*       _in_ep_a[1];
    DummyLayerSinkEndpoint _inEP;

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

    virtual bool isConnected() const;

private:
    size_t _cnt;

    size_t _null_cnt;

    ostream* _log_file;

    void inc_drop_count( );

    void inc_null_count( );
};


}; // namespace SH

#endif /* DUMMY_LAYER_SINK_SH */

---