Mercurial > hg > Database > Christie

annotate src/main/java/christie/codegear/CodeGear.java @ 21:5baccb8f7fbd

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add RemoteTake, but it isn't working
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Mon, 22 Jan 2018 23:22:09 +0900
parents 7b45ccc0f70e
children 77583ea56656
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 package christie.codegear;
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
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;
21
5baccb8f7fbd add RemoteTake, but it isn't working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
4 import christie.annotation.RemoteTake;
0
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 import christie.annotation.Take;
21
5baccb8f7fbd add RemoteTake, but it isn't working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
6 import christie.datagear.Command;
5baccb8f7fbd add RemoteTake, but it isn't working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
7 import christie.datagear.CommandType;
0
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
8 import christie.datagear.DataGear;
1
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 0
diff changeset
9 import christie.datagear.DataGearManager;
0
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
10
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
11 import java.lang.reflect.Field;
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
12 import java.util.ArrayList;
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
13
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
14 /**
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
15 * 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
16 * Annotationからのinputコマンドの生成、揃ったDataGearの値を返す
0
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
17 */
7
21372a589bd3 add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 6
diff changeset
18 public abstract class CodeGear{
18
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
19 private InputDataGear idg = new InputDataGear(this);
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
20 private OutputDataGear odg = new OutputDataGear(this);
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
21 private ArrayList<Command> commandList = new ArrayList<Command>();
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
22 private CodeGearManager cgm;
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
23 private DataGearManager localDGM;
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
24 private CodeGearExecutor cge;
0
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
25
10
4b608ce0c483 add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 7
diff changeset
26 protected abstract void run(CodeGearManager cgm);
4b608ce0c483 add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 7
diff changeset
27
7
21372a589bd3 add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 6
diff changeset
28 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
29 this.cgm = cgm;
7
21372a589bd3 add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 6
diff changeset
30 this.cge = new CodeGearExecutor(this, this.cgm);
14
f2b30b47ef67 RemotePutTest is working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
31 this.localDGM = cgm.getLocalDGM();
5
5be6647b87d2 StartCodeGear implements Runnable to wait InputDataGear
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 4
diff changeset
32 odg.initODG(cgm);
3
e3bb0eea73f2 resolve Annotation error and TestCodeGear is working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 2
diff changeset
33
7
21372a589bd3 add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 6
diff changeset
34 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
35 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
36 Take ano = field.getAnnotation(Take.class);
21
5baccb8f7fbd add RemoteTake, but it isn't working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
37 checkAndSetCommand(field, "local", ano.value());
6
3dcfe63d6394 set type to DataGear by Annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 5
diff changeset
38 } 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
39 Peek ano = field.getAnnotation(Peek.class);
21
5baccb8f7fbd add RemoteTake, but it isn't working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
40 checkAndSetCommand(field, "local", ano.value());
5baccb8f7fbd add RemoteTake, but it isn't working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
41 } else if (field.isAnnotationPresent(RemoteTake.class)) {
5baccb8f7fbd add RemoteTake, but it isn't working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
42 RemoteTake ano = field.getAnnotation(RemoteTake.class);
5baccb8f7fbd add RemoteTake, but it isn't working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
43 checkAndSetCommand(field, ano.dsmName(), ano.key());
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 }
3
e3bb0eea73f2 resolve Annotation error and TestCodeGear is working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 2
diff changeset
46
6
3dcfe63d6394 set type to DataGear by Annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 5
diff changeset
47 idg.finishInput(cgm, commandList);
1
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 0
diff changeset
48 }
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 0
diff changeset
49
21
5baccb8f7fbd add RemoteTake, but it isn't working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
50 public void checkAndSetCommand(Field field, String dsmName, String key){
11
4e5f6db22033 minor change
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 10
diff changeset
51
21
5baccb8f7fbd add RemoteTake, but it isn't working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
52 if (!field.getName().equals(key)){
10
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
4e5f6db22033 minor change
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 10
diff changeset
63 if (dg.getClazz() == null){
4e5f6db22033 minor change
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 10
diff changeset
64 throw new NullPointerException("please initialize DataGear");
4e5f6db22033 minor change
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 10
diff changeset
65 }
4e5f6db22033 minor change
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 10
diff changeset
66
21
5baccb8f7fbd add RemoteTake, but it isn't working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
67 commandList.add(new Command(CommandType.TAKE, this, cgm.cgmID, dsmName, key, dg));
10
4b608ce0c483 add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 7
diff changeset
68 }
18
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
69
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
70 public DataGearManager getLocalDGM() {
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
71 return localDGM;
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
72 }
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
73
20
7b45ccc0f70e add MessagePackDataGear
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
74 public DataGearManager getDGM(String dgmName) {
18
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
75 return cgm.getDGM(dgmName);
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
76 }
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
77
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
78 public InputDataGear getIdg() {
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
79 return idg;
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
80 }
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
81
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
82 public OutputDataGear getOdg() {
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
83 return odg;
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
84 }
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
85
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
86 public CodeGearExecutor getCge() {
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
87 return cge;
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
88 }
0
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
89 }