Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 1 | var enableIPerfLog = false; |
| 2 | |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 3 | function iperfLog(message, flow) { |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 4 | if (enableIPerfLog) { |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 5 | console.log('flow: ' + flow.flowId + '===>' + message); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 6 | } |
| 7 | } |
| 8 | |
| 9 | function hasIPerf(flow) { |
| 10 | return flow && flow.iperfFetchTimeout; |
| 11 | } |
| 12 | |
| 13 | function clearIPerf(flow) { |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 14 | iperfLog('clearing iperf interval for: ' + flow.flowId, flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 15 | clearTimeout(flow.iperfFetchTimeout); |
| 16 | delete flow.iperfFetchTimeout; |
| 17 | clearInterval(flow.iperfDisplayInterval); |
| 18 | delete flow.iperfDisplayInterval; |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 19 | clearTimeout(flow.animationTimeout); |
| 20 | delete flow.animationTimeout; |
| 21 | stopFlowAnimation(flow); |
| 22 | delete flow.iperfData.timestamp; |
| 23 | |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 24 | delete flow.iperfData; |
| 25 | } |
| 26 | |
| 27 | function startIPerfForFlow(flow) { |
| 28 | var duration = 10000; // seconds |
| 29 | var interval = 100; // ms. this is defined by the server |
| 30 | var updateRate = 3000; // ms |
| 31 | var pointsToDisplay = 1000; |
| 32 | |
| 33 | function makeGraph(iperfData) { |
| 34 | var d = 'M0,0'; |
| 35 | |
| 36 | var now = flow.iperfData.startTime + (Date.now() - flow.iperfData.localNow)/1000; |
| 37 | |
| 38 | if (iperfData.samples && iperfData.samples.length) { |
| 39 | |
| 40 | var lastX; |
| 41 | var i = iperfData.samples.length - 1; |
| 42 | while (i) { |
| 43 | var sample = iperfData.samples[i]; |
| 44 | |
| 45 | var x = (1000 - (now - sample.time)*10); |
| 46 | // workaround for discontinuity in iperf data |
| 47 | if (x < 0) { |
| 48 | i -= 1; |
| 49 | continue; |
| 50 | } |
| 51 | |
| 52 | var y = 28 * sample.value/1000000; |
| 53 | if (y > 28) { |
| 54 | y = 28; |
| 55 | } |
| 56 | if (i == iperfData.samples.length - 1) { |
| 57 | d = 'M' + x + ',30'; |
| 58 | } |
| 59 | |
| 60 | // handle gaps |
| 61 | // 1.5 for rounding error |
| 62 | if (lastX && lastX - x > 1.5) { |
| 63 | d += 'L' + lastX + ',30'; |
| 64 | d += 'M' + x + ',30' |
| 65 | } |
| 66 | lastX = x; |
| 67 | |
| 68 | d += 'L' + x + ',' + (30-y); |
| 69 | |
| 70 | i -= 1; |
| 71 | } |
| 72 | d += 'L' + lastX + ',30'; |
| 73 | } |
| 74 | return d; |
| 75 | } |
| 76 | |
| 77 | if (flow.flowId) { |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 78 | iperfLog('starting iperf', flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 79 | startIPerf(flow, duration, updateRate/interval); |
| 80 | flow.iperfDisplayInterval = setInterval(function () { |
| 81 | if (flow.iperfData) { |
| 82 | var iperfPath = d3.select(document.getElementById(makeSelectedFlowKey(flow))).select('path'); |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 83 | flow.iperfData.samples.sort(function (a, b) { |
| 84 | return a.time - b.time; |
| 85 | }); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 86 | iperfPath.attr('d', makeGraph(flow.iperfData)); |
| 87 | } |
| 88 | |
| 89 | |
| 90 | }, interval); |
| 91 | |
| 92 | var animationTimeout; |
| 93 | flow.iperfData = { |
| 94 | samples: [] |
| 95 | } |
| 96 | |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 97 | function resetFlowAnimationTimeout() { |
| 98 | clearTimeout(flow.animationTimeout); |
| 99 | // kill the animation if iperfdata stops flowing |
| 100 | flow.animationTimeout = setTimeout(function () { |
| 101 | stopFlowAnimation(flow); |
| 102 | }, updateRate*1.5); |
| 103 | } |
| 104 | |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 105 | var lastTime; |
| 106 | function fetchData() { |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 107 | iperfLog('Requesting iperf data', flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 108 | var fetchTime = Date.now(); |
| 109 | getIPerfData(flow, function (data) { |
| 110 | var requestTime = Date.now() - fetchTime; |
| 111 | var requestTimeMessage = 'iperf request completed in: ' + requestTime + 'ms'; |
| 112 | if (requestTime > 1000) { |
| 113 | requestTimeMessage = requestTimeMessage.toUpperCase(); |
| 114 | } |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 115 | iperfLog(requestTimeMessage, flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 116 | |
| 117 | if (!flow.iperfData) { |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 118 | iperfLog('iperf session closed', flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 119 | return; |
| 120 | } |
| 121 | |
| 122 | try { |
| 123 | var iperfData = JSON.parse(data); |
| 124 | |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 125 | // iperfLog(iperfData.timestamp, flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 126 | |
| 127 | // if the data is fresh |
| 128 | if (!(flow.iperfData.timestamp && iperfData.timestamp != flow.iperfData.timestamp)) { |
| 129 | if (!flow.iperfData.timestamp) { |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 130 | iperfLog('received first iperf buffer', flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 131 | } else { |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 132 | iperfLog('received duplicate iperf buffer with timestamp: ' + iperfData.timestamp, flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 133 | } |
| 134 | } else { |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 135 | iperfLog('received new iperf buffer with timstamp: ' + iperfData.timestamp, flow); |
| 136 | startFlowAnimation(flow); |
| 137 | resetFlowAnimationTimeout(); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 138 | |
| 139 | var endTime = Math.floor(iperfData['end-time']*10)/10; |
| 140 | |
| 141 | var startTime = endTime - (iperfData.samples.length * interval/1000); |
| 142 | // set now on the first buffer |
| 143 | if (!flow.iperfData.startTime) { |
| 144 | flow.iperfData.startTime = startTime; |
| 145 | flow.iperfData.localNow = Date.now(); |
| 146 | } |
| 147 | |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 148 | iperfLog('iperf buffer start time: ' + startTime, flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 149 | if (lastTime && (startTime - lastTime) > updateRate/1000) { |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 150 | iperfLog('iperf buffer gap: ' + (startTime - lastTime), flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 151 | } |
| 152 | lastTime = startTime; |
| 153 | |
| 154 | // clear out the old data |
| 155 | while (flow.iperfData.samples.length > pointsToDisplay + iperfData.samples.length) { |
| 156 | flow.iperfData.samples.shift(); |
| 157 | } |
| 158 | |
| 159 | // if the client gets too out of sync, resynchronize |
| 160 | var clientNow = flow.iperfData.startTime + (Date.now() - flow.iperfData.localNow)/1000; |
| 161 | if (Math.abs(clientNow - startTime) > (updateRate/1000) * 2) { |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 162 | iperfLog('resynchronizing now: ' + clientNow + ' => ' + startTime, flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 163 | flow.iperfData.startTime = startTime; |
| 164 | flow.iperfData.localNow = Date.now(); |
| 165 | } |
| 166 | |
| 167 | var time = startTime; |
| 168 | iperfData.samples.forEach(function (s) { |
| 169 | var sample = { |
| 170 | time: time, |
| 171 | value: s |
| 172 | }; |
| 173 | flow.iperfData.samples.push(sample); |
| 174 | time += interval/1000; |
| 175 | }); |
| 176 | } |
| 177 | flow.iperfData.timestamp = iperfData.timestamp; |
| 178 | } catch (e) { |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 179 | iperfLog('bad iperf data: ' + data, flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 180 | } |
| 181 | flow.iperfFetchTimeout = setTimeout(fetchData, updateRate*.25); // over sample to avoid gaps |
Paul Greyson | eeb6996 | 2013-04-12 15:53:29 -0700 | [diff] [blame^] | 182 | // iperfLog(data, flow); |
Paul Greyson | 17f8447 | 2013-04-12 14:39:21 -0700 | [diff] [blame] | 183 | }); |
| 184 | } |
| 185 | fetchData(); |
| 186 | |
| 187 | } |
| 188 | } |