Synnefo

from django.db.models import Q

from django.db import transaction, IntegrityError

from .models import (Holder, Entity, Policy, Holding,

class QuotaholderDjangoDBCallpoint(Callpoint):

        for entity, key, newkey in set_entity_key:

            try:

            except Entity.DoesNotExist:

                append(entity)

                continue

                import_limit, export_limit  ) in set_limits:

                try:

                except Policy.DoesNotExist:

                    Policy.objects.create(  policy=policy,

                                            quantity=quantity,

    def _set_holding(self, entity, resource, policy, flags):

        try:

            h.policy = p

            h.flags = flags

            h.save()

                continue

            try:

                h.policy = p

                h.flags = flags

                h.save()

                          imported, exported, returned, released,

                          flags):

        try:

        except Holding.DoesNotExist:

            h = Holding(entity=entity, resource=resource)

                continue

            try:

                h.imported=imported

                h.importing=imported

                h.exported=exported

    def _increase_resource(self, entity, resource, amount):

        try:

        except Holding.DoesNotExist:

            h = Holding(entity=entity, resource=resource)

            p = Policy.objects.create(policy=self._new_policy_name(),

        for idx, (entity, resource, key) in enumerate(release_holding):

            try:

            except Holding.DoesNotExist:

                append(idx)

                continue

                )

                try:

                    p = h.policy

                    h.policy = newp

                    h.flags = flags

                release = 1

            try:

            except Holding.DoesNotExist:

                m = ("There is not enough quantity "

                     "to allocate from in %s.%s" % (entity, resource))

                    raise NoQuantityError(m)

            try:

            except Holding.DoesNotExist:

                m = ("There is not enough capacity "

                     "to allocate into in %s.%s" % (target, resource))

        for serial in serials:

            try:

            except Commission.DoesNotExist:

                return

            t = c.entity

            for pv in provisions:

                try:

                except Holding.DoesNotExist:

                    m = "Corrupted provision"

                    raise CorruptedError(m)

        for serial in serials:

            try:

            except Commission.DoesNotExist:

                return

            t = c.entity

            for pv in provisions:

                try:

                except Holding.DoesNotExist:

                    m = "Corrupted provision"

                    raise CorruptedError(m)

        append = rejected.append

        for entity, key in release_entity:

            try:

            except Entity.DoesNotExist:

                append(entity)

                continue