Haizea

# -------------------------------------------------------------------------- #

from mx.DateTime import DateTime

from haizea.core.leases import LeaseWorkload, Site

class LWFAnalyser(object):

    def __init__(self, lwffile, utilization_length):

        # Arbitrary start time

        self.starttime = DateTime(2006,11,25,13)

        self.workload = LeaseWorkload.from_xml_file(lwffile, self.starttime)

        self.site = Site.from_lwf_file(lwffile)

        if utilization_length == None:

            self.utilization_length = self.workload.get_leases()[-1].submit_time - self.starttime

        else:

            self.utilization_length = utilization_length

        print self.utilization_length

    def analyse(self):

        utilization = 0

        for lease in self.workload.get_leases():

            if lease.start.requested + lease.duration.requested > self.starttime + self.utilization_length:

                duration = self.starttime + self.utilization_length - lease.start.requested

            else: 

                duration = lease.duration.requested.seconds

            for res in lease.requested_resources.values():

                for i in range(1,res.get_ninstances("CPU") + 1):

                    utilization += res.get_quantity_instance("CPU", i) * duration

        if self.site != None:

            max_utilization = 0

            duration = self.utilization_length.seconds

            for res in self.site.nodes.get_all_nodes().values():

                for i in range(1,res.get_ninstances("CPU") + 1):

                    max_utilization += res.get_quantity_instance("CPU", i) * duration

        print "Utilization: %.2f%%" % (utilization / max_utilization)