source: java/main/src/main/java/com/framsticks/params/Registry.java @ 96

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

HIGHLIGHTS:

  • cleanup Instance management
    • extract Instance interface
    • extract Instance common algorithms to InstanceUtils?
  • fix closing issues: Ctrl+C or window close button

properly shutdown whole program

by Java Framsticks framework

  • fix parsing and printing of all request types
  • hide exception passing in special handle method of closures
    • substantially improve readability of closures
    • basically enable use of exception in asynchronous closures

(thrown exception is transported back to the caller)

  • implement call request on both sides

CHANGELOG:
Further improve calling.

Improve instance calling.

Calling is working on both sides.

Improve exception handling in testing.

Waiters do not supercede other apllication exception being thrown.

Finished parsing and printing of all request types (with tests).

Move implementation and tests of request parsing to Request.

Add tests for Requests.

Improve waits in asynchronours tests.

Extract more algorithms to InstanceUtils?.

Extract Instance.resolve to InstanceUtils?.

Improve naming.

Improve passing exception in InstanceClient?.

Hide calling of passed functor in StateCallback?.

Hide Exception passing in asynchronous closures.

Hide exception passing in Future.

Make ResponseCallback? an abstract class.

Make Future an abstract class.

Minor change.

Move getPath to Path.to()

Move bindAccess to InstanceUtils?.

Extract common things to InstanceUtils?.

Fix synchronization bug in Connection.

Move resolve to InstanceUtils?.

Allow names of Joinable to be dynamic.

Add support for set request server side.

More fixes in communication.

Fix issues with parsing in connection.

Cut new line characters when reading.

More improvements.

Migrate closures to FramsticksException?.

Several changes.

Extract resolveAndFetch to InstanceUtils? algorithms.

Test resolving and fetching.

More fixes with function signature deduction.

Do not print default values in SimpleAbstractAccess?.

Add test of FramsClass? printing.

Improve FramsticksException? messages.

Add explicit dispatcher synchronization feature.

Rework assertions in tests.

Previous solution was not generic enough.

Allow addition of joinables to collection after start.

Extract SimulatorInstance? from RemoteInstance?.

Remove PrivateJoinableCollection?.

Improve connections.

Move shutdown hook to inside the Monitor.

It should work in TestNG tests, but it seems that
hooks are not called.

In ServerTest? client connects to testing server.

Move socket initialization to receiver thread.

