View Javadoc

1   // Autogenerated Jamon implementation
2   // /Users/stack/checkouts/hbase.git/hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/master/RegionServerListTmpl.jamon
3   
4   package org.apache.hadoop.hbase.tmpl.master;
5   
6   // 27, 9
7   import java.util.*;
8   // 28, 9
9   import org.apache.hadoop.util.StringUtils;
10  // 29, 9
11  import org.apache.hadoop.hbase.util.Bytes;
12  // 30, 9
13  import org.apache.hadoop.hbase.util.JvmVersion;
14  // 31, 9
15  import org.apache.hadoop.hbase.util.FSUtils;
16  // 32, 9
17  import org.apache.hadoop.hbase.master.HMaster;
18  // 33, 9
19  import org.apache.hadoop.hbase.HConstants;
20  // 34, 9
21  import org.apache.hadoop.hbase.ServerLoad;
22  // 35, 9
23  import org.apache.hadoop.hbase.ServerName;
24  // 36, 9
25  import org.apache.hadoop.hbase.client.HBaseAdmin;
26  // 37, 9
27  import org.apache.hadoop.hbase.client.HConnectionManager;
28  // 38, 9
29  import org.apache.hadoop.hbase.HTableDescriptor;
30  // 39, 9
31  import org.apache.hadoop.hbase.HBaseConfiguration;
32  
33  public class RegionServerListTmplImpl
34    extends org.jamon.AbstractTemplateImpl
35    implements org.apache.hadoop.hbase.tmpl.master.RegionServerListTmpl.Intf
36  
37  {
38    private final HMaster master;
39    private final List<ServerName> servers;
40    protected static org.apache.hadoop.hbase.tmpl.master.RegionServerListTmpl.ImplData __jamon_setOptionalArguments(org.apache.hadoop.hbase.tmpl.master.RegionServerListTmpl.ImplData p_implData)
41    {
42      if(! p_implData.getServers__IsNotDefault())
43      {
44        p_implData.setServers(null);
45      }
46      return p_implData;
47    }
48    public RegionServerListTmplImpl(org.jamon.TemplateManager p_templateManager, org.apache.hadoop.hbase.tmpl.master.RegionServerListTmpl.ImplData p_implData)
49    {
50      super(p_templateManager, __jamon_setOptionalArguments(p_implData));
51      master = p_implData.getMaster();
52      servers = p_implData.getServers();
53    }
54    
55    public void renderNoFlush(@SuppressWarnings({"unused","hiding"}) final java.io.Writer jamonWriter)
56      throws java.io.IOException
57    {
58      // 43, 1
59      if ((servers != null && servers.size() > 0))
60      {
61        // 43, 47
62        jamonWriter.write("\n\n");
63        // 45, 1
64        
65  ServerName [] serverNames = servers.toArray(new ServerName[servers.size()]);
66  Arrays.sort(serverNames);
67  
68        // 50, 1
69        jamonWriter.write("<div class=\"tabbable\">\n    <ul class=\"nav nav-pills\">\n        <li class=\"active\"><a href=\"#tab_baseStats\" data-toggle=\"tab\">Base Stats</a></li>\n        <li class=\"\"><a href=\"#tab_memoryStats\" data-toggle=\"tab\">Memory</a></li>\n        <li class=\"\"><a href=\"#tab_requestStats\" data-toggle=\"tab\">Requests</a></li>\n        <li class=\"\"><a href=\"#tab_storeStats\" data-toggle=\"tab\">Storefiles</a></li>\n        <li class=\"\"><a href=\"#tab_compactStas\" data-toggle=\"tab\">Compactions</a></li>\n    </ul>\n    <div class=\"tab-content\" style=\"padding-bottom: 9px; border-bottom: 1px solid #ddd;\">\n        <div class=\"tab-pane active\" id=\"tab_baseStats\">\n            ");
70        // 60, 13
71        {
72          // 60, 13
73          __jamon_innerUnit__baseStats(jamonWriter, serverNames);
74        }
75        // 60, 56
76        jamonWriter.write("\n        </div>\n        <div class=\"tab-pane\" id=\"tab_memoryStats\">\n            ");
77        // 63, 13
78        {
79          // 63, 13
80          __jamon_innerUnit__memoryStats(jamonWriter, serverNames);
81        }
82        // 63, 58
83        jamonWriter.write("\n        </div>\n        <div class=\"tab-pane\" id=\"tab_requestStats\">\n            ");
84        // 66, 13
85        {
86          // 66, 13
87          __jamon_innerUnit__requestStats(jamonWriter, serverNames);
88        }
89        // 66, 59
90        jamonWriter.write("\n        </div>\n        <div class=\"tab-pane\" id=\"tab_storeStats\">\n            ");
91        // 69, 13
92        {
93          // 69, 13
94          __jamon_innerUnit__storeStats(jamonWriter, serverNames);
95        }
96        // 69, 57
97        jamonWriter.write("\n        </div>\n        <div class=\"tab-pane\" id=\"tab_compactStas\">\n            ");
98        // 72, 13
99        {
100         // 72, 13
101         __jamon_innerUnit__compactionStats(jamonWriter, serverNames);
102       }
103       // 72, 62
104       jamonWriter.write("\n        </div>\n    </div>\n</div>\n\n");
105     }
106     // 77, 7
107     jamonWriter.write("\n\n");
108   }
109   
110   
111   // 279, 1
112   private void __jamon_innerUnit__serverNameLink(@SuppressWarnings({"unused","hiding"}) final java.io.Writer jamonWriter, final ServerName serverName, final ServerLoad serverLoad)
113     throws java.io.IOException
114   {
115     // 284, 9
116     
117         int infoPort = master.getRegionServerInfoPort(serverName);
118         String url = "//" + serverName.getHostname() + ":" + infoPort + "/rs-status";
119         
120     // 289, 9
121     if ((infoPort > 0) )
122     {
123       // 289, 31
124       jamonWriter.write("\n            <a href=\"");
125       // 290, 22
126       org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(url), jamonWriter);
127       // 290, 31
128       jamonWriter.write("\">");
129       // 290, 33
130       org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(serverName.getServerName()), jamonWriter);
131       // 290, 65
132       jamonWriter.write("</a>\n        ");
133     }
134     // 291, 9
135     else
136     {
137       // 291, 16
138       jamonWriter.write("\n            ");
139       // 292, 13
140       org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(serverName.getServerName()), jamonWriter);
141       // 292, 45
142       jamonWriter.write("\n        ");
143     }
144     // 293, 15
145     jamonWriter.write("\n");
146   }
147   
148   
149   // 197, 1
150   private void __jamon_innerUnit__storeStats(@SuppressWarnings({"unused","hiding"}) final java.io.Writer jamonWriter, final ServerName[] serverNames)
151     throws java.io.IOException
152   {
153     // 201, 1
154     jamonWriter.write("<table class=\"table table-striped\">\n<tr>\n    <th>ServerName</th>\n    <th>Num. Stores</th>\n    <th>Num. Storefiles</th>\n    <th>Storefile Size Uncompressed</th>\n    <th>Storefile Size</th>\n    <th>Index Size</th>\n    <th>Bloom Size</th>\n</tr>\n");
155     // 211, 1
156     
157 for (ServerName serverName: serverNames) {
158 
159 ServerLoad sl = master.getServerManager().getLoad(serverName);
160 if (sl != null) {
161 
162     // 217, 1
163     jamonWriter.write("<tr>\n<td>");
164     // 218, 5
165     {
166       // 218, 5
167       __jamon_innerUnit__serverNameLink(jamonWriter, serverName, sl);
168     }
169     // 218, 66
170     jamonWriter.write("</td>\n<td>");
171     // 219, 5
172     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getStores()), jamonWriter);
173     // 219, 25
174     jamonWriter.write("</td>\n<td>");
175     // 220, 5
176     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getStorefiles()), jamonWriter);
177     // 220, 29
178     jamonWriter.write("</td>\n<td>");
179     // 221, 5
180     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getStoreUncompressedSizeMB()), jamonWriter);
181     // 221, 42
182     jamonWriter.write("m</td>\n<td>");
183     // 222, 5
184     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getStorefileSizeInMB()), jamonWriter);
185     // 222, 36
186     jamonWriter.write("mb</td>\n<td>");
187     // 223, 5
188     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getTotalStaticIndexSizeKB()), jamonWriter);
189     // 223, 41
190     jamonWriter.write("k</td>\n<td>");
191     // 224, 5
192     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getTotalStaticBloomSizeKB()), jamonWriter);
193     // 224, 41
194     jamonWriter.write("k</td>\n</tr>\n");
195     // 226, 1
196     
197         }  else {
198         
199     // 229, 1
200     {
201       // 229, 1
202       __jamon_innerUnit__emptyStat(jamonWriter, serverName);
203     }
204     // 229, 40
205     jamonWriter.write("\n");
206     // 230, 1
207     
208     }
209 }
210 
211     // 234, 1
212     jamonWriter.write("</table>\n");
213   }
214   
215   
216   // 162, 1
217   private void __jamon_innerUnit__requestStats(@SuppressWarnings({"unused","hiding"}) final java.io.Writer jamonWriter, final ServerName[] serverNames)
218     throws java.io.IOException
219   {
220     // 166, 1
221     jamonWriter.write("<table class=\"table table-striped\">\n<tr>\n    <th>ServerName</th>\n    <th>Request Per Second</th>\n    <th>Read Request Count</th>\n    <th>Write Request Count</th>\n</tr>\n");
222     // 173, 1
223     
224 for (ServerName serverName: serverNames) {
225 
226 ServerLoad sl = master.getServerManager().getLoad(serverName);
227 if (sl != null) {
228 
229     // 179, 1
230     jamonWriter.write("<tr>\n<td>");
231     // 180, 5
232     {
233       // 180, 5
234       __jamon_innerUnit__serverNameLink(jamonWriter, serverName, sl);
235     }
236     // 180, 66
237     jamonWriter.write("</td>\n<td>");
238     // 181, 5
239     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(String.format("%.0f", sl.getRequestsPerSecond())), jamonWriter);
240     // 181, 59
241     jamonWriter.write("</td>\n<td>");
242     // 182, 5
243     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getReadRequestsCount()), jamonWriter);
244     // 182, 36
245     jamonWriter.write("</td>\n<td>");
246     // 183, 5
247     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getWriteRequestsCount()), jamonWriter);
248     // 183, 37
249     jamonWriter.write("</td>\n</tr>\n");
250     // 185, 1
251     
252         }  else {
253         
254     // 188, 1
255     {
256       // 188, 1
257       __jamon_innerUnit__emptyStat(jamonWriter, serverName);
258     }
259     // 188, 40
260     jamonWriter.write("\n");
261     // 189, 1
262     
263         }
264 }
265 
266     // 193, 1
267     jamonWriter.write("</table>\n");
268   }
269   
270   
271   // 125, 1
272   private void __jamon_innerUnit__memoryStats(@SuppressWarnings({"unused","hiding"}) final java.io.Writer jamonWriter, final ServerName[] serverNames)
273     throws java.io.IOException
274   {
275     // 129, 1
276     jamonWriter.write("<table class=\"table table-striped\">\n<tr>\n    <th>ServerName</th>\n    <th>Used Heap</th>\n    <th>Max Heap</th>\n    <th>Memstore Size</th>\n\n</tr>\n");
277     // 137, 1
278     
279 for (ServerName serverName: serverNames) {
280 
281     ServerLoad sl = master.getServerManager().getLoad(serverName);
282     if (sl != null) {
283 
284     // 143, 1
285     jamonWriter.write("<tr>\n    <td>");
286     // 144, 9
287     {
288       // 144, 9
289       __jamon_innerUnit__serverNameLink(jamonWriter, serverName, sl);
290     }
291     // 144, 70
292     jamonWriter.write("</td>\n    <td>");
293     // 145, 9
294     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getUsedHeapMB()), jamonWriter);
295     // 145, 33
296     jamonWriter.write("m</td>\n    <td>");
297     // 146, 9
298     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getMaxHeapMB()), jamonWriter);
299     // 146, 32
300     jamonWriter.write("m</td>\n    <td>");
301     // 147, 9
302     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getMemstoreSizeInMB()), jamonWriter);
303     // 147, 39
304     jamonWriter.write("m</td>\n\n</tr>\n");
305     // 150, 1
306     
307         }  else {
308 
309     // 153, 1
310     {
311       // 153, 1
312       __jamon_innerUnit__emptyStat(jamonWriter, serverName);
313     }
314     // 153, 40
315     jamonWriter.write("\n");
316     // 154, 1
317     
318         }
319 }
320 
321     // 158, 1
322     jamonWriter.write("</table>\n");
323   }
324   
325   
326   // 237, 1
327   private void __jamon_innerUnit__compactionStats(@SuppressWarnings({"unused","hiding"}) final java.io.Writer jamonWriter, final ServerName[] serverNames)
328     throws java.io.IOException
329   {
330     // 241, 1
331     jamonWriter.write("<table class=\"table table-striped\">\n<tr>\n    <th>ServerName</th>\n    <th>Num. Compacting KVs</th>\n    <th>Num. Compacted KVs</th>\n    <th>Remaining KVs</th>\n    <th>Compaction Progress</th>\n</tr>\n");
332     // 249, 1
333     
334 for (ServerName serverName: serverNames) {
335 
336 ServerLoad sl = master.getServerManager().getLoad(serverName);
337 if (sl != null) {
338 String percentDone = "";
339 if  (sl.getTotalCompactingKVs() > 0) {
340      percentDone = String.format("%.2f", 100 *
341         ((float) sl.getCurrentCompactedKVs() / sl.getTotalCompactingKVs())) + "%";
342 }
343 
344     // 260, 1
345     jamonWriter.write("<tr>\n<td>");
346     // 261, 5
347     {
348       // 261, 5
349       __jamon_innerUnit__serverNameLink(jamonWriter, serverName, sl);
350     }
351     // 261, 66
352     jamonWriter.write("</td>\n<td>");
353     // 262, 5
354     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getTotalCompactingKVs()), jamonWriter);
355     // 262, 37
356     jamonWriter.write("</td>\n<td>");
357     // 263, 5
358     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getCurrentCompactedKVs()), jamonWriter);
359     // 263, 38
360     jamonWriter.write("</td>\n<td>");
361     // 264, 5
362     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(sl.getTotalCompactingKVs() - sl.getCurrentCompactedKVs()), jamonWriter);
363     // 264, 67
364     jamonWriter.write("</td>\n<td>");
365     // 265, 5
366     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(percentDone), jamonWriter);
367     // 265, 22
368     jamonWriter.write("</td>\n</tr>\n");
369     // 267, 1
370     
371         }  else {
372         
373     // 270, 1
374     {
375       // 270, 1
376       __jamon_innerUnit__emptyStat(jamonWriter, serverName);
377     }
378     // 270, 40
379     jamonWriter.write("\n");
380     // 271, 1
381     
382     }
383 }
384 
385     // 275, 1
386     jamonWriter.write("</table>\n");
387   }
388   
389   
390   // 79, 1
391   private void __jamon_innerUnit__baseStats(@SuppressWarnings({"unused","hiding"}) final java.io.Writer jamonWriter, final ServerName[] serverNames)
392     throws java.io.IOException
393   {
394     // 83, 1
395     jamonWriter.write("<table class=\"table table-striped\">\n<tr>\n    <th>ServerName</th>\n    <th>Start time</th>\n    <th>Requests Per Second</th>\n    <th>Num. Regions</th>\n</tr>\n");
396     // 90, 1
397     
398     int totalRegions = 0;
399     int totalRequests = 0;
400     for (ServerName serverName: serverNames) {
401 
402     ServerLoad sl = master.getServerManager().getLoad(serverName);
403     double requestsPerSecond = 0.0;
404     int numRegionsOnline = 0;
405 
406     if (sl != null) {
407         requestsPerSecond = sl.getRequestsPerSecond();
408         numRegionsOnline = sl.getNumberOfRegions();
409         totalRegions += sl.getNumberOfRegions();
410         // Is this correct?  Adding a rate to a measure.
411         totalRequests += sl.getNumberOfRequests();
412     }
413     long startcode = serverName.getStartcode();
414 
415     // 108, 1
416     jamonWriter.write("<tr>\n    <td>");
417     // 109, 9
418     {
419       // 109, 9
420       __jamon_innerUnit__serverNameLink(jamonWriter, serverName, sl);
421     }
422     // 109, 70
423     jamonWriter.write("</td>\n    <td>");
424     // 110, 9
425     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(new Date(startcode)), jamonWriter);
426     // 110, 34
427     jamonWriter.write("</td>\n    <td>");
428     // 111, 9
429     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(String.format("%.0f", requestsPerSecond)), jamonWriter);
430     // 111, 55
431     jamonWriter.write("</td>\n    <td>");
432     // 112, 9
433     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(numRegionsOnline), jamonWriter);
434     // 112, 31
435     jamonWriter.write("</td>\n</tr>\n");
436     // 114, 1
437     
438 }
439 
440     // 117, 1
441     jamonWriter.write("<tr><td>Total:");
442     // 117, 15
443     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(servers.size()), jamonWriter);
444     // 117, 35
445     jamonWriter.write("</td>\n<td></td>\n<td>");
446     // 119, 5
447     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(totalRequests), jamonWriter);
448     // 119, 24
449     jamonWriter.write("</td>\n<td>");
450     // 120, 5
451     org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(totalRegions), jamonWriter);
452     // 120, 23
453     jamonWriter.write("</td>\n</tr>\n</table>\n");
454   }
455   
456   
457   // 296, 1
458   private void __jamon_innerUnit__emptyStat(@SuppressWarnings({"unused","hiding"}) final java.io.Writer jamonWriter, final ServerName serverName)
459     throws java.io.IOException
460   {
461     // 300, 5
462     jamonWriter.write("<tr>\n    <td>");
463     // 301, 9
464     {
465       // 301, 9
466       __jamon_innerUnit__serverNameLink(jamonWriter, serverName, null);
467     }
468     // 301, 72
469     jamonWriter.write("</td>\n    <td></td>\n    <td></td>\n    <td></td>\n    <td></td>\n    <td></td>\n    <td></td>\n    </tr>\n");
470   }
471   
472   
473 }