src/main/GarbageCollector.h

Go to the documentation of this file.

#ifndef _GARBAGECOLLECTOR_H
#define _GARBAGECOLLECTOR_H

#include <list>
#include <set>
#include <utility>
#include <deque>
#include <pthread.h>

#include "Space.h"
#include "Cache.h"

class GarbageCollector {

private:

        typedef std::list<Space*> SpaceList;
        typedef std::set<Space*> SpaceSet;

        Cache *cache;
        unsigned sleepInterval;
        SpaceList spaceList;
        SpaceSet spacesToRemove;
        SpaceList spacesToAdd;

        pthread_mutex_t removeMutex;
        pthread_mutex_t addMutex;

        pthread_t threadID;

        //SpaceManager:
        unsigned reqHistoryLimiter;
        std::map<Space *, std::deque<unsigned> *> reqHistoryMap;
        std::deque<unsigned> reqHistoryTotal;
        unsigned long long quotaToDistribute;
        unsigned long long nextQuotaToDistribute;
        std::map<Space *, unsigned long long> requiredMinimum;
        unsigned long long maxHardQuota;

public:

        GarbageCollector(Cache *cache, unsigned sleepInterval);

        virtual ~GarbageCollector();

        void addObservedSpace(Space *space);

        void removeObservedSpace(Space * space);

        void setInterval(unsigned interval);

        void operator()();

private:

        void collect(Space * space, bool goBelowQuota);

        unsigned long long determineNewQuota(Space * space);

};

void * GCThread(void * arg);



#endif  /* _GARBAGECOLLECTOR_H */

---