ProbabilisticScheduler Class Reference

#include <probabilisticscheduler.h>

Inheritance diagram for ProbabilisticScheduler:

Collaboration diagram for ProbabilisticScheduler:

Public Member Functions
	ProbabilisticScheduler ()
virtual	~ProbabilisticScheduler ()
virtual TskComAgent *	scheduleTask (CloudTask *task, std::vector< ResourceProvider * > providers)
Public Member Functions inherited from ScoreScheduler
	ScoreScheduler ()
virtual	~ScoreScheduler ()
Public Member Functions inherited from DcScheduler
	DcScheduler ()
virtual	~DcScheduler ()

Private Member Functions
virtual double	calculateScore (ResourceProvider *rp)=0

Detailed Description

Definition at line 15 of file probabilisticscheduler.h.

Constructor & Destructor Documentation

ProbabilisticScheduler::ProbabilisticScheduler

(

)

Definition at line 10 of file probabilisticscheduler.cc.

                                               {


}

ProbabilisticScheduler::~ProbabilisticScheduler ( )

virtual

Definition at line 15 of file probabilisticscheduler.cc.

                                                {

}

Member Function Documentation

virtual double ProbabilisticScheduler::calculateScore ( ResourceProvider *  rp )

privatepure virtual

Implements ScoreScheduler.

Implemented in RandDENS, and RandomScheduler.

TskComAgent * ProbabilisticScheduler::scheduleTask ( CloudTask *  task, std::vector< ResourceProvider * >  providers  )

virtual

Implements DcScheduler.

Reimplemented in RandDENS, and RandomScheduler.

Definition at line 19 of file probabilisticscheduler.cc.

                                                                                                         {
                //1. calculate mDENS score array
                //2. generate random number in [0:summed mDENS score]
                //3. binary search on the array
                //4. return the selected host
                TskComAgent* selected = NULL;
                std::vector<double>  mdens_score(providers.size());
                std::vector<double>   mdens_score_cumulative(providers.size());
                vector <ResourceProvider*>::iterator res_p;
                vector <double>::iterator score;
                vector <double>::iterator cumul;
                for (res_p = providers.begin(), score = mdens_score.begin(), cumul = mdens_score_cumulative.begin();
                                                res_p!=providers.end();
                                                res_p++, score++, cumul++)
                {
                                (*score) = calculateScore((*res_p));
                                if(cumul==mdens_score_cumulative.begin()){
                                                (*cumul) = (*score);
                                } else {
                                                (*cumul) = (*score) + (*(cumul-1));
                                }
//                              std::cout << "score:" << (*score)<< " cumul: " << (*cumul) << "\n";
                }
//              srand(time(0));
                double r = ( (double)rand() / (double)RAND_MAX ) * mdens_score_cumulative.at(mdens_score_cumulative.size()-1);
//              std::cerr << "Random: " << r  << "\n";
                vector <double>::iterator lb = lower_bound(mdens_score_cumulative.begin(),mdens_score_cumulative.end(),r);
                int sel_ind = lb - mdens_score_cumulative.begin();
//              std::cerr << "Lb: "<< (*lb) << " ind: " << sel_ind << "\n";
//              abort();
                selected = providers.at(sel_ind)->getTskComAgent();
                return selected;
}

---

The documentation for this class was generated from the following files:

• probabilisticscheduler.h
• probabilisticscheduler.cc