- Timestamp:
- 11/26/13 11:56:07 (11 years ago)
- Location:
- DCWoRMS/branches/coolemall/src/simulator/stats/implementation/out
- Files:
-
- 3 edited
-
CoolEmAllStringSerializer.java (modified) (12 diffs)
-
StatsSerializer.java (modified) (2 diffs)
-
StringSerializer.java (modified) (8 diffs)
Legend:
- Unmodified
- Added
- Removed
-
DCWoRMS/branches/coolemall/src/simulator/stats/implementation/out/CoolEmAllStringSerializer.java
r1140 r1207 1 1 package simulator.stats.implementation.out; 2 2 3 import java.text.DecimalFormat; 3 4 import java.util.Map; 4 5 … … 7 8 8 9 import schedframe.resources.CoolEmAllResourceType; 10 import schedframe.resources.ResourceHistoryChanges; 9 11 import schedframe.resources.StandardResourceType; 12 import simulator.stats.implementation.MetricsStats; 10 13 import simulator.stats.implementation.ResourceAirFlowStats; 14 import simulator.stats.implementation.ResourceAvailabilityStats; 15 import simulator.stats.implementation.ResourceHistoryStats; 11 16 import simulator.stats.implementation.ResourcePowerStats; 12 17 import simulator.stats.implementation.ResourceTemperatureStats; 13 18 import simulator.stats.implementation.ResourceUsageStats; 19 import simulator.stats.implementation.ResourceUsefulWorkStats; 14 20 15 21 public class CoolEmAllStringSerializer extends StringSerializer { … … 19 25 public Object visit(ResourceUsageStats resourceUsageStats) { 20 26 Map<Long, Double> resourceUsage = resourceUsageStats.getHistory(); 21 String cpuMetricName = "CPU_Load"; 27 //String metricName = "cpu_load"; 28 String metricName = resourceUsageStats.getUsageType(); 22 29 int mapSize = resourceUsage.size(); 23 30 /* … … 45 52 } 46 53 47 if( resourceUsageStats.getResourceType().equals(StandardResourceType.Processor) || resourceUsageStats.getResourceType().equals(CoolEmAllResourceType.Processor)){54 if(!resourceUsageStats.getResourceType().getName().equals(StandardResourceType.Core.getName()) && !resourceUsageStats.getResourceType().getName().equals(CoolEmAllResourceType.Core.getName())){ 48 55 for (Long timestamp : resourceUsage.keySet()) { 49 56 50 buffer.append(cpuMetricName); 51 buffer.append(fieldSeparator); 52 buffer.append(resourceUsageStats.getResourceName()); 57 buffer.append(metricName); 58 buffer.append(fieldSeparator); 59 if(resourceUsageStats.getResourceName().startsWith("/")) 60 buffer.append(resourceUsageStats.getResourceName().substring(1)); 61 else buffer.append(resourceUsageStats.getResourceName()); 53 62 buffer.append(fieldSeparator); 54 63 Double value = resourceUsage.get(timestamp); … … 73 82 public Object visit(ResourcePowerStats resourceEnergyStats) { 74 83 Map<Long, Double> resourceEnergy = resourceEnergyStats.getHistory(); 75 String nodeMetricName = "RECS_Power"; 84 //String nodeMetricName = "power"; 85 String metricName = resourceEnergyStats.getUsageType(); 76 86 int mapSize = resourceEnergy.size(); 77 87 /* … … 98 108 buffer = new StringBuffer(size); 99 109 } 100 101 if(resourceEnergyStats.getResourceType().equals(StandardResourceType.ComputingNode) || resourceEnergyStats.getResourceType().equals(CoolEmAllResourceType.Node)){ 110 //if(resourceEnergyStats.getResourceType().getName().equals(StandardResourceType.ComputingNode.getName()) || resourceEnergyStats.getResourceType().getName().equals(CoolEmAllResourceType.Node.getName()) || 111 //resourceEnergyStats.getResourceType().getName().equals(StandardResourceType.Inlet.getName()) || resourceEnergyStats.getResourceType().getName().equals(StandardResourceType.Outlet.getName()) || 112 // resourceEnergyStats.getResourceType().getName().equals(StandardResourceType.Heatsink.getName())){ 113 102 114 for (Long timestamp : resourceEnergy.keySet()) { 103 115 104 buffer.append( nodeMetricName);116 buffer.append(metricName); 105 117 buffer.append(fieldSeparator); 106 118 if(resourceEnergyStats.getResourceName().startsWith("/")) … … 117 129 buffer.append(System.getProperty("line.separator")); 118 130 } 119 }131 // } 120 132 121 133 int lastIdx = buffer.lastIndexOf(System.getProperty("line.separator")); … … 129 141 public Object visit(ResourceAirFlowStats resourceAirFlowStats) { 130 142 Map<Long, Double> resourceAirFlow = resourceAirFlowStats.getHistory(); 131 String nodeMetricName = "RECS_Airflow"; 143 //String nodeMetricName = "airflow_volume"; 144 String metricName = resourceAirFlowStats.getUsageType(); 132 145 int mapSize = resourceAirFlow.size(); 133 146 /* … … 154 167 buffer = new StringBuffer(size); 155 168 } 156 157 if(resourceAirFlowStats.getResourceType(). equals(StandardResourceType.ComputingNode) || resourceAirFlowStats.getResourceType().equals(CoolEmAllResourceType.Node)){169 170 if(resourceAirFlowStats.getResourceType().getName().equals(StandardResourceType.Inlet.getName()) || resourceAirFlowStats.getResourceType().getName().equals(StandardResourceType.Outlet.getName())){ 158 171 for (Long timestamp : resourceAirFlow.keySet()) { 159 160 buffer.append(nodeMetricName); 172 buffer.append(metricName); 161 173 buffer.append(fieldSeparator); 162 174 if(resourceAirFlowStats.getResourceName().startsWith("/")) … … 185 197 public Object visit(ResourceTemperatureStats resourceTemperatureStats) { 186 198 Map<Long, Double> resourceTemperature = resourceTemperatureStats.getHistory(); 187 String nodeMetricName = "RECS_Temperature"; 188 String cpuMetricName = "CPU_Temp"; 199 //String nodeMetricName = "temperature"; 200 //String cpuMetricName = "temperature"; 201 202 String metricName = resourceTemperatureStats.getUsageType(); 203 189 204 int mapSize = resourceTemperature.size(); 190 205 /* … … 212 227 } 213 228 214 if(resourceTemperatureStats.getResourceType().equals(StandardResourceType.ComputingNode) || resourceTemperatureStats.getResourceType().equals(CoolEmAllResourceType.Node) || 215 resourceTemperatureStats.getResourceType().equals(StandardResourceType.Processor) || resourceTemperatureStats.getResourceType().equals(CoolEmAllResourceType.Processor)){ 216 String metricName = null; 229 if(resourceTemperatureStats.getResourceType().getName().equals(StandardResourceType.Node.getName()) || resourceTemperatureStats.getResourceType().getName().equals(StandardResourceType.Processor.getName())){ 230 /*String metricName = null; 217 231 if(resourceTemperatureStats.getResourceType().equals(StandardResourceType.ComputingNode) || resourceTemperatureStats.getResourceType().equals(CoolEmAllResourceType.Node)){ 218 232 metricName = nodeMetricName; 219 233 } else if(resourceTemperatureStats.getResourceType().equals(StandardResourceType.Processor) || resourceTemperatureStats.getResourceType().equals(CoolEmAllResourceType.Processor)){ 220 234 metricName = cpuMetricName; 221 } 235 }*/ 222 236 for (Long timestamp : resourceTemperature.keySet()) { 223 237 224 238 buffer.append(metricName); 225 239 buffer.append(fieldSeparator); 226 buffer.append(resourceTemperatureStats.getResourceName()); 240 if(resourceTemperatureStats.getResourceName().startsWith("/")) 241 buffer.append(resourceTemperatureStats.getResourceName().substring(1)); 242 else buffer.append(resourceTemperatureStats.getResourceName()); 227 243 buffer.append(fieldSeparator); 228 244 Double value = resourceTemperature.get(timestamp); … … 245 261 } 246 262 247 263 public Object visit(MetricsStats metricsStats) { 264 StringBuffer buffer = null; 265 266 if(printedHeaders.add("metrics")) { 267 buffer = new StringBuffer(600); 268 /*String[] headers = metricsStats.getHeaders(); 269 for(int i = 0; i < headers.length; i++) 270 { 271 buffer.append(headers[i]); 272 buffer.append(fieldSeparator); 273 } 274 buffer.append(System.getProperty("line.separator"));*/ 275 } else { 276 buffer = new StringBuffer(300); 277 } 278 DecimalFormat df = new DecimalFormat(); 279 df.setMaximumFractionDigits(3); 280 df.setGroupingUsed(false); 281 282 buffer.append(metricsStats.getMetricName()); 283 buffer.append(fieldSeparator); 284 buffer.append(metricsStats.getResourceName()); 285 buffer.append(fieldSeparator); 286 buffer.append(metricsStats.getTimestamp()); 287 buffer.append(fieldSeparator); 288 buffer.append(df.format(metricsStats.getValue())); 289 buffer.append(fieldSeparator); 290 291 return buffer.toString(); 292 } 293 294 public Object visit(ResourceHistoryStats arg) { 295 StringBuffer buffer = null; 296 297 if(printedHeaders.add("metrics")) { 298 buffer = new StringBuffer(600); 299 /*String[] headers = metricsStats.getHeaders(); 300 for(int i = 0; i < headers.length; i++) 301 { 302 buffer.append(headers[i]); 303 buffer.append(fieldSeparator); 304 } 305 buffer.append(System.getProperty("line.separator"));*/ 306 } else { 307 buffer = new StringBuffer(300); 308 } 309 DecimalFormat df = new DecimalFormat(); 310 df.setMaximumFractionDigits(3); 311 df.setGroupingUsed(false); 312 313 for(ResourceHistoryChanges rhc: arg.getResHistChanges()){ 314 buffer.append(rhc.getTimestamp()); 315 buffer.append(fieldSeparator); 316 buffer.append(rhc.getResourceName()); 317 buffer.append(fieldSeparator); 318 buffer.append(rhc.getOperation()); 319 buffer.append(fieldSeparator); 320 buffer.append(rhc.getParamter()); 321 buffer.append(fieldSeparator); 322 buffer.append(System.getProperty("line.separator")); 323 } 324 325 return buffer.toString(); 326 } 327 328 public Object visit(ResourceUsefulWorkStats resourceUsefulWorkStats) { 329 330 String metricName = resourceUsefulWorkStats.getUsageType(); 331 332 StringBuffer buffer = null; 333 334 if(printedHeaders.add("metrics")) { 335 buffer = new StringBuffer(600); 336 /*String[] headers = metricsStats.getHeaders(); 337 for(int i = 0; i < headers.length; i++) 338 { 339 buffer.append(headers[i]); 340 buffer.append(fieldSeparator); 341 } 342 buffer.append(System.getProperty("line.separator"));*/ 343 } else { 344 buffer = new StringBuffer(300); 345 } 346 DecimalFormat df = new DecimalFormat(); 347 df.setMaximumFractionDigits(3); 348 df.setGroupingUsed(false); 349 if(!resourceUsefulWorkStats.getResourceType().getName().equals(StandardResourceType.Core.getName()) && !resourceUsefulWorkStats.getResourceType().getName().equals(CoolEmAllResourceType.Core.getName())){ 350 351 buffer.append(metricName); 352 buffer.append(fieldSeparator); 353 buffer.append(resourceUsefulWorkStats.getResourceName()); 354 buffer.append(fieldSeparator); 355 buffer.append(resourceUsefulWorkStats.getTimestamp()); 356 buffer.append(fieldSeparator); 357 buffer.append(df.format(resourceUsefulWorkStats.getValue())); 358 buffer.append(fieldSeparator); 359 buffer.append(System.getProperty("line.separator")); 360 } 361 return buffer.toString(); 362 } 363 364 365 public Object visit(ResourceAvailabilityStats resourceAvailabilityStats) { 366 367 String metricName = resourceAvailabilityStats.getUsageType(); 368 369 StringBuffer buffer = null; 370 371 if(printedHeaders.add("metrics")) { 372 buffer = new StringBuffer(600); 373 /*String[] headers = metricsStats.getHeaders(); 374 for(int i = 0; i < headers.length; i++) 375 { 376 buffer.append(headers[i]); 377 buffer.append(fieldSeparator); 378 } 379 buffer.append(System.getProperty("line.separator"));*/ 380 } else { 381 buffer = new StringBuffer(300); 382 } 383 DecimalFormat df = new DecimalFormat(); 384 df.setMaximumFractionDigits(3); 385 df.setGroupingUsed(false); 386 if(resourceAvailabilityStats.getResourceType().getName().equals(CoolEmAllResourceType.NodeGroup.getName())){ 387 388 buffer.append(metricName); 389 buffer.append(fieldSeparator); 390 buffer.append(resourceAvailabilityStats.getResourceName()); 391 buffer.append(fieldSeparator); 392 buffer.append(resourceAvailabilityStats.getTimestamp()); 393 buffer.append(fieldSeparator); 394 buffer.append(df.format(resourceAvailabilityStats.getValue())); 395 buffer.append(fieldSeparator); 396 buffer.append(System.getProperty("line.separator")); 397 } 398 return buffer.toString(); 399 } 248 400 } -
DCWoRMS/branches/coolemall/src/simulator/stats/implementation/out/StatsSerializer.java
r805 r1207 4 4 import simulator.stats.implementation.GSSAccumulatorsStats; 5 5 import simulator.stats.implementation.JobStats; 6 import simulator.stats.implementation.MetricsStats; 6 7 import simulator.stats.implementation.ResourceAirFlowStats; 8 import simulator.stats.implementation.ResourceAvailabilityStats; 9 import simulator.stats.implementation.ResourceHistoryStats; 7 10 import simulator.stats.implementation.ResourcePowerStats; 8 11 import simulator.stats.implementation.ResourceStats; 9 12 import simulator.stats.implementation.ResourceTemperatureStats; 10 13 import simulator.stats.implementation.ResourceUsageStats; 14 import simulator.stats.implementation.ResourceUsefulWorkStats; 11 15 import simulator.stats.implementation.TaskStats; 12 16 … … 34 38 public Object visit(ResourceTemperatureStats arg); 35 39 40 public Object visit(ResourceUsefulWorkStats arg); 41 36 42 public Object visit(GSSAccumulatorsStats arg); 37 43 44 public Object visit(MetricsStats arg); 45 46 public Object visit(ResourceHistoryStats arg); 47 48 public Object visit(ResourceAvailabilityStats resourceAvailabilityStats); 49 38 50 } -
DCWoRMS/branches/coolemall/src/simulator/stats/implementation/out/StringSerializer.java
r1192 r1207 11 11 import simulator.stats.implementation.GSSAccumulatorsStats; 12 12 import simulator.stats.implementation.JobStats; 13 import simulator.stats.implementation.MetricsStats; 13 14 import simulator.stats.implementation.ResourceAirFlowStats; 15 import simulator.stats.implementation.ResourceAvailabilityStats; 16 import simulator.stats.implementation.ResourceHistoryStats; 14 17 import simulator.stats.implementation.ResourcePowerStats; 15 18 import simulator.stats.implementation.ResourceStats; 16 19 import simulator.stats.implementation.ResourceTemperatureStats; 17 20 import simulator.stats.implementation.ResourceUsageStats; 21 import simulator.stats.implementation.ResourceUsefulWorkStats; 18 22 import simulator.stats.implementation.TaskStats; 19 23 … … 48 52 buffer.append(fieldSeparator); 49 53 } 50 51 54 } 52 55 … … 108 111 .longValue()); 109 112 buffer.append(fieldSeparator); 110 buffer.append(taskStats.getProcessorsName()); 113 buffer.append(taskStats.getHostName()); 114 buffer.append(fieldSeparator); 115 buffer.append(taskStats.getProcessingElementsName()); 116 buffer.append(fieldSeparator); 117 buffer.append(0); 118 buffer.append(fieldSeparator); 119 buffer.append(taskStats.getExecName()); 111 120 buffer.append(fieldSeparator); 112 121 } … … 311 320 } 312 321 313 int lastIdx = buffer.lastIndexOf(System.getProperty("line.separator"));314 if(lastIdx != -1)315 buffer.deleteCharAt(lastIdx);316 317 322 if(resourceUsage.size() > 0){ 318 323 buffer.append("mean: " + resourceUsageStats.getMeanValue()); … … 373 378 374 379 } 375 376 int lastIdx = buffer.lastIndexOf(System.getProperty("line.separator")); 377 if(lastIdx != -1) 378 buffer.deleteCharAt(lastIdx); 379 380 380 381 if(resourceEnergy.size() > 0) { 381 382 buffer.append("mean: "+resourceEnergyStats.getMeanValue() + " sum: " +resourceEnergyStats.getSumValue()); … … 437 438 438 439 } 439 int lastIdx = buffer.lastIndexOf(System.getProperty("line.separator")); 440 if(lastIdx != -1) 441 buffer.deleteCharAt(lastIdx); 442 440 443 441 if(resourceAirFlow.size() > 0) { 444 442 buffer.append("mean: "+resourceAirFlowStats.getMeanValue()); … … 500 498 501 499 } 502 503 int lastIdx = buffer.lastIndexOf(System.getProperty("line.separator")); 504 if(lastIdx != -1) 505 buffer.deleteCharAt(lastIdx); 506 500 507 501 if(resourceTemperature.size() > 0) { 508 502 buffer.append("mean: "+resourceTemperatureStats.getMeanValue()); … … 573 567 } 574 568 569 public Object visit(MetricsStats metricsStats) { 570 StringBuffer buffer = new StringBuffer(300); 571 return buffer.toString(); 572 } 573 574 public Object visit(ResourceHistoryStats arg) { 575 StringBuffer buffer = new StringBuffer(300); 576 return buffer.toString(); 577 } 578 579 public Object visit(ResourceUsefulWorkStats arg) { 580 StringBuffer buffer = new StringBuffer(300); 581 return buffer.toString(); 582 } 583 584 public Object visit(ResourceAvailabilityStats arg) { 585 StringBuffer buffer = new StringBuffer(300); 586 return buffer.toString(); 587 } 588 589 575 590 }
Note: See TracChangeset
for help on using the changeset viewer.
