Mercurial > hg > Database > Christie

changeset 247:901d65bad48d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add remote take object test msgpack and javassist are too old
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Fri, 24 Jan 2020 18:59:24 +0900
parents 824d75bafe67
children 4794710670bf
files src/test/java/christie/example/FizzBuzz/Counter.java src/test/java/christie/example/FizzBuzz/FizzBuzz.java src/test/java/christie/example/RemoteTake/CreateRemoteTakeTest.java src/test/java/christie/example/RemoteTake/FinishRemoteTake.java src/test/java/christie/example/RemoteTake/RTCommand.java src/test/java/christie/example/RemoteTake/StartRemoteTake.java
diffstat 6 files changed, 58 insertions(+), 12 deletions(-) [+]
line wrap: on
line diff
--- a/src/test/java/christie/example/FizzBuzz/Counter.java	Fri Jan 24 18:23:20 2020 +0900
+++ b/src/test/java/christie/example/FizzBuzz/Counter.java	Fri Jan 24 18:59:24 2020 +0900
@@ -17,6 +17,9 @@
             getDGM("fizzBuzz").put("num", num);
             cgm.getLocalDGM().put("num", num + 1);
             cgm.setup(new Counter());
+        } else {
+            getDGM("fizzBuzz").put("num", -1); // finish mark
+            cgm.getLocalDGM().finish();
         }
     }
 }
--- a/src/test/java/christie/example/FizzBuzz/FizzBuzz.java	Fri Jan 24 18:23:20 2020 +0900
+++ b/src/test/java/christie/example/FizzBuzz/FizzBuzz.java	Fri Jan 24 18:59:24 2020 +0900
@@ -10,17 +10,18 @@
     @Take
     int num;
 
-
-
     @Override
     protected void run(CodeGearManager cgm) {
         if (num % 3 == 0 && num  % 5 == 0) {
             System.out.println(num + ":FizzBuzz");
-        }else if(num % 3 == 0){
+        } else if (num % 3 == 0) {
             System.out.println(num + ":Fizz");
-        }else if(num % 5 == 0){
+        } else if (num % 5 == 0) {
             System.out.println(num + ":Buzz");
-        }else{
+        } else if (num < 0 ) {  // finish
+            cgm.getLocalDGM().finish();
+            return;
+        } else {
             System.out.println(num);
         }
         cgm.setup(new FizzBuzz());
--- a/src/test/java/christie/example/RemoteTake/CreateRemoteTakeTest.java	Fri Jan 24 18:23:20 2020 +0900
+++ b/src/test/java/christie/example/RemoteTake/CreateRemoteTakeTest.java	Fri Jan 24 18:59:24 2020 +0900
@@ -1,11 +1,16 @@
 package christie.example.RemoteTake;
 
+import christie.annotation.Take;
 import christie.codegear.CodeGear;
 import christie.codegear.CodeGearManager;
 
 public class CreateRemoteTakeTest extends CodeGear {
+    @Take
+    RTCommand command;
+
     @Override
     protected void run(CodeGearManager cgm) {
-
+        System.out.println(command);
+        cgm.getLocalDGM().put("finish","end");
     }
 }
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/test/java/christie/example/RemoteTake/FinishRemoteTake.java	Fri Jan 24 18:59:24 2020 +0900
@@ -0,0 +1,15 @@
+package christie.example.RemoteTake;
+
+import christie.annotation.Take;
+import christie.codegear.CodeGear;
+import christie.codegear.CodeGearManager;
+
+public class FinishRemoteTake extends CodeGear {
+    @Take String finish;
+
+    @Override
+    protected void run(CodeGearManager cgm) {
+        cgm.getDGM("remote").finish();
+        cgm.getLocalDGM().finish();
+    }
+}
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/test/java/christie/example/RemoteTake/RTCommand.java	Fri Jan 24 18:59:24 2020 +0900
@@ -0,0 +1,25 @@
+package christie.example.RemoteTake;
+
+import org.msgpack.annotation.Message;
+
+@Message
+class RTCommand {
+    private final String line;
+    String cmd;
+    int offset;
+
+    public RTCommand(String cmd, String line, int i) {
+        this.cmd = cmd;
+        this.line = line;
+        this.offset = i;
+    }
+
+    @Override
+    public String toString() {
+        return "RTCommand{" +
+                "line='" + line + '\'' +
+                ", cmd='" + cmd + '\'' +
+                ", offset=" + offset +
+                '}';
+    }
+}
--- a/src/test/java/christie/example/RemoteTake/StartRemoteTake.java	Fri Jan 24 18:23:20 2020 +0900
+++ b/src/test/java/christie/example/RemoteTake/StartRemoteTake.java	Fri Jan 24 18:59:24 2020 +0900
@@ -12,12 +12,9 @@
     public static void main(String args[]){
         CodeGearManager cgm = createCGM(10000);
         new StartRemoteTake(cgm);
-
-        cgm.createRemoteDGM("remote", "localhost", 10001);
+        cgm.createRemoteDGM("remote", "localhost", 10000);
         cgm.setup(new CreateRemoteTakeTest());
-
-        CodeGearManager cgm2 = createCGM(10001);
-        cgm2.createRemoteDGM("remote", "localhost", 10000);
-        cgm2.setup(new CreateRemoteTakeTest());
+        RTCommand cmd = new RTCommand("insert","line",0);
+        cgm.getDGM("remote").put("command",cmd);
     }
 }