~mpontillo/maas/dns-template-changes-1.7

Viewing changes to src/provisioningserver/cache.py

Committer: MaaS Lander
Author(s): Gavin Panella
Date: 2014-09-23 21:21:43 UTC
mfrom: (3064.2.10 rpc-dns)
Revision ID: maas_lander-20140923212143-tjgdnu2f3tjd2pmd

[r=blake-rouse][bug=][author=allenap] Purge all remaining Celery code from the cluster controller code.

Code in provisioningserver relating to DNS still uses Celery, but it is not used on the cluster controllers.

files removed:
etc/celeryconfig_cluster.py

etc/democeleryconfig_cluster.py

etc/maas_local_celeryconfig_cluster.py

services/cluster-worker

services/cluster-worker/down

services/cluster-worker/run

src/maasserver/refresh_worker.py

src/maasserver/testing/tags.py

src/maasserver/tests/test_refresh_worker.py

src/provisioningserver/cache.py

src/provisioningserver/initialize_cache.py

src/provisioningserver/testing/worker_cache.py

src/provisioningserver/tests/test_auth.py

src/provisioningserver/tests/test_cache.py

files modified:
Makefile

buildout.cfg

docs/development/cluster-registration.rst

docs/maascli.rst

docs/man/maas.8.rst

etc/celeryconfig.py

etc/celeryconfig_common.py

man/maas-import-pxe-files.8

man/maas-region-admin.8

man/maas.8

services/reloader/run

setup.py

src/maasserver/api/node_groups.py

src/maasserver/api/tests/test_nodegroup.py

src/maasserver/models/nodegroup.py

src/maasserver/models/tests/test_nodegroup.py

src/maasserver/start_up.py

src/maasserver/testing/testcase.py

src/maasserver/tests/test_start_up.py

src/provisioningserver/auth.py

src/provisioningserver/config.py

src/provisioningserver/dhcp/leases.py

src/provisioningserver/dhcp/tests/test_detect.py

src/provisioningserver/import_images/boot_resources.py

src/provisioningserver/start_cluster_controller.py

src/provisioningserver/tags.py

src/provisioningserver/tasks.py

src/provisioningserver/testing/testcase.py

src/provisioningserver/tests/test_start_cluster_controller.py

src/provisioningserver/tests/test_tags.py

src/provisioningserver/tests/test_tasks.py

Show diffs side-by-side

added added

removed removed

src/provisioningserver/cache.py

# GNU Affero General Public License version 3 (see the file LICENSE).

"""API credentials for node-group workers."""

from __future__ import (

absolute_import,

print_function,

unicode_literals,

)

str = None

__metaclass__ = type

__all__ = [

'cache',

'initialize',

]

from multiprocessing import Manager

class Cache:

"""A process-safe dict-like cache."""

def __init__(self, cache_backend):

self.cache_backend = cache_backend

def set(self, key, value):

self.cache_backend[key] = value

def get(self, key):

return self.cache_backend.get(key, None)

def clear(self):

self.cache_backend.clear()

_manager = None

cache = None

initialized = False

def initialize():

"""Initialize cache of shared data between processes.

This needs to be done exactly once, by the parent process, before it

start forking off workers.

"""

global _manager

global cache

global initialized

if not initialized:

_manager = Manager()

cache = Cache(_manager.dict())

initialized = True

Older »