Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

AMBARI-23536. Fix TestCustomServiceOrchestrator.py and TestRegistration #966

Merged
merged 6 commits into from Apr 16, 2018
Expand Up @@ -553,49 +553,6 @@ def dump_command_to_json(self, command, retry=False):
f.write(content)
return file_path

def decompressClusterHostInfo(self, clusterHostInfo):
info = clusterHostInfo.copy()
#Pop info not related to host roles
hostsList = info.pop(self.HOSTS_LIST_KEY)
pingPorts = info.pop(self.PING_PORTS_KEY)
racks = info.pop(self.RACKS_KEY)
ipv4_addresses = info.pop(self.IPV4_ADDRESSES_KEY)

ambariServerHost = info.pop(self.AMBARI_SERVER_HOST)
ambariServerPort = info.pop(self.AMBARI_SERVER_PORT)
ambariServerUseSsl = info.pop(self.AMBARI_SERVER_USE_SSL)

decompressedMap = {}

for k,v in info.items():
# Convert from 1-3,5,6-8 to [1,2,3,5,6,7,8]
indexes = self.convertRangeToList(v)
# Convert from [1,2,3,5,6,7,8] to [host1,host2,host3...]
decompressedMap[k] = [hostsList[i] for i in indexes]

#Convert from ['1:0-2,4', '42:3,5-7'] to [1,1,1,42,1,42,42,42]
pingPorts = self.convertMappedRangeToList(pingPorts)
racks = self.convertMappedRangeToList(racks)
ipv4_addresses = self.convertMappedRangeToList(ipv4_addresses)

#Convert all elements to str
pingPorts = map(str, pingPorts)

#Add ping ports to result
decompressedMap[self.PING_PORTS_KEY] = pingPorts
#Add hosts list to result
decompressedMap[self.HOSTS_LIST_KEY] = hostsList
#Add racks list to result
decompressedMap[self.RACKS_KEY] = racks
#Add ips list to result
decompressedMap[self.IPV4_ADDRESSES_KEY] = ipv4_addresses
#Add ambari-server properties to result
decompressedMap[self.AMBARI_SERVER_HOST] = ambariServerHost
decompressedMap[self.AMBARI_SERVER_PORT] = ambariServerPort
decompressedMap[self.AMBARI_SERVER_USE_SSL] = ambariServerUseSsl

return decompressedMap

# Converts from 1-3,5,6-8 to [1,2,3,5,6,7,8]
def convertRangeToList(self, list):

Expand Down
Expand Up @@ -48,14 +48,13 @@ class InitializerModule:
"""
def __init__(self):
self.stop_event = threading.Event()
self.config = AmbariConfig.get_resolved_config()
self.init()

def init(self):
"""
Initialize properties
"""
self.config = AmbariConfig.get_resolved_config()

self.is_registered = False

self.metadata_cache = ClusterMetadataCache(self.config.cluster_cache_dir)
Expand Down