| /* |
| Copyright 2012 IBM |
| |
| Licensed 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. |
| */ |
| |
| window.Switch = Backbone.Model.extend({ |
| |
| urlRoot:"/fl/core/switch/", |
| |
| defaults: { |
| datapathDescription: '', |
| hardwareDescription: '', |
| manufacturerDescription: '', |
| serialNumber: '', |
| softwareDescription: '', |
| flowCount: ' ', |
| packetCount: ' ', |
| byteCount: ' ', |
| }, |
| |
| initialize:function () { |
| var self = this; |
| |
| //console.log("fetching switch " + this.id + " desc") |
| $.ajax({ |
| url:hackBase + "/fl/core/switch/" + self.id + '/desc/json', |
| dataType:"json", |
| success:function (data) { |
| //console.log("fetched switch " + self.id + " desc"); |
| //console.log(data[self.id][0]); |
| self.set(data[self.id][0]); |
| } |
| }); |
| |
| //console.log("fetching switch " + this.id + " aggregate") |
| $.ajax({ |
| url:hackBase + "/fl/core/switch/" + self.id + '/aggregate/json', |
| dataType:"json", |
| success:function (data) { |
| //console.log("fetched switch " + self.id + " aggregate"); |
| //console.log(data[self.id][0]); |
| self.set(data[self.id][0]); |
| } |
| }); |
| self.trigger('add'); |
| this.ports = new PortCollection(); |
| this.flows = new FlowCollection(); |
| //this.loadPorts(); |
| //this.loadFlows(); |
| }, |
| |
| fetch:function () { |
| this.initialize() |
| }, |
| |
| loadPorts:function () { |
| var self = this; |
| //console.log("fetching switch " + this.id + " ports") |
| //console.log("fetching switch " + this.id + " features") |
| $.when($.ajax({ |
| url:hackBase + "/fl/core/switch/" + self.id + '/port/json', |
| dataType:"json", |
| success:function (data) { |
| //console.log("fetched switch " + self.id + " ports"); |
| //console.log(data[self.id]); |
| var old_ids = self.ports.pluck('id'); |
| //console.log("old_ids" + old_ids); |
| |
| // create port models |
| _.each(data[self.id], function(p) { |
| // workaround for REST serialization signed/unsigned bug |
| if(p.portNumber < 0) {p.portNumber = 65536 + p.portNumber}; |
| |
| p.id = self.id+'-'+p.portNumber; |
| old_ids = _.without(old_ids, p.id); |
| p.dropped = p.receiveDropped + p.transmitDropped; |
| p.errors = p.receiveCRCErrors + p.receiveErrors + p.receiveOverrunErrors + |
| p.receiveFrameErrors + p.transmitErrors; |
| // this is a knda kludgy way to merge models |
| var m = self.ports.get(p.id); |
| if(m) { |
| m.set(p, {silent: true}); |
| } else { |
| self.ports.add(p, {silent: true}); |
| } |
| //console.log(p); |
| }); |
| |
| // old_ids now holds ports that no longer exist; remove them |
| //console.log("old_ids" + old_ids); |
| _.each(old_ids, function(p) { |
| console.log("removing port " + p); |
| self.remove({id:p}); |
| }); |
| } |
| }), |
| $.ajax({ |
| url:hackBase + "/fl/core/switch/" + self.id + '/features/json', |
| dataType:"json", |
| success:function (data) { |
| //console.log("fetched switch " + self.id + " features"); |
| //console.log(data[self.id]); |
| // update port models |
| _.each(data[self.id].ports, function(p) { |
| p.id = self.id+'-'+p.portNumber; |
| if(p.name != p.portNumber) { |
| p.name = p.portNumber + ' (' + p.name + ')'; |
| } |
| p.status = ''; |
| p.status += (p.state & 1) ? 'DOWN' : 'UP'; |
| switch(p.currentFeatures & 0x7f) { |
| case 1: |
| p.status += ' 10 Mbps'; |
| break; |
| case 2: |
| p.status += ' 10 Mbps FDX'; |
| break; |
| case 4: |
| p.status += ' 100 Mbps'; |
| break; |
| case 8: |
| p.status += ' 100 Mbps FDX'; |
| break; |
| case 16: |
| p.status += ' 1 Gbps'; // RLY? |
| break; |
| case 32: |
| p.status += ' 1 Gbps FDX'; |
| break; |
| case 64: |
| p.status += ' 10 Gbps FDX'; |
| break; |
| } |
| // TODO parse copper/fiber, autoneg, pause |
| |
| // this is a knda kludgy way to merge models |
| var m = self.ports.get(p.id); |
| if(m) { |
| m.set(p, {silent: true}); |
| } else { |
| self.ports.add(p, {silent: true}); |
| } |
| //console.log(p); |
| }); |
| } |
| })).done(function() { |
| self.ports.trigger('add'); // batch redraws |
| }); |
| }, |
| |
| loadFlows:function () { |
| var self = this; |
| //console.log("fetching switch " + this.id + " flows") |
| $.ajax({ |
| url:hackBase + "/fl/core/switch/" + self.id + '/flow/json', |
| dataType:"json", |
| success:function (data) { |
| //console.log("fetched switch " + self.id + " flows"); |
| var flows = data[self.id]; |
| //console.log(flows); |
| |
| // create flow models |
| var i = 0; |
| _.each(flows, function(f) { |
| f.id = self.id + '-' + i++; |
| |
| // build human-readable match |
| f.matchHTML = ''; |
| if(!(f.match.wildcards & (1<<0))) { // input port |
| f.matchHTML += "port=" + f.match.inputPort + ", "; |
| } |
| if(!(f.match.wildcards & (1<<1))) { // VLAN ID |
| f.matchHTML += "VLAN=" + f.match.dataLayerVirtualLan + ", "; |
| } |
| if(!(f.match.wildcards & (1<<20))) { // VLAN prio |
| f.matchHTML += "prio=" + f.match.dataLayerVirtualLanPriorityCodePoint + ", "; |
| } |
| if(!(f.match.wildcards & (1<<2))) { // src MAC |
| f.matchHTML += "src=<a href='/host/" + f.match.dataLayerSource + "'>" + |
| f.match.dataLayerSource + "</a>, "; |
| } |
| if(!(f.match.wildcards & (1<<3))) { // dest MAC |
| f.matchHTML += "dest=<a href='/host/" + f.match.dataLayerDestination + "'>" + |
| f.match.dataLayerDestination + "</a>, "; |
| } |
| if(!(f.match.wildcards & (1<<4))) { // Ethertype |
| // TODO print a human-readable name instead of hex |
| f.matchHTML += "ethertype=" + f.match.dataLayerType + ", "; |
| } |
| if(!(f.match.wildcards & (1<<5))) { // IP protocol |
| // TODO print a human-readable name |
| f.matchHTML += "proto=" + f.match.networkProtocol + ", "; |
| } |
| if(!(f.match.wildcards & (1<<6))) { // TCP/UDP source port |
| f.matchHTML += "IP src port=" + f.match.transportSource + ", "; |
| } |
| if(!(f.match.wildcards & (1<<7))) { // TCP/UDP dest port |
| f.matchHTML += "IP dest port=" + f.match.transportDestination + ", "; |
| } |
| if(!(f.match.wildcards & (32<<8))) { // src IP |
| f.matchHTML += "src=" + f.match.networkSource + ", "; |
| } |
| if(!(f.match.wildcards & (32<<14))) { // dest IP |
| f.matchHTML += "dest=" + f.match.networkDestination + ", "; |
| } |
| if(!(f.match.wildcards & (1<<21))) { // IP TOS |
| f.matchHTML += "TOS=" + f.match.networkTypeOfService + ", "; |
| } |
| // remove trailing ", " |
| f.matchHTML = f.matchHTML.substr(0, f.matchHTML.length - 2); |
| |
| // build human-readable action list |
| f.actionText = _.reduce(f.actions, function (memo, a) { |
| switch (a.type) { |
| case "OUTPUT": |
| return memo + "output " + a.port + ', '; |
| case "OPAQUE_ENQUEUE": |
| return memo + "enqueue " + a.port + ':' + a.queueId + ', '; |
| case "STRIP_VLAN": |
| return memo + "strip VLAN, "; |
| case "SET_VLAN_ID": |
| return memo + "VLAN=" + a.virtualLanIdentifier + ', '; |
| case "SET_VLAN_PCP": |
| return memo + "prio=" + a.virtualLanPriorityCodePoint + ', '; |
| case "SET_DL_SRC": |
| return memo + "src=" + a.dataLayerAddress + ', '; |
| case "SET_DL_DST": |
| return memo + "dest=" + a.dataLayerAddress + ', '; |
| case "SET_NW_TOS": |
| return memo + "TOS=" + a.networkTypeOfService + ', '; |
| case "SET_NW_SRC": |
| return memo + "src=" + a.networkAddress + ', '; |
| case "SET_NW_DST": |
| return memo + "dest=" + a.networkAddress + ', '; |
| case "SET_TP_SRC": |
| return memo + "src port=" + a.transportPort + ', '; |
| case "SET_TP_DST": |
| return memo + "dest port=" + a.transportPort + ', '; |
| } |
| }, ""); |
| // remove trailing ", " |
| f.actionText = f.actionText.substr(0, f.actionText.length - 2); |
| |
| //console.log(f); |
| self.flows.add(f, {silent: true}); |
| }); |
| self.flows.trigger('add'); |
| } |
| }); |
| }, |
| }); |
| |
| window.SwitchCollection = Backbone.Collection.extend({ |
| |
| model:Switch, |
| |
| fetch:function () { |
| var self = this; |
| //console.log("fetching switch list") |
| $.ajax({ |
| url:hackBase + "/fl/core/controller/switches/json", |
| dataType:"json", |
| success:function (data) { |
| //console.log("fetched switch list: " + data.length); |
| //console.log(data); |
| var old_ids = self.pluck('id'); |
| //console.log("old_ids" + old_ids); |
| |
| _.each(data, function(sw) { |
| old_ids = _.without(old_ids, sw['dpid']); |
| self.add({id: sw['dpid'], inetAddress: sw.inetAddress, |
| connectedSince: new Date(sw.connectedSince).toLocaleString()})}); |
| |
| // old_ids now holds switches that no longer exist; remove them |
| //console.log("old_ids" + old_ids); |
| _.each(old_ids, function(sw) { |
| console.log("removing switch " + sw); |
| self.remove({id:sw}); |
| }); |
| }, |
| }); |
| }, |
| |
| }); |