mirror of
https://github.com/apache/cloudstack.git
synced 2025-10-26 08:42:29 +01:00
c269097a27
On redundant VR setups, the primary resolver being handed out to instances is the guest_ip (primary IP for the VR). This might lead to problems upon failover, at least while the DHCP lease doesn't update (because the primary resolver will be checked first until times out, however it'll be gone upon failover). If Global Setting use_ext_dns is true, we don't want the VR to be the primary resolver at all.
102 lines
2.8 KiB
Python
Executable File
102 lines
2.8 KiB
Python
Executable File
# -- coding: utf-8 --
|
|
# Licensed to the Apache Software Foundation (ASF) under one
|
|
# or more contributor license agreements. See the NOTICE file
|
|
# distributed with this work for additional information
|
|
# regarding copyright ownership. The ASF licenses this file
|
|
# to you under the Apache License, Version 2.0 (the
|
|
# "License"); you may not use this file except in compliance
|
|
# with the License. You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing,
|
|
# software distributed under the License is distributed on an
|
|
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
# KIND, either express or implied. See the License for the
|
|
# specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
from CsDatabag import CsCmdLine
|
|
from CsAddress import CsAddress
|
|
import logging
|
|
|
|
|
|
class CsConfig(object):
|
|
"""
|
|
A class to cache all the stuff that the other classes need
|
|
"""
|
|
__LOG_FILE = "/var/log/cloud.log"
|
|
__LOG_LEVEL = "DEBUG"
|
|
__LOG_FORMAT = "%(asctime)s %(levelname)-8s %(message)s"
|
|
cl = None
|
|
|
|
def __init__(self):
|
|
self.fw = []
|
|
|
|
def set_address(self):
|
|
self.ips = CsAddress("ips", self)
|
|
|
|
@classmethod
|
|
def get_cmdline_instance(cls):
|
|
if cls.cl is None:
|
|
cls.cl = CsCmdLine("cmdline")
|
|
return cls.cl
|
|
|
|
def cmdline(self):
|
|
return self.get_cmdline_instance()
|
|
|
|
def address(self):
|
|
return self.ips
|
|
|
|
def get_fw(self):
|
|
return self.fw
|
|
|
|
def get_logger(self):
|
|
return self.__LOG_FILE
|
|
|
|
def get_level(self):
|
|
return self.__LOG_LEVEL
|
|
|
|
def is_vpc(self):
|
|
return self.cl.get_type() == "vpcrouter"
|
|
|
|
def is_router(self):
|
|
return self.cl.get_type() == "router"
|
|
|
|
def get_domain(self):
|
|
return self.cl.get_domain()
|
|
|
|
def get_dns(self):
|
|
dns = []
|
|
if not self.cl.get_use_ext_dns():
|
|
if not self.is_vpc() and self.cl.is_redundant():
|
|
dns.append(self.cl.get_guest_gw())
|
|
else:
|
|
dns.append(self.address().get_guest_ip())
|
|
names = ["dns1", "dns2"]
|
|
for name in names:
|
|
if name in self.cmdline().idata():
|
|
dns.append(self.cmdline().idata()[name])
|
|
return dns
|
|
|
|
def get_format(self):
|
|
return self.__LOG_FORMAT
|
|
|
|
def get_ingress_chain(self, device, ip):
|
|
if self.is_vpc():
|
|
return "ACL_INBOUND_%s" % device
|
|
else:
|
|
return "FIREWALL_%s" % ip
|
|
|
|
def get_egress_chain(self, device, ip):
|
|
if self.is_vpc():
|
|
return "ACL_OUTBOUND_%s" % device
|
|
else:
|
|
return "FW_EGRESS_RULES"
|
|
|
|
def get_egress_table(self):
|
|
if self.is_vpc():
|
|
return 'mangle'
|
|
else:
|
|
return ""
|