Source code for spinn_front_end_common.abstract_models.impl.machine_allocation_controller

# Copyright (c) 2017-2019 The University of Manchester
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# GNU General Public License for more details.
# You should have received a copy of the GNU General Public License
# along with this program.  If not, see <>.

import logging
import sys
from threading import Thread
from spinn_utilities.log import FormatAdapter
from spinn_utilities.overrides import overrides
from spinn_utilities.abstract_base import AbstractBase, abstractmethod
from spinn_front_end_common.abstract_models import (
logger = FormatAdapter(logging.getLogger(__name__))

[docs]class MachineAllocationController( AbstractMachineAllocationController, metaclass=AbstractBase): """ How to manage the allocation of a machine so that it gets cleaned up\ neatly when the script dies. """ __slots__ = [ #: boolean flag for telling this thread when the system has ended "_exited" ] def __init__(self, thread_name): """ :param str thread_name: """ thread = Thread(name=thread_name, target=self.__manage_allocation) thread.daemon = True self._exited = False thread.start()
[docs] @overrides(AbstractMachineAllocationController.close) def close(self): self._exited = True
@abstractmethod def _wait(self): """ Wait for some bounded amount of time for a change in the status\ of the machine allocation. :return: Whether the machine is still (believed to be) allocated. :rtype: bool """ def _teardown(self): """ Perform any extra teardown that the thread requires. Does not\ need to be overridden if no action is desired.""" def __manage_allocation(self): machine_still_allocated = True while machine_still_allocated and not self._exited: machine_still_allocated = self._wait() self._teardown() if not self._exited: logger.error( "The allocated machine has been released before the end of" " the script; this script will now exit") sys.exit(1)