Changeset 96 for java/main/src/main/java/com/framsticks/diagnostics
- Timestamp:
- 07/04/13 20:29:50 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/diagnostics/Diagnostics.java
r88 r96 1 1 package com.framsticks.diagnostics; 2 3 2 4 3 import java.util.Date; … … 14 13 import com.framsticks.core.AbstractInstanceListener; 15 14 import com.framsticks.core.Instance; 15 import com.framsticks.core.Path; 16 16 import com.framsticks.dumping.PrintWriterSink; 17 17 import com.framsticks.dumping.SaveStream; 18 18 import com.framsticks.params.annotations.AutoAppendAnnotation; 19 19 import com.framsticks.remote.RecursiveFetcher; 20 import com.framsticks.util.FramsticksException; 20 21 import com.framsticks.util.Logging; 21 22 import com.framsticks.util.PeriodicTask; … … 28 29 */ 29 30 public class Diagnostics extends JoinableCollection<Instance> { 30 private static final Logger log = 31 Logger.getLogger(Diagnostics.class); 31 private static final Logger log = Logger.getLogger(Diagnostics.class); 32 32 33 33 … … 59 59 60 60 log.info("starting periodic dump"); 61 new RecursiveFetcher(instance, instance.getRootPath(), new StateFunctor() {61 new RecursiveFetcher(instance, Path.to(instance, "/"), new StateFunctor() { 62 62 @Override 63 public void call(Exception e) { 64 if (Logging.log(log, "recursively fetch", instance, e)) { 65 again(); 66 return; 67 } 63 public void handle(FramsticksException e) { 64 Logging.log(log, "recursively fetch", instance, e); 65 again(); 66 } 67 68 @Override 69 public void call() { 68 70 log.info("instance resolved, saving"); 69 71 try { 70 72 final String fileName = dumpsPath + "/" + instance + "_" + new SimpleDateFormat(dumpsFormat).format(new Date()) + ".param"; 71 73 File file = new File(fileName); 72 new SaveStream(new PrintWriterSink(new PrintWriter(new OutputStreamWriter(new FileOutputStream(file), Encoding.getFramsticksCharset()))), instance, instance.getRootPath(), new StateFunctor() {74 new SaveStream(new PrintWriterSink(new PrintWriter(new OutputStreamWriter(new FileOutputStream(file), Encoding.getFramsticksCharset()))), instance, Path.to(instance, "/"), new StateFunctor() { 73 75 @Override 74 public void call(Exception e) {76 public void handle(FramsticksException e) { 75 77 Logging.log(log, "periodic dump in " + fileName + " of", instance, e); 78 again(); 79 } 80 81 @Override 82 public void call() { 76 83 again(); 77 84 }
Note: See TracChangeset
for help on using the changeset viewer.