Synnefo

import inspect

def environ_get(key, default_value=''):

    if os.environ.has_key(key):

def printf(fmt, *args):

    global QH_DEBUG

    if(QH_DEBUG):

    return 0

def exn(fmt, *args):

        p = Policy.policies.get(name)

        if(p == None):

            p = Policy.newDummy()

            Policy.policies[name] = p

        return p

    def splitRejected(policyList, rejectedList):

        (a, b) = split((lambda p: p.policyName not in rejectedList), policyList)

        if(b != []):

        return (a, b)

    @staticmethod

    @staticmethod

    def saveMany(policyList):

        inputList = [(p.policyName, p.quantity, p.capacity, p.importLimit, p.exportLimit)

        if(inputList != []):

            rejectedList = Policy.con().set_limits(context=Policy.Context, set_limits=inputList)

        else:

        ok, notok = Policy.splitRejected(policyList, rejectedList)

        for p in ok:

            p.exist = Policy.PolicyState.EXISTS

        for p in notok:

                p.exist = Policy.PolicyState.NOT_EXISTS

        return notok

                p.exist = Policy.PolicyState.NOT_EXISTS

        return notok

    def reset(self):

        self.set(None, 0, 0, 0, 0)

            oList1 = []

        else:

            oList1 = Resource.con().get_quota(context=Resource.Context, get_quota=iList1)

                res1 = find((lambda r: r.resourceName == res), rl1)

                res1.imported = i

                res1.exported = e

            ol1 = []

        else:

            il1 = [(r.entity.entityName, r.resourceName, r.entity.entityKey,r.policy.quantity,

            ol1 = Resource.con().set_quota(context=Resource.Context,set_quota=il1)

        if(rl2 == []):

            ol2 = []

        else:

            ol2 = Resource.con().set_holding(context=Resource.Context,set_holding=il2)

        rejectedList = []

    def set(self, name, password, parent):

        super(ResourceHolder,self).set(name, password, parent)

        return self

    def __init__(self):

        #super(ResourceHolder,self).__init__()

        ResourceHolder.__init__(self)

        # load policies for groups

        self.loadGroupResourcePolicies()

    def loadGroupResourcePolicies(self):

        for r in self.getResources():

        for r in self.resourceNames:

            self.userResourcePolicies[r] = Policy.get("{0}.{1}".format(self.entityName,r))

    def getUserPolicyFor(self,resourceName):

        return self.userResourcePolicies[resourceName]

        for name,quantity in kwargs.items():

            r = self.getResource(name)

            r.policy.quantity = quantity

            policies.append(r.policy)

        Policy.saveMany(policies)

    def saveUserPolicyQuantities(self,**kwargs):

        policies = []

        for name,quantity in kwargs.items():

            p = self.getUserPolicyFor(name)

            p.quantity = quantity

            policies.append(p)

class User(ResourceHolder):

        self.groups.append(group)

        group.users.append(self)

        #

        for r in self.getResources():

            groupUserPolicy = group.getUserPolicyFor(r.resourceName)

            self.commission.addResource(group.getResource(r.resourceName),groupUserPolicy.quantity)

        #DO NOT COMMIT HERE

        # self.commit !!! no

# Main program

try:

    # Group1

    printf("Step 1")

    group1 = Group.get("group1","group1")

    printf("Step 2  name : {0}",group1.entityName)

    #["pithos","cyclades.vm","cyclades.cpu","cyclades.mem"]

    printf("Group1 resources BEGIN")

    for r in group1.getResources(True):