source: java/main/src/main/java/com/framsticks/dumping/SaveStream.java @ 85

Last change on this file since 85 was 85, checked in by psniegowski, 11 years ago

HIGHLIGHTS:

  • upgrade to Java 7
    • use try-multi-catch clauses
    • use try-with-resources were appropriate
  • configure FindBugs? (use mvn site and then navigate in browser to the report)
    • remove most bugs found
  • parametrize Dispatching environment (Dispatcher, RunAt?) to enforce more control on the place of closures actual call

CHANGELOG:
Rework FavouritesXMLFactory.

FindBugs?. Thread start.

FindBugs?. Minor change.

FindBugs?. Iterate over entrySet.

FindBugs?. Various.

FindBug?.

FindBug?. Encoding.

FindBug?. Final fields.

FindBug?.

Remove synchronization bug in ClientConnection?.

Experiments with findbugs.

Finish parametrization.

Make RunAt? an abstract class.

More changes in parametrization.

More changes in parametrizing dispatching.

Several changes to parametrize tasks.

Rename Runnable to RunAt?.

Add specific framsticks Runnable.

Add JSR305 (annotations).

Add findbugs reporting.

More improvements to ParamBuilder? wording.

Make FramsClass? accept also ParamBuilder?.

Change wording of ParamBuilder?.

Change wording of Request creation.

Use Java 7 exception catch syntax.

Add ScopeEnd? class.

Upgrade to Java 7.

File size: 2.9 KB
Line 
1package com.framsticks.dumping;
2
3import com.framsticks.core.Node;
4import com.framsticks.core.Path;
5import com.framsticks.params.AccessInterface;
6import com.framsticks.params.CompositeParam;
7import com.framsticks.params.FramsClass;
8import com.framsticks.params.ListAccess;
9import com.framsticks.params.SinkInterface;
10import com.framsticks.parsers.Savers;
11import com.framsticks.core.Instance;
12import com.framsticks.util.*;
13import com.framsticks.util.dispatching.Dispatching;
14import org.apache.log4j.Logger;
15import com.framsticks.util.dispatching.RunAt;
16
17import java.util.HashSet;
18import java.util.Set;
19import static com.framsticks.util.lang.Containers.filterInstanceof;
20
21/**
22 * @author Piotr Sniegowski
23 */
24public class SaveStream {
25
26        private final static Logger log = Logger.getLogger(SaveStream.class.getName());
27
28        protected final SinkInterface sink;
29        protected final Instance instance;
30        protected final StateFunctor stateFunctor;
31        protected final Stopwatch stopwatch = new Stopwatch();
32        protected final Set<FramsClass> storedInfo = new HashSet<FramsClass>();
33
34        private int dispatched = 0;
35
36        public SaveStream(SinkInterface sink, Instance instance, Path root, StateFunctor stateFunctor) {
37                assert Dispatching.isThreadSafe();
38                this.sink = sink;
39                this.instance = instance;
40                this.stateFunctor = stateFunctor;
41                dispatchWrite(root);
42        }
43
44        protected void dispatchWrite(final Path path) {
45                ++dispatched;
46                instance.invokeLater(new RunAt<Instance>() {
47                        @Override
48                        public void run() {
49                                write(path);
50                        }
51                });
52        }
53
54        protected void finished() {
55                assert instance.isActive();
56                log.info("stored in " + stopwatch);
57                stateFunctor.call(null);
58        }
59
60        public void write(final Path path) {
61                assert instance.isActive();
62                if (!path.isResolved()) {
63                        log.debug("path " + path + " is not resolved - skipping");
64                } else {
65                        AccessInterface access = instance.bindAccess(path);
66                        assert access != null;
67                        FramsClass framsClass = access.getFramsClass();
68                        assert framsClass != null;
69                        if (!storedInfo.contains(framsClass)) {
70                                storedInfo.add(framsClass);
71                                sink.print("info ").print(path.getTextual()).breakLine();
72                                sink.print("file").breakLine();
73                                Savers.saveFramsClass(sink, framsClass);
74                                sink.print("eof").breakLine();
75                                sink.print("ok").breakLine();
76                        }
77                        if (!(access instanceof ListAccess)) {
78                                sink.print("get ").print(path.getTextual()).breakLine();
79                                sink.print("file").breakLine();
80                                //stream.print("#" + access.getSelected().getClass().getCanonicalName() + "\n");
81                                access.save(sink);
82                                sink.print("eof").breakLine();
83                                sink.print("ok").breakLine();
84                        }
85                        for (CompositeParam p : filterInstanceof(access.getParams(), CompositeParam.class)) {
86                                final Path childPath = path.appendNode(new Node(p, access.get(p, Object.class)));
87                                if (childPath.isResolved() && instance.getInfoFromCache(childPath) != null) {
88                                        dispatchWrite(childPath);
89                                }
90                        }
91                }
92                --dispatched;
93                if (dispatched == 0) {
94                        finished();
95                }
96        }
97}
Note: See TracBrowser for help on using the repository browser.