DcRack Class Reference

#include <dcrack.h>

Inheritance diagram for DcRack:

Collaboration diagram for DcRack:

Public Member Functions
	DcRack ()
virtual	~DcRack ()
virtual int	command (int argc, const char *const *argv)

Public Attributes
int	rack_id_
double	stat_interval
double	link_load
double	uplink_B

Protected Member Functions
void	updatestats ()
virtual void	expire (Event *e)
void	addHost (DcHost *hst)

Protected Attributes
vector< DcHost * >	hosts_list_
vector< QueueMonitor * >	qmon_uplink_list
int	breceived_
int	breceived_old_

Detailed Description

Definition at line 9 of file dcrack.h.

Constructor & Destructor Documentation

DcRack::DcRack

(

)

Definition at line 15 of file dcrack.cc.

              : rack_id_(0), stat_interval (0.0), breceived_(0), breceived_old_(0)
{
                bind("rack_id_", &rack_id_);
                bind("breceived_", &breceived_);
                bind("stat_interval", &stat_interval);
                bind("uplink_B", &uplink_B);
}

DcRack::~DcRack ( )

virtual

Definition at line 23 of file dcrack.cc.

{
                hosts_list_.~vector();
                qmon_uplink_list.~vector();
}

Member Function Documentation

void DcRack::addHost ( DcHost *  hst )

protected

Definition at line 60 of file dcrack.cc.

                               {
                hosts_list_.push_back(hst);
                hst->rack_=this;
}

int DcRack::command ( int  argc, const char *const *  argv  )

virtual

Definition at line 65 of file dcrack.cc.

{
                if (argc == 2) {
                                if (strcmp(argv[1], "update-stats") == 0) {
                                                updatestats();
                                                return (TCL_OK);
                                } else if (strcmp(argv[1], "start") == 0) {
                                                expire(new Event());
                                                return (TCL_OK);
                                }
                } else if (argc == 3) {
                                if (strcmp(argv[1], "add-dchost") == 0) {
                                                DcHost *hst = dynamic_cast<DcHost*> (TclObject::lookup(argv[2]));
                                                if(hst){
                                                                addHost(hst);
                                                                return (TCL_OK);
                                                }
                                                return (TCL_ERROR);
                                }
                                else if (strcmp(argv[1], "add-uplink-qmon") == 0) {
                                                QueueMonitor *uplinkqmon = dynamic_cast<QueueMonitor*> (TclObject::lookup(argv[2]));
                                                if(uplinkqmon){
                                                                qmon_uplink_list.push_back(uplinkqmon);

                                                                return (TCL_OK);
                                                }
                                                return (TCL_ERROR);
                                }
                }
                return (DcRack::command(argc, argv));
}

void DcRack::expire ( Event *  e )

protectedvirtual

Definition at line 54 of file dcrack.cc.

                            {

                updatestats();
                this->resched(stat_interval);
}

void DcRack::updatestats ( )

protected

Definition at line 29 of file dcrack.cc.

                        {

                vector <QueueMonitor*>::iterator iter;
                breceived_old_ = breceived_;
                breceived_ = 0;
//              link_load = 0;

                /* Update statistics on the number of bytes received */
                for (iter = qmon_uplink_list.begin(); iter!=qmon_uplink_list.end(); iter++)
                {
                                breceived_ += (*iter)->bdepartures_tot();
                }
                if(breceived_-breceived_old_<0){
                                std::cerr << "ERROR in DcRack.cc: Byte counter overflow, consider resetting bdepartures_tot in qmon";
                                abort();
                }
                link_load  =(breceived_-breceived_old_)/(qmon_uplink_list.size()*stat_interval*uplink_B);
                //TODO: fix the problem
                link_load *=qmon_uplink_list.size();
                if(link_load > 1 ){
                                link_load=1;
                }
//              std:cerr << "Rack " << this->rack_id_ << " link load\t" << link_load <<"\n";
}

Member Data Documentation

int DcRack::breceived_

protected

bytes received

Definition at line 32 of file dcrack.h.

int DcRack::breceived_old_

protected

Definition at line 33 of file dcrack.h.

vector<DcHost*> DcRack::hosts_list_

protected

list of hosts in a rack

Definition at line 23 of file dcrack.h.

double DcRack::link_load

Definition at line 17 of file dcrack.h.

vector<QueueMonitor*> DcRack::qmon_uplink_list

protected

uplink queue monitors

Definition at line 24 of file dcrack.h.

int DcRack::rack_id_

Definition at line 15 of file dcrack.h.

double DcRack::stat_interval

Definition at line 16 of file dcrack.h.

double DcRack::uplink_B

Definition at line 18 of file dcrack.h.

---

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

• dcrack.h
• dcrack.cc