123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392 |
- /**
- * 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.
- */
- (function () {
- "use strict";
- dust.loadSource(dust.compile($('#tmpl-federationhealth').html(), 'federationhealth'));
- dust.loadSource(dust.compile($('#tmpl-namenode').html(), 'namenode-info'));
- dust.loadSource(dust.compile($('#tmpl-router').html(), 'router-info'));
- dust.loadSource(dust.compile($('#tmpl-datanode').html(), 'datanode-info'));
- dust.loadSource(dust.compile($('#tmpl-mounttable').html(), 'mounttable'));
- $.fn.dataTable.ext.order['ng-value'] = function (settings, col)
- {
- return this.api().column(col, {order:'index'} ).nodes().map(function (td, i) {
- return $(td).attr('ng-value');
- });
- };
- function load_overview() {
- var BEANS = [
- {"name": "federation", "url": "/jmx?qry=Hadoop:service=Router,name=FederationState"}
- ];
- var HELPERS = {
- 'helper_fs_max_objects': function (chunk, ctx, bodies, params) {
- var o = ctx.current();
- if (o.MaxObjects > 0) {
- chunk.write('(' + Math.round((o.FilesTotal + o.BlockTotal) / o.MaxObjects * 100) * 100 + ')%');
- }
- },
- 'helper_dir_status': function (chunk, ctx, bodies, params) {
- var j = ctx.current();
- for (var i in j) {
- chunk.write('<tr><td>' + i + '</td><td>' + j[i] + '</td><td>' + params.type + '</td></tr>');
- }
- },
- 'helper_date_tostring' : function (chunk, ctx, bodies, params) {
- var value = dust.helpers.tap(params.value, chunk, ctx);
- return chunk.write('' + new Date(Number(value)).toLocaleString());
- }
- };
- var data = {};
- // Workarounds for the fact that JMXJsonServlet returns non-standard JSON strings
- function workaround(nn) {
- nn.NodeUsage = JSON.parse(nn.NodeUsage);
- return nn;
- }
- load_json(
- BEANS,
- guard_with_startup_progress(function(d) {
- for (var k in d) {
- data[k] = k === 'federation' ? workaround(d[k].beans[0]) : d[k].beans[0];
- }
- render();
- }),
- function (url, jqxhr, text, err) {
- show_err_msg('<p>Failed to retrieve data from ' + url + ', cause: ' + err + '</p>');
- });
- function render() {
- var base = dust.makeBase(HELPERS);
- dust.render('federationhealth', base.push(data), function(err, out) {
- $('#tab-overview').html(out);
- $('#ui-tabs a[href="#tab-overview"]').tab('show');
- });
- }
- }
- function load_namenode_info() {
- var HELPERS = {
- 'helper_lastcontact_tostring' : function (chunk, ctx, bodies, params) {
- var value = dust.helpers.tap(params.value, chunk, ctx);
- return chunk.write('' + new Date(Date.now()-1000*Number(value)));
- }
- };
- function workaround(r) {
- function node_map_to_array(nodes) {
- var res = [];
- for (var n in nodes) {
- var p = nodes[n];
- p.name = n;
- res.push(p);
- }
- return res;
- }
- function capitalise(string) {
- return string.charAt(0).toUpperCase() + string.slice(1).toLowerCase();
- }
- function augment_namenodes(nodes) {
- for (var i = 0, e = nodes.length; i < e; ++i) {
- var n = nodes[i];
- n.usedPercentage = Math.round(n.used * 1.0 / n.totalSpace * 100);
- n.title = "Unavailable";
- n.iconState = "unavailable";
- if (n.isSafeMode === true) {
- n.title = capitalise(n.state) + " (safe mode)"
- n.iconState = "safemode";
- } else if (n.state === "ACTIVE") {
- n.title = capitalise(n.state);
- n.iconState = "active";
- } else if (nodes[i].state === "STANDBY") {
- n.title = capitalise(n.state);
- n.iconState = "standby";
- } else if (nodes[i].state === "UNAVAILABLE") {
- n.title = capitalise(n.state);
- n.iconState = "unavailable";
- }
- if (n.namenodeId === "null") {
- n.namenodeId = "";
- }
- }
- }
- r.Nameservices = node_map_to_array(JSON.parse(r.Nameservices));
- augment_namenodes(r.Nameservices);
- r.Namenodes = node_map_to_array(JSON.parse(r.Namenodes));
- augment_namenodes(r.Namenodes);
- return r;
- }
- $.get(
- '/jmx?qry=Hadoop:service=Router,name=FederationState',
- guard_with_startup_progress(function (resp) {
- var data = workaround(resp.beans[0]);
- var base = dust.makeBase(HELPERS);
- dust.render('namenode-info', base.push(data), function(err, out) {
- $('#tab-namenode').html(out);
- $('#ui-tabs a[href="#tab-namenode"]').tab('show');
- });
- })).error(ajax_error_handler);
- }
- function load_router_info() {
- var HELPERS = {
- 'helper_lastcontact_tostring' : function (chunk, ctx, bodies, params) {
- var value = dust.helpers.tap(params.value, chunk, ctx);
- return chunk.write('' + new Date(Date.now()-1000*Number(value)));
- }
- };
- function workaround(r) {
- function node_map_to_array(nodes) {
- var res = [];
- for (var n in nodes) {
- var p = nodes[n];
- p.name = n;
- res.push(p);
- }
- return res;
- }
- function capitalise(string) {
- return string.charAt(0).toUpperCase() + string.slice(1).toLowerCase();
- }
- function augment_routers(nodes) {
- for (var i = 0, e = nodes.length; i < e; ++i) {
- var n = nodes[i];
- n.title = "Unavailable"
- n.iconState = "unavailable";
- if (n.status === "INITIALIZING") {
- n.title = capitalise(n.status);
- n.iconState = "active";
- } else if (n.status === "RUNNING") {
- n.title = capitalise(n.status);
- n.iconState = "active";
- } else if (n.status === "SAFEMODE") {
- n.title = capitalise(n.status);
- n.iconState = "safemode";
- } else if (n.status === "STOPPING") {
- n.title = capitalise(n.status);
- n.iconState = "unavailable";
- } else if (n.status === "SHUTDOWN") {
- n.title = capitalise(n.status);
- n.iconState = "unavailable";
- }
- }
- }
- r.Routers = node_map_to_array(JSON.parse(r.Routers));
- augment_routers(r.Routers);
- return r;
- }
- $.get(
- '/jmx?qry=Hadoop:service=Router,name=FederationState',
- guard_with_startup_progress(function (resp) {
- var data = workaround(resp.beans[0]);
- var base = dust.makeBase(HELPERS);
- dust.render('router-info', base.push(data), function(err, out) {
- $('#tab-router').html(out);
- $('#ui-tabs a[href="#tab-router"]').tab('show');
- });
- })).error(ajax_error_handler);
- }
- // TODO Copied directly from dfshealth.js; is there a way to import this function?
- function load_datanode_info() {
- var HELPERS = {
- 'helper_relative_time' : function (chunk, ctx, bodies, params) {
- var value = dust.helpers.tap(params.value, chunk, ctx);
- return chunk.write(moment().subtract(Number(value), 'seconds').format('YYYY-MM-DD HH:mm:ss'));
- },
- 'helper_usage_bar' : function (chunk, ctx, bodies, params) {
- var value = dust.helpers.tap(params.value, chunk, ctx);
- var v = Number(value);
- var r = null;
- if (v < 70) {
- r = 'progress-bar-success';
- } else if (v < 85) {
- r = 'progress-bar-warning';
- } else {
- r = "progress-bar-danger";
- }
- return chunk.write(r);
- },
- };
- function workaround(r) {
- function node_map_to_array(nodes) {
- var res = [];
- for (var n in nodes) {
- var p = nodes[n];
- p.name = n;
- res.push(p);
- }
- return res;
- }
- function augment_live_nodes(nodes) {
- for (var i = 0, e = nodes.length; i < e; ++i) {
- var n = nodes[i];
- n.usedPercentage = Math.round((n.used + n.nonDfsUsedSpace) * 1.0 / n.capacity * 100);
- if (n.adminState === "In Service") {
- n.state = "alive";
- } else if (nodes[i].adminState === "Decommission In Progress") {
- n.state = "decommissioning";
- } else if (nodes[i].adminState === "Decommissioned") {
- n.state = "decommissioned";
- }
- }
- }
- function augment_dead_nodes(nodes) {
- for (var i = 0, e = nodes.length; i < e; ++i) {
- if (nodes[i].decommissioned) {
- nodes[i].state = "down-decommissioned";
- } else {
- nodes[i].state = "down";
- }
- }
- }
- r.LiveNodes = node_map_to_array(JSON.parse(r.LiveNodes));
- augment_live_nodes(r.LiveNodes);
- r.DeadNodes = node_map_to_array(JSON.parse(r.DeadNodes));
- augment_dead_nodes(r.DeadNodes);
- r.DecomNodes = node_map_to_array(JSON.parse(r.DecomNodes));
- return r;
- }
- $.get(
- '/jmx?qry=Hadoop:service=NameNode,name=NameNodeInfo',
- guard_with_startup_progress(function (resp) {
- var data = workaround(resp.beans[0]);
- var base = dust.makeBase(HELPERS);
- dust.render('datanode-info', base.push(data), function(err, out) {
- $('#tab-datanode').html(out);
- $('#table-datanodes').dataTable( {
- 'lengthMenu': [ [25, 50, 100, -1], [25, 50, 100, "All"] ],
- 'columns': [
- { 'orderDataType': 'ng-value', 'searchable': true },
- { 'orderDataType': 'ng-value', 'type': 'numeric' },
- { 'orderDataType': 'ng-value', 'type': 'numeric' },
- { 'orderDataType': 'ng-value', 'type': 'numeric'}
- ]});
- $('#ui-tabs a[href="#tab-datanode"]').tab('show');
- });
- })).error(ajax_error_handler);
- }
- function load_mount_table() {
- var HELPERS = {}
- function workaround(resource) {
- function augment_read_only(mountTable) {
- for (var i = 0, e = mountTable.length; i < e; ++i) {
- if (mountTable[i].readonly == true) {
- mountTable[i].readonly = "true"
- } else {
- mountTable[i].readonly = "false"
- }
- }
- }
- resource.MountTable = JSON.parse(resource.MountTable)
- augment_read_only(resource.MountTable)
- return resource;
- }
- $.get(
- '/jmx?qry=Hadoop:service=Router,name=FederationState',
- guard_with_startup_progress(function (resp) {
- var data = workaround(resp.beans[0]);
- var base = dust.makeBase(HELPERS);
- dust.render('mounttable', base.push(data), function(err, out) {
- $('#tab-mounttable').html(out);
- $('#ui-tabs a[href="#tab-mounttable"]').tab('show');
- });
- })).error(ajax_error_handler);
- }
- function toTitleCase(str) {
- return str.replace(/\w\S*/g, function(txt){
- return txt.charAt(0).toUpperCase() + txt.substr(1).toLowerCase();
- });
- }
- function show_err_msg(msg) {
- $('#alert-panel-body').html(msg);
- $('#alert-panel').show();
- }
- function ajax_error_handler(url, jqxhr, text, err) {
- show_err_msg('<p>Failed to retrieve data from ' + url + ', cause: ' + err + '</p>');
- }
- function guard_with_startup_progress(fn) {
- return function() {
- try {
- fn.apply(this, arguments);
- } catch (err) {
- if (err instanceof TypeError) {
- show_err_msg('Router error: ' + err);
- }
- }
- };
- }
- function load_page() {
- var hash = window.location.hash;
- switch(hash) {
- case "#tab-overview":
- load_overview();
- break;
- case "#tab-namenode":
- load_namenode_info();
- break;
- case "#tab-router":
- load_router_info();
- break;
- case "#tab-datanode":
- load_datanode_info();
- break;
- case "#tab-mounttable":
- load_mount_table();
- break;
- default:
- window.location.hash = "tab-overview";
- break;
- }
- }
- load_page();
- $(window).bind('hashchange', function () {
- load_page();
- });
- })();
|