QOSOptimizer.h

Go to the documentation of this file.

#ifndef BOREALIS_QOSOPT_H
#define BOREALIS_QOSOPT_H

#include "BasicComponent.h"

BOREALIS_NAMESPACE_BEGIN


// --------------------------------------------------
class QOSOptimizer : public BasicComponent {

 public:
    QOSOptimizer(string id);
    ~QOSOptimizer() {}

    // RPC: #include "Stats.h"
    
    NMSTL_RPC_OBJECT(QOSOptimizer);

    RPC<void> do_something(double life, double tp); 
    RPC<int> call_me();
    RPC<vector<Stats> > get_stat();

    
 protected:
    void in_thread_init();
    void handle_load_offer(AsyncRPC< ptr<LoadOffer> > completion, ptr<LoadOffer> offer);

 private:

    // Completion for initial request
    AsyncRPC<void> m_completion;


    class OverloadedException {
    public:
        string m_message;
        OverloadedException(string message): m_message(message) { }
    };

    //static const double EPSILON_COST = 0.002;
    static const double EPSILON_COST = 0.1;

    // Cached version of latest stats
    typedef vector< Stats > StatsList;
    vector<Stats> m_operatorStats;    
    double m_total_cpu; // Total used in percent
    double m_total_bw; // Total used in MBytes
    double m_bw_utilization; // Fraction total used (ratio)
    double m_cpu_utilization; // Fraction total used (ratio)
    double m_load_level;
    double m_marginal_cost;

    double m_lifetime;
    double m_sel;
    int counter;
    bool whereJoin;
    bool switchLoc;

    //typedef list< Contract > Contracts;
    //Contracts m_contracts; 

    //void init_contracts();

    void update_stats();
    void update_stats_2(RPC<StatsList> result);
    void yomama(RPC<double> result);
    void updateSel(double sel);

    double compute_avg_marginal_cost(double cpuUsage, double deltaCPU, double bwUsage, double deltaBW);    

    // Giving load
    bool m_offerPending;

    void reset_partners();
    void send_out_load_offers();
    void pick_boxes(StatsList& src, StatsList& dst, double threshold);
    void handle_load_offer_response(string partner, ptr<LoadOffer> original_offer, 
                                    RPC< ptr<LoadOffer> > counter_offer);
    void done_moving_load(RPC<void> stat);
    vector<Name> extract_names(vector<Stats> boxes);

    // Taking load
    bool m_movementInProgress;
    typedef list< ptr<LoadOffer> > LoadOffers;
    typedef map < ptr<LoadOffer>, AsyncRPC< ptr<LoadOffer> > > LoadOfferCompletions;
    LoadOffers m_load_offers;
    LoadOfferCompletions m_load_offer_completions;
    void examine_load_offers();
    void pick_new_boxes(StatsList& src, StatsList& dst, double threshold,
                        double& acceptedDeltaCPU, double& acceptedDeltaBW);


};

BOREALIS_NAMESPACE_END

#endif

---