/usr/lib/python2.7/dist-packages/maasserver/views/rpc.py is in python-django-maas 1.5.4+bzr2294-0ubuntu1.2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 | # Copyright 2014 Canonical Ltd. This software is licensed under the
# GNU Affero General Public License version 3 (see the file LICENSE).
"""Views relating to the region<-->cluster RPC mechanism.
Each region controller process starts its own RPC endpoint, and this
provides the means for clusters to discover what they are.
"""
from __future__ import (
absolute_import,
print_function,
unicode_literals,
)
str = None
__metaclass__ = type
__all__ = [
"info",
]
import json
from django.http import HttpResponse
from maasserver import eventloop
def info(request):
"""View returning a JSON document with information about RPC endpoints.
Currently the only information returned is a list of `(host, port)`
tuples on which the region has listening RPC endpoints.
"""
try:
advertiser = eventloop.services.getServiceNamed("rpc-advertise")
except KeyError:
# RPC advertising service has not been created, so we declare
# that there are no endpoints *at all*.
endpoints = {}
else:
if advertiser.running:
endpoints = {}
for name, addr, port in advertiser.dump():
if name in endpoints:
endpoints[name].append((addr, port))
else:
endpoints[name] = [(addr, port)]
else:
# RPC advertising service is not running, so we declare that
# there are no endpoints *at all*.
endpoints = {}
# Each endpoint is an entry point into this event-loop.
info = {"eventloops": endpoints}
return HttpResponse(json.dumps(info), content_type="application/json")
|