TestCachingProxy.h

Go to the documentation of this file.

#ifndef TEST_CACHING_PROXY_H 
#define TEST_CACHING_PROXY_H 

#include <config.h>

#include "MNRTSPServer.h"
#include "MNTimer.h"
#include "MNTimerCall.h"
#include "MNString.h"

class ControlBase;

class TestCachingProxy : public MNRTSPServer
{
    class Probability;

    ControlBase* _dummyUplink;
    size_t       _no_of_requests;
    Probability* _prob;

    MNTimer         _timer;
    struct timeval  _interarrival_time;

    TimerCall<TestCachingProxy> _new_request;

public:
    TestCachingProxy();
    ~TestCachingProxy();

    void ListenClient();

    virtual ControlBase* getFillBufferTo( const MNString& serverUrl );

private:
    void newRequest( void* data, TimerCallBase* self );

private:
    class Probability
    {
    public:
        virtual int draw( ) = 0;
    };

    class ProbabilityCycle : public Probability
    {
        const int _num;
        int       _current;

    public:
        ProbabilityCycle( int num );
        virtual int draw( );
    };

    class ProbabilityZipf : public Probability
    {
        double* _probabilities;

    public:
        ProbabilityZipf( int num );
        virtual ~ProbabilityZipf( );
        virtual int draw( );
    };

    class ProbabilityUnified : public Probability
    {
        const int _num;
        double    _share;

    public:
        ProbabilityUnified( int num );
        virtual int draw( );
    };
};

#endif /* TEST_CACHING_PROXY_H */

---