sfa/server/registry.py

   1 #
   2 # Registry is a SfaServer that implements the Registry interface
   3 #
   4 from sfa.server.sfaserver import SfaServer
   5 from sfa.server.interface import Interfaces, Interface
   6 from sfa.util.config import Config
   7
   8 #
   9 # Registry is a SfaServer that serves registry and slice operations at PLC.
  10 # this truly is a server-side object
  11 #
  12 class Registry(SfaServer):
  13     ##
  14     # Create a new registry object.
  15     #
  16     # @param ip the ip address to listen on
  17     # @param port the port to listen on
  18     # @param key_file private key filename of registry
  19     # @param cert_file certificate filename containing public key (could be a GID file)
  20
  21     def __init__(self, ip, port, key_file, cert_file):
  22         SfaServer.__init__(self, ip, port, key_file, cert_file,'registry')
  23         # initialize db schema
  24         from sfa.storage.alchemy import dbsession
  25         from sfa.storage.persistentobjs import init_tables
  26         init_tables(dbsession)
  27
  28 #
  29 # Registries is a dictionary of registry connections keyed on the registry hrn
  30 # as such it's more of a client-side thing for registry servers to reach their peers
  31 #
  32 class Registries(Interfaces):
  33
  34     default_dict = {'registries': {'registry': [Interfaces.default_fields]}}
  35
  36     def __init__(self, conf_file = "/etc/sfa/registries.xml"):
  37         Interfaces.__init__(self, conf_file)
  38         sfa_config = Config()
  39         if sfa_config.SFA_REGISTRY_ENABLED:
  40             addr = sfa_config.SFA_REGISTRY_HOST
  41             port = sfa_config.SFA_REGISTRY_PORT
  42             hrn = sfa_config.SFA_INTERFACE_HRN
  43             interface = Interface(hrn, addr, port)
  44             self[hrn] = interface