in ambari-web/app/mixins/main/host/details/actions/check_host.js [772:1000]
parseWarnings: function (data) {
data = App.get('testMode') ? data : this.filterBootHosts(data);
var warnings = [];
var warning;
var hosts = [];
var warningCategories = {
fileFoldersWarnings: {},
packagesWarnings: {},
processesWarnings: {},
servicesWarnings: {},
usersWarnings: {},
alternativeWarnings: {}
};
var hostsPackagesData = this.get('hostsPackagesData');
data.items.sortPropertyLight('Hosts.host_name').forEach(function (_host) {
var host = {
name: _host.Hosts.host_name,
warnings: []
};
if (!_host.Hosts.last_agent_env) {
// in some unusual circumstances when last_agent_env is not available from the _host,
// skip the _host and proceed to process the rest of the hosts.
return;
}
//parse all directories and files warnings for host
//todo: to be removed after check in new API
var stackFoldersAndFiles = _host.Hosts.last_agent_env.stackFoldersAndFiles || [];
stackFoldersAndFiles.forEach(function (path) {
warning = warningCategories.fileFoldersWarnings[path.name];
if (warning) {
warning.hosts.push(_host.Hosts.host_name);
warning.hostsLong.push(_host.Hosts.host_name);
} else {
warningCategories.fileFoldersWarnings[path.name] = warning = {
name: path.name,
hosts: [_host.Hosts.host_name],
hostsLong: [_host.Hosts.host_name],
category: 'fileFolders'
};
}
host.warnings.push(warning);
}, this);
//parse all package warnings for host
var _hostPackagesData = hostsPackagesData.findProperty('hostName', _host.Hosts.host_name);
if (_hostPackagesData) {
_hostPackagesData.installedPackages.forEach(function (_package) {
warning = warningCategories.packagesWarnings[_package.name];
if (warning) {
warning.hosts.push(_host.Hosts.host_name);
warning.hostsLong.push(_host.Hosts.host_name);
warning.version = _package.version;
} else {
warningCategories.packagesWarnings[_package.name] = warning = {
name: _package.name,
version: _package.version,
hosts: [_host.Hosts.host_name],
hostsLong: [_host.Hosts.host_name],
category: 'packages'
};
}
host.warnings.push(warning);
}, this);
}
//parse all process warnings for host
//todo: to be removed after check in new API
var javaProcs = _host.Hosts.last_agent_env.hostHealth ? _host.Hosts.last_agent_env.hostHealth.activeJavaProcs : _host.Hosts.last_agent_env.javaProcs;
if (javaProcs) {
javaProcs.forEach(function (process) {
warning = warningCategories.processesWarnings[process.pid];
if (warning) {
warning.hosts.push(_host.Hosts.host_name);
warning.hostsLong.push(_host.Hosts.host_name);
} else {
var command = 'pid=' + process.pid + ', user=' + process.user;
warningCategories.processesWarnings[process.pid] = warning = {
name: command.length > 36 ? (command.substr(0, 35) + '...') : command,
hosts: [_host.Hosts.host_name],
hostsLong: [_host.Hosts.host_name],
category: 'processes',
user: process.user,
pid: process.pid,
command: command
};
}
host.warnings.push(warning);
}, this);
}
//parse all service warnings for host
//todo: to be removed after check in new API
if (_host.Hosts.last_agent_env.hostHealth && _host.Hosts.last_agent_env.hostHealth.liveServices) {
_host.Hosts.last_agent_env.hostHealth.liveServices.forEach(function (service) {
if (service.status === 'Unhealthy') {
warning = warningCategories.servicesWarnings[service.name];
if (warning) {
warning.hosts.push(_host.Hosts.host_name);
warning.hostsLong.push(_host.Hosts.host_name);
} else {
warningCategories.servicesWarnings[service.name] = warning = {
name: service.name,
hosts: [_host.Hosts.host_name],
hostsLong: [_host.Hosts.host_name],
category: 'services'
};
}
host.warnings.push(warning);
}
}, this);
}
//parse all user warnings for host
//todo: to be removed after check in new API
if (_host.Hosts.last_agent_env.existingUsers) {
_host.Hosts.last_agent_env.existingUsers.forEach(function (user) {
warning = warningCategories.usersWarnings[user.name];
if (warning) {
warning.hosts.push(_host.Hosts.host_name);
warning.hostsLong.push(_host.Hosts.host_name);
} else {
warningCategories.usersWarnings[user.name] = warning = {
name: user.name,
hosts: [_host.Hosts.host_name],
hostsLong: [_host.Hosts.host_name],
category: 'users'
};
}
host.warnings.push(warning);
}, this);
}
//parse misc warnings for host
var umask = _host.Hosts.last_agent_env.umask;
if (umask && umask > 23) {
warning = warnings.filterProperty('category', 'misc').findProperty('name', umask);
if (warning) {
warning.hosts.push(_host.Hosts.host_name);
warning.hostsLong.push(_host.Hosts.host_name);
} else {
warning = {
name: umask,
hosts: [_host.Hosts.host_name],
hostsLong: [_host.Hosts.host_name],
category: 'misc'
};
warnings.push(warning);
}
host.warnings.push(warning);
}
var firewallRunning = _host.Hosts.last_agent_env.firewallRunning;
if (firewallRunning !== null && firewallRunning) {
var name = _host.Hosts.last_agent_env.firewallName + " Running";
warning = warnings.filterProperty('category', 'firewall').findProperty('name', name);
if (warning) {
warning.hosts.push(_host.Hosts.host_name);
warning.hostsLong.push(_host.Hosts.host_name);
} else {
warning = {
name: name,
hosts: [_host.Hosts.host_name],
hostsLong: [_host.Hosts.host_name],
category: 'firewall'
};
warnings.push(warning);
}
host.warnings.push(warning);
}
if (_host.Hosts.last_agent_env.alternatives) {
_host.Hosts.last_agent_env.alternatives.forEach(function (alternative) {
warning = warningCategories.alternativeWarnings[alternative.name];
if (warning) {
warning.hosts.push(_host.Hosts.host_name);
warning.hostsLong.push(_host.Hosts.host_name);
} else {
warningCategories.alternativeWarnings[alternative.name] = warning = {
name: alternative.name,
target: alternative.target,
hosts: [_host.Hosts.host_name],
hostsLong: [_host.Hosts.host_name],
category: 'alternatives'
};
}
host.warnings.push(warning);
}, this);
}
if (_host.Hosts.last_agent_env.reverseLookup === false) {
var name = Em.I18n.t('installer.step3.hostWarningsPopup.reverseLookup.name');
warning = warnings.filterProperty('category', 'reverseLookup').findProperty('name', name);
if (warning) {
warning.hosts.push(_host.Hosts.host_name);
warning.hostsLong.push(_host.Hosts.host_name);
} else {
warning = {
name: name,
hosts: [_host.Hosts.host_name],
hostsLong: [_host.Hosts.host_name],
category: 'reverseLookup'
};
warnings.push(warning);
}
host.warnings.push(warning);
}
hosts.push(host);
}, this);
for (var categoryId in warningCategories) {
var category = warningCategories[categoryId];
for (var warningId in category) {
warnings.push(category[warningId]);
}
}
hosts.unshift({
name: 'All Hosts',
warnings: warnings
});
this.set('warnings', warnings);
this.set('warningsByHost', hosts);
},