Add proper closing on Ctrl+C (don't use signals).

Fix bugs with server accepting connections.

Merge Entity into Joinable.

Reworking ServerInstance?.

Extract more algorithm to InstanceUtils?.

Extract some common functionality from AbstractInstance?.

Functions were placed in InstanceUtils?.

Hide registry of Instance.

Use ValueParam? in Instance interface.

Minor change.

Extract Instance interface.

Old Instance is now AbstractInstance?.

File size: 4.5 KB
Line 
1package com.framsticks.params;
2
3import org.apache.log4j.Logger;
4
5import com.framsticks.params.annotations.FramsClassAnnotation;
6import com.framsticks.params.annotations.ParamAnnotation;
7import com.framsticks.util.DoubleMap;
8import com.framsticks.util.FramsticksException;
9
10import java.util.HashMap;
11import java.util.Map;
12import java.util.Set;
13
14import javax.annotation.Nonnull;
15
16/**
17 * Author: Piotr Śniegowski
18 */
19@FramsClassAnnotation
20public class Registry {
21        private static final Logger log = Logger.getLogger(Registry.class.getName());
22
23        protected final DoubleMap<String, Class<?>> javaClasses = new DoubleMap<>();
24        protected final DoubleMap<String, FramsClass> framsClasses = new DoubleMap<>();
25        protected final Map<Class<?>, FramsClass> javaToFramsAssociation = new HashMap<>();
26
27        /**
28         *
29         */
30        public Registry() {
31                // registerAndBuild(Registry.class);
32                // registerAndBuild(FramsClass.class);
33                // registerAndBuild(Param.class);
34        }
35
36        public void registerReflectedClass(String name, String id, Class<?> javaClass) {
37                javaClasses.put(id, name, javaClass);
38        }
39
40        public void associate(Class<?> javaClass, FramsClass framsClass) {
41                javaToFramsAssociation.put(javaClass, framsClass);
42        }
43
44        public Registry registerAndBuild(Class<?> javaClass) {
45                register(javaClass);
46                associate(javaClass, putFramsClass(FramsClass.build().forClass(javaClass)));
47                return this;
48        }
49
50        public FramsClass registerReflectedIfNeeded(Class<?> javaClass) {
51                if (!javaToFramsAssociation.containsKey(javaClass)) {
52                        registerAndBuild(javaClass);
53                }
54                return javaToFramsAssociation.get(javaClass);
55        }
56
57        public Registry register(Class<?> javaClass) {
58                FramsClassAnnotation a = javaClass.getAnnotation(FramsClassAnnotation.class);
59                if (a == null) {
60                        throw new FramsticksException().msg("class is not annotated").arg("class", javaClass);
61                }
62
63                registerReflectedClass(FramsClassBuilder.getName(a, javaClass), FramsClassBuilder.getId(a, javaClass), javaClass);
64                return this;
65        }
66
67        public @Nonnull ReflectionAccess createAccess(Class<?> javaClass) throws ConstructionException {
68                try {
69                        if (!javaClasses.containsValue(javaClass)) {
70                                throw new FramsticksException().msg("java class is not registered");
71                        }
72                        if (!javaToFramsAssociation.containsKey(javaClass)) {
73                                throw new FramsticksException().msg("java class is not associated with any frams class");
74                        }
75                        return new ReflectionAccess(javaClass, javaToFramsAssociation.get(javaClass));
76                }
77                catch (FramsticksException e) {
78                        throw new FramsticksException().msg("failed to create access for java class").arg("class", javaClass).cause(e);
79                }
80        }
81
82        public @Nonnull AccessInterface createAccess(String name, FramsClass framsClass) throws ConstructionException {
83                // assert framsClasses.containsValue(framsClass);
84                if (javaClasses.containsKey(name)) {
85                        return new ReflectionAccess(javaClasses.get(name), framsClass);
86                }
87                return new PropertiesAccess(framsClass);
88        }
89
90        public FramsClass putFramsClass(FramsClass framsClass) {
91                log.debug("caching info for " + framsClass);
92                framsClasses.put(framsClass.getId(), framsClass.getName(), framsClass);
93                return framsClass;
94        }
95
96        public FramsClass getFramsClass(@Nonnull String identifier) {
97                return framsClasses.get(identifier);
98        }
99
100        public static @Nonnull AccessInterface wrapAccessWithListIfNeeded(@Nonnull CompositeParam param, @Nonnull AccessInterface access) {
101                return param.prepareAccessInterface(access);
102        }
103
104        public @Nonnull AccessInterface prepareAccess(CompositeParam param) throws ConstructionException {
105                return wrapAccessWithListIfNeeded(param, createAccess(param.getContainedTypeName()));
106        }
107
108        public @Nonnull AccessInterface createAccess(@Nonnull String name) throws ConstructionException {
109                try {
110                        FramsClass framsClass = getFramsClass(name);
111                        if (framsClass == null) {
112                                throw new ConstructionException().msg("framsclass is missing");
113                        }
114
115                        return createAccess(name, framsClass);
116                }
117                catch (FramsticksException e) {
118                        throw new FramsticksException().msg("failed to create access for name").arg("name", name).cause(e);
119                }
120        }
121
122        public Set<Class<?>> getReflectedClasses() {
123                return javaClasses.getValues();
124        }
125
126        public Set<FramsClass> getFramsClasses() {
127                return framsClasses.getValues();
128        }
129
130        @ParamAnnotation
131        public Map<String, FramsClass> getFramsClassesById() {
132                return framsClasses.getValuesById();
133        }
134
135        public void takeAllFrom(Registry source) {
136                for (Class<?> javaClass : source.getReflectedClasses()) {
137                        register(javaClass);
138                }
139                for (FramsClass framsClass : source.getFramsClasses()) {
140                        putFramsClass(framsClass);
141                }
142
143        }
144
145}
Note: See TracBrowser for help on using the repository browser.