Mercurial > hg > Database > Christie

annotate src/main/java/christie/codegear/CodeGear.java @ 196:ad49723367c2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add priority
author akahori
date Sat, 09 Mar 2019 14:03:06 +0900
parents 2886363f5e12
children ef5aad739292
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;
32
307ac87ddcf7 add TakeFrom annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 31
diff changeset
4 import christie.annotation.PeekFrom;
0
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 import christie.annotation.Take;
32
307ac87ddcf7 add TakeFrom annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 31
diff changeset
6 import christie.annotation.TakeFrom;
23
695705dba324 Increased commands by type
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 22
diff changeset
7 import christie.datagear.*;
26
bf8ac57409af make dg package
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
8 import christie.datagear.command.Command;
bf8ac57409af make dg package
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
9 import christie.datagear.command.PeekCommand;
bf8ac57409af make dg package
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
10 import christie.datagear.command.TakeCommand;
bf8ac57409af make dg package
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
11 import christie.datagear.dg.DataGear;
0
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
12
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
13 import java.lang.reflect.Field;
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
14 import java.util.ArrayList;
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
15
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
16 /**
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
17 * 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
18 * Annotationからのinputコマンドの生成、揃ったDataGearの値を返す
0
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
19 */
7
21372a589bd3 add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 6
diff changeset
20 public abstract class CodeGear{
18
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
21 private InputDataGear idg = new InputDataGear(this);
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
22 private ArrayList<Command> commandList = new ArrayList<Command>();
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
23 private CodeGearManager cgm;
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
24 private DataGearManager localDGM;
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
25 private CodeGearExecutor cge;
0
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
26
10
4b608ce0c483 add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 7
diff changeset
27 protected abstract void run(CodeGearManager cgm);
4b608ce0c483 add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 7
diff changeset
28
196
ad49723367c2 add priority
akahori
parents: 128
diff changeset
29 public void setup(CodeGearManager cgm, int priority){
3
e3bb0eea73f2 resolve Annotation error and TestCodeGear is working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 2
diff changeset
30 this.cgm = cgm;
196
ad49723367c2 add priority
akahori
parents: 128
diff changeset
31 this.cge = new CodeGearExecutor(this, this.cgm, priority);
14
f2b30b47ef67 RemotePutTest is working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
32 this.localDGM = cgm.getLocalDGM();
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)) {
196
ad49723367c2 add priority
akahori
parents: 128
diff changeset
36 //Take ano = field.getAnnotation(Take.class);
32
307ac87ddcf7 add TakeFrom annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 31
diff changeset
37 setTakeCommand("local", field.getName(), new DataGear(field.getType()));
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)) {
196
ad49723367c2 add priority
akahori
parents: 128
diff changeset
39 //Peek ano = field.getAnnotation(Peek.class);
32
307ac87ddcf7 add TakeFrom annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 31
diff changeset
40 setPeekCommand("local", field.getName(), new DataGear(field.getType()));
36
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
41 } else if (field.isAnnotationPresent(TakeFrom.class)) {
32
307ac87ddcf7 add TakeFrom annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 31
diff changeset
42 TakeFrom ano = field.getAnnotation(TakeFrom.class);
307ac87ddcf7 add TakeFrom annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 31
diff changeset
43 setTakeCommand(ano.value(), field.getName(), new DataGear(field.getType()));
307ac87ddcf7 add TakeFrom annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 31
diff changeset
44 } else if (field.isAnnotationPresent(PeekFrom.class)) {
307ac87ddcf7 add TakeFrom annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 31
diff changeset
45 PeekFrom ano = field.getAnnotation(PeekFrom.class);
31
e29900328fff remove RemoteTake annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
46 setPeekCommand(ano.value(), field.getName(), new DataGear(field.getType()));
1
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 0
diff changeset
47 }
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 0
diff changeset
48 }
3
e3bb0eea73f2 resolve Annotation error and TestCodeGear is working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 2
diff changeset
49
6
3dcfe63d6394 set type to DataGear by Annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 5
diff changeset
50 idg.finishInput(cgm, commandList);
1
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 0
diff changeset
51 }
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 0
diff changeset
52
25
76fac42a840e work RemoteTakeTest
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 23
diff changeset
53 public void setTakeCommand(String toDgmName, String key, DataGear dg){
76fac42a840e work RemoteTakeTest
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 23
diff changeset
54 commandList.add(new TakeCommand(this, cgm.cgmID, toDgmName, key, dg));
76fac42a840e work RemoteTakeTest
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 23
diff changeset
55 }
76fac42a840e work RemoteTakeTest
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 23
diff changeset
56
76fac42a840e work RemoteTakeTest
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 23
diff changeset
57 public void setPeekCommand(String toDgmName, String key, DataGear dg){
76fac42a840e work RemoteTakeTest
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 23
diff changeset
58 commandList.add(new PeekCommand(this, cgm.cgmID, toDgmName, key, dg));
10
4b608ce0c483 add local repeat test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 7
diff changeset
59 }
18
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
60
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
61 public DataGearManager getLocalDGM() {
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
62 return localDGM;
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
63 }
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
64
20
7b45ccc0f70e add MessagePackDataGear
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
65 public DataGearManager getDGM(String dgmName) {
18
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
66 return cgm.getDGM(dgmName);
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
67 }
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
68
128
2886363f5e12 update put
akahori
parents: 112
diff changeset
69 public CodeGear put(String dgmName, String key, Object data){
36
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
70 getDGM(dgmName).put(key, data);
128
2886363f5e12 update put
akahori
parents: 112
diff changeset
71 return this;
36
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
72 }
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
73
128
2886363f5e12 update put
akahori
parents: 112
diff changeset
74 public CodeGear put(String key, Object value){
2886363f5e12 update put
akahori
parents: 112
diff changeset
75
36
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
76 localDGM.put(key, value);
128
2886363f5e12 update put
akahori
parents: 112
diff changeset
77 return this;
36
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
78 }
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
79
112
20f7270e997d update add contains
akahori
parents: 36
diff changeset
80 public Boolean containsDGM(String dgmName){ return cgm.containsDGM(dgmName);}
20f7270e997d update add contains
akahori
parents: 36
diff changeset
81
20f7270e997d update add contains
akahori
parents: 36
diff changeset
82 public void finish(String managerKey) {
20f7270e997d update add contains
akahori
parents: 36
diff changeset
83 if (cgm.getDGMList().contains(managerKey))
20f7270e997d update add contains
akahori
parents: 36
diff changeset
84 cgm.getDGMList().get(managerKey).finish();
20f7270e997d update add contains
akahori
parents: 36
diff changeset
85 }
20f7270e997d update add contains
akahori
parents: 36
diff changeset
86
20f7270e997d update add contains
akahori
parents: 36
diff changeset
87
20f7270e997d update add contains
akahori
parents: 36
diff changeset
88
36
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
89 public void flip(String dgmName, String key){//ToDo: これ値を編集できるからflipできてない。初期値をflipしたい。
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
90 for (Field field : this.getClass().getDeclaredFields()) {
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
91 if (field.getName() == key){
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
92 try {
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
93 getDGM(dgmName).put(key, field.get(this));
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
94 } catch (IllegalAccessException e) {
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
95 e.printStackTrace();
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
96 }
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
97 }
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
98 }
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
99 }
4479d37c8e53 change put syntax
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
100
18
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
101 public InputDataGear getIdg() {
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
102 return idg;
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
103 }
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
104
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
105 public CodeGearExecutor getCge() {
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
106 return cge;
b8dc461b29f4 waitList use Queue
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 17
diff changeset
107 }
196
ad49723367c2 add priority
akahori
parents: 128
diff changeset
108
0
c082039368f5 make project
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
109 }