DistFastRedundantShare.h

Go to the documentation of this file.

/* 
 * File:   FastRedundantShare.h
 * Author: fermat
 *
 * Created on 27. März 2010, 12:18
 */

#ifndef _FASTREDUNDANTSHARE_H
#define _FASTREDUNDANTSHARE_H

#include"DistRedundantShare.h"
#include "DistShare.h"
#include<limits>
#include<string>
#include<sstream>
#include<iostream>
#include"helper.h"

#define VDRIVE_FRS_KMAP std::tr1::unordered_map<int64_t, DistShare*>
#define VDRIVE_FRS_KMAPit VDRIVE_FRS_KMAP::iterator
#define VDRIVE_FRS_MMAP std::tr1::unordered_map<int32_t, VDRIVE_FRS_KMAP *>
#define VDRIVE_FRS_MMAPit VDRIVE_FRS_MMAP::iterator

#define VDRIVE_FRS_DISKMAP std::tr1::unordered_map<int64_t, Disk*>
#define VDRIVE_FRS_DISKMAPit VDRIVE_FRS_DISKMAP::iterator

namespace VDRIVE {

    class DistFastRedundantShare : public Distributor {
    public:
        DistFastRedundantShare(int argc, char** argv);
        DistFastRedundantShare(xercesc::DOMElement* data);
        DistFastRedundantShare(const DistFastRedundantShare& orig);
        virtual ~DistFastRedundantShare();

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

        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;

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

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

        virtual int64_t getExtentsize() const {
            return extentsize;
        }

        virtual int32_t getCopies() const {
            return copies;
        }

        virtual void setBaseMessage(uint8_t* baseMessage);
        
    private:
        VDRIVE_FRS_MMAP *distributors;

        int32_t copies;

        int64_t extentsize;

        VDRIVE_FRS_DISKMAP *disks;

        void initShareStructures(DistRedundantShare *rs);
        
        DistShare* createShare(RSDisk** disks, int32_t first, int32_t last, int32_t k);

    };
}
#endif  /* _FASTREDUNDANTSHARE_H */