DistNearestNeighbour.h

Go to the documentation of this file.

/* 
 * File:   DistNearestNeighbour.h
 * Author: fermat
 *
 * Created on 20. Januar 2010, 11:32
 */

#ifndef _DISTNEARESTNEIGHBOUR_H
#define _DISTNEARESTNEIGHBOUR_H

#include"Distributor.h"
#include"ImprovedMap.h"
#include<set>
#include<map>
#include<tr1/unordered_map>

#define VDRIVE_DNN_DDT std::tr1::unordered_map<uint64_t, Disk*>
#define VDRIVE_DNN_DDTit std::tr1::unordered_map<uint64_t, Disk*>::iterator
#define VDRIVE_DNN_MULT std::tr1::unordered_map<uint64_t, int32_t>
#define VDRIVE_DNN_MULTit std::tr1::unordered_map<uint64_t, int32_t>::iterator

namespace VDRIVE {

    class DistNearestNeighbour : public Distributor {
    public:

        DistNearestNeighbour(xercesc::DOMElement* data);

        DistNearestNeighbour(int argc, char** argv);

        DistNearestNeighbour(bool staticNNCopies, int32_t nnCopies, int32_t nnCopiesFactor);

        DistNearestNeighbour(const DistNearestNeighbour& orig);

        virtual ~DistNearestNeighbour();

        virtual std::list<Disk*>* placeExtent(int64_t virtualVolumeId, int64_t position) ;

        virtual void setDisksMulti(std::list<Disk*>* disks, VDRIVE_DNN_MULT *multiplicity);

        virtual void setConfiguration(std::list<Disk*>* disks, int64_t extentsize, int32_t copies);

        virtual void setDisks(std::list<Disk*>* disks);

        virtual xercesc::DOMElement* toXML(xercesc::DOMDocument* doc) const;

        virtual std::list<Disk*>* getDisks() const;

        virtual int64_t getExtentsize() const {
            return extentsize;
        }

        virtual int32_t getCopies() const {
            return copies;
        }

        static std::string getXMLRootType() {
            return std::string("NearestNeighbour");
        }

    private:
        int64_t extentsize;

        int32_t copies;

        int32_t nnCopies;

        int32_t nnCopiesFactor;

        uint64_t cutFactor;

        std::list<Disk*>* disks;

        ImprovedMap *keyFinder;

        std::set<uint64_t> *keys;

        VDRIVE_DNN_DDT *diskDistribution;

        bool staticNNCopies;

        uint64_t hashFunction(int64_t virtualVolumeId, int64_t blockposition, int64_t index) const;

        uint64_t hashFunction(Disk* disk, int64_t iteration) const;

    protected:
        virtual int32_t getNNCopies(std::list<Disk*>* disks) const;
    };
}
#endif  /* _DISTNEARESTNEIGHBOUR_H */