Mercurial > hg > Database > Christie
annotate src/main/java/christie/codegear/CodeGear.java @ 17:59fabebb67d8
delete cgmName as String, add cgmID as int
author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
---|---|
date | Thu, 18 Jan 2018 16:49:54 +0900 |
parents | 4e867538adb7 |
children | b8dc461b29f4 |
rev | line source |
---|---|
0 | 1 package christie.codegear; |
2 | |
6
3dcfe63d6394
set type to DataGear by Annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
5
diff
changeset
|
3 import christie.annotation.Peek; |
0 | 4 import christie.annotation.Take; |
13
bcd4f2c19185
don't work MessagePack unconvert for remote put
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
12
diff
changeset
|
5 import christie.daemon.ChristieDaemon; |
0 | 6 import christie.datagear.DataGear; |
1
3ea61d0bfc34
add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
7 import christie.datagear.DataGearManager; |
0 | 8 |
9 import java.lang.reflect.Field; | |
10 import java.util.ArrayList; | |
11 import java.util.HashMap; | |
12 | |
13 /** | |
14 * Created by e125769 on 12/7/17. | |
1
3ea61d0bfc34
add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
15 * Annotationからのinputコマンドの生成、揃ったDataGearの値を返す |
0 | 16 */ |
7
21372a589bd3
add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
6
diff
changeset
|
17 public abstract class CodeGear{ |
5
5be6647b87d2
StartCodeGear implements Runnable to wait InputDataGear
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
4
diff
changeset
|
18 public InputDataGear idg = new InputDataGear(this); |
5be6647b87d2
StartCodeGear implements Runnable to wait InputDataGear
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
4
diff
changeset
|
19 public OutputDataGear odg = new OutputDataGear(this); |
3
e3bb0eea73f2
resolve Annotation error and TestCodeGear is working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
2
diff
changeset
|
20 public ArrayList<Command> commandList = new ArrayList<Command>(); |
e3bb0eea73f2
resolve Annotation error and TestCodeGear is working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
2
diff
changeset
|
21 public CodeGearManager cgm; |
7
21372a589bd3
add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
6
diff
changeset
|
22 public DataGearManager localDGM; |
21372a589bd3
add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
6
diff
changeset
|
23 public CodeGearExecutor cge; |
0 | 24 |
10
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
25 protected abstract void run(CodeGearManager cgm); |
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
26 |
7
21372a589bd3
add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
6
diff
changeset
|
27 public void setup(CodeGearManager cgm){ |
3
e3bb0eea73f2
resolve Annotation error and TestCodeGear is working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
2
diff
changeset
|
28 this.cgm = cgm; |
7
21372a589bd3
add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
6
diff
changeset
|
29 this.cge = new CodeGearExecutor(this, this.cgm); |
14
f2b30b47ef67
RemotePutTest is working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
13
diff
changeset
|
30 this.localDGM = cgm.getLocalDGM(); |
5
5be6647b87d2
StartCodeGear implements Runnable to wait InputDataGear
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
4
diff
changeset
|
31 odg.initODG(cgm); |
3
e3bb0eea73f2
resolve Annotation error and TestCodeGear is working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
2
diff
changeset
|
32 |
7
21372a589bd3
add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
6
diff
changeset
|
33 for (Field field : this.getClass().getDeclaredFields()) {//AnnotationからInputDataGearをセット |
6
3dcfe63d6394
set type to DataGear by Annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
5
diff
changeset
|
34 if (field.isAnnotationPresent(Take.class)) { |
1
3ea61d0bfc34
add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
35 Take ano = field.getAnnotation(Take.class); |
10
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
36 checkAndSetCommand(field, ano.value()); |
6
3dcfe63d6394
set type to DataGear by Annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
5
diff
changeset
|
37 } else if (field.isAnnotationPresent(Peek.class)) { |
3dcfe63d6394
set type to DataGear by Annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
5
diff
changeset
|
38 Peek ano = field.getAnnotation(Peek.class); |
10
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
39 checkAndSetCommand(field, ano.value()); |
1
3ea61d0bfc34
add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
40 } |
3ea61d0bfc34
add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
41 } |
3
e3bb0eea73f2
resolve Annotation error and TestCodeGear is working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
2
diff
changeset
|
42 |
6
3dcfe63d6394
set type to DataGear by Annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
5
diff
changeset
|
43 idg.finishInput(cgm, commandList); |
1
3ea61d0bfc34
add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
44 } |
3ea61d0bfc34
add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
45 |
17
59fabebb67d8
delete cgmName as String, add cgmID as int
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
15
diff
changeset
|
46 public DataGearManager dgm(String dgmName) { |
59fabebb67d8
delete cgmName as String, add cgmID as int
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
15
diff
changeset
|
47 return cgm.getDGM(dgmName); |
7
21372a589bd3
add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
6
diff
changeset
|
48 } |
10
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
49 |
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
50 public void checkAndSetCommand(Field field, String name){ |
11 | 51 |
10
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
52 if (!field.getName().equals(name)){ |
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
53 throw new IllegalArgumentException("key and DataGearName do not match"); |
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
54 } |
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
55 |
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
56 DataGear dg = null; |
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
57 try { |
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
58 dg = (DataGear) field.get(this); |
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
59 } catch (IllegalAccessException e) { |
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
60 e.printStackTrace(); |
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
61 } |
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
62 |
11 | 63 if (dg.getClazz() == null){ |
64 throw new NullPointerException("please initialize DataGear"); | |
65 } | |
66 | |
17
59fabebb67d8
delete cgmName as String, add cgmID as int
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
15
diff
changeset
|
67 commandList.add(new Command(this, dg, cgm.cgmID,"local", name, CommandType.TAKE)); |
10
4b608ce0c483
add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
7
diff
changeset
|
68 } |
0 | 69 } |