OpenXM/src/k097/lib/ox/ox.k - diff

Return to ox.k CVS log

Up to [local] / OpenXM / src / k097 / lib / ox

Diff for /OpenXM/src/k097/lib/ox/ox.k between version 1.2 and 1.11

-version 1.2, 2000/12/06 23:45:32
+version 1.11, 2001/01/26 12:24:57
 Line 1
 Line 1
 Line 1
- /* $OpenXM: OpenXM/src/k097/lib/ox/ox.k,v 1.1 2000/12/06 11:37:34 takayama Exp $  */
+ /* $OpenXM: OpenXM/src/k097/lib/ox/ox.k,v 1.10 2001/01/13 12:40:57 takayama Exp $  */
+ /* Load_sm1(["ox.sm1",AddString([GetEnv("OpenXM_HOME"),"/lib/sm1/ox.sm1"])],
+          "ox.sm1.loaded"); */
+ Load_sm1(["oxasir.sm1",AddString([GetEnv("OpenXM_HOME"),
+           "/lib/sm1/oxasir.sm1"])],
+          "oxasir.sm1.loaded");
+ class OXchannel extends Object {
+   local channel;
+   /* Just add a tag. */
+   def getChannel() {
+     return(channel);
+   }
+   def generate(c) {
+     this = new();
+     if (IsArray(c)) {
+       if (c[0] != "client") {
+          Error("OXchannel.generate(c) : c is not client object.");
+       }
+     }else{
+       Error("OXchannel.generate(c) : c is not client object.");
+     }
+     channel = c;
+     return(this);
+   }
+   def pushCMO(ob) {
+     local cc;
+     cc = channel;
+     sm1(" cc ob oxpushcmo ");
+   }
+   def pushCMD(ob) {
+     local cc;
+     cc = channel;
+     if (IsInteger(ob)) {
+       ob = IntegerToSm1Integer(ob);
+     }
+     sm1(" [(oxPushCMD) cc ob] extension ");
+   }
+   def popCMO() {
+     local cc,r;
+     cc = channel;
+     sm1(" cc oxpopcmo /r set ");
+     return(r);
+   }
+   def popString() {
+     local cc,r;
+     cc = channel;
+     sm1(" cc oxpopstring /r set ");
+     return(r);
+   }
+ }
  class OXcontrol extends Object {
    local control;
-   def new0(c) {
+   def getControl() {
+     return(control);
+   }
+   def generate(c,useX) {
+      if (Length(Arglist) <= 1) {
+        useX = true;
+      }
       if (Tag(c) != 0) {
         control = c;
         return(this);
       }else{
-        return(start());
+        return(start(useX));
       }
    }
-   def start() {
+   def start(useX) {
-     local c,e, pass, peer, data, s, stmp;
+     local c,e, pass, peer, data, s, stmp, xopt;
-     this = new(super.new0());
+     if (Length(Arglist) == 0) {
+        useX = true;
+     }
+     if (useX) {
+         xopt = " -x ";
+     }else{
+         xopt = "  ";
+     }
+     this = new(Object.new0());
      sm1(" [(oxGenPass)] extension /pass set ");
      sm1(" [(oxGetPort1) (localhost)] extension /peer set ");
      sm1(" /data peer 1 get toString def ");
      s = AddString(
-       ["/home/nobuki/OpenXM/src/oxc/oxc",
+       [GetEnv("OpenXM_HOME"),
-        " -c ", pass, " -h "," localhost ", " -p ", data, " -x ",
+        "/bin/oxc",
+        " -c ", pass, " -h "," localhost ", " -p ", data, xopt,
         " & "]);
      sm1(" [ (/bin/csh -c \") s (\") ] cat /stmp set ");
      sm1(" stmp message ");
      sm1(" stmp system  ");
      sm1(" [(oxCreateControl_RFC_101) peer 0 pass] extension /c set ");
-     control = c;
+     control = OXchannel.generate(c);
      return(this);
    }
+   def pushCMO(a) {
+     control.channel.pushCMO(a);
+   }
+   def pushCMD(a) {
+     control.channel.pushCMD(a);
+   }
+   def popCMO() {
+     return(control.channel.popCMO());
+   }
+   def popString() {
+     return(control.channel.popString());
+   }
  }
+ /* How to debug?
+    sm1(" OX { vname } sendmsg /aaa set ");
+    Get the value of vname in the context OX and set it to aaa.
+ */
- class OXengine extends OXcontrol {
+ class OX extends OXcontrol {
-   local engine;
+   local engine, engineIDs;
-   def start(control,name) {
+   def getEngine() {
-     local c,e, pass, peer, data, s, stmp, engineID;
+      return(engine);
-     this = super.new0(control);
+   }
-     control = this.control;
+   def getEngineIDs() {
+      return(engineIDs);
+   }
+   /* OX.generate("ox_sm1"); or OX.generate("ox_sm1",null) */
+   def generate(name,control,useX) {
+     local c,e, pass, peer, data, s, stmp, engineID,nn;
+     nn = Length(Arglist);
+     if (nn == 0) {
+       name = "ox_sm1";  control = null; useX = true;
+     }
+     if (nn == 1) {
+       control = null; useX = true;
+     }
+     if (nn == 2) {
+       useX = true;
+     }
+     this = new(OXcontrol.generate(control,useX));
+     control = this.getControl();
      sm1(" [(oxGetPort1) (localhost)] extension /peer set ");
      sm1(" /data peer 1 get def ");
-     control.pushCMO(data);
+     /* BUG: control.pushCMO(data) does not work.
-     control.pushCMO(name);
+             Use control = super.getControl(); */
+     control.pushCMO([[data],name]);
      control.pushCMD(SM_control_spawn_server);
      engineID = control.popCMO();
+     print("engineID=");Println(engineID);
+     if (Tag(engineID) == 257 ) {  /* error object */
+        Error("Server could be found.");
+     }
+     engineIDs = [engineID];
      sm1(" [(oxCreateEngine_RFC_101) peer 0 (Empty) engineID] extension /c set ");
-     engine = c;
+     engine = OXchannel.generate(c);
      return(this);
+   }
+   def pushCMO(a) {
+     engine.channel.pushCMO(a);
+   }
+   def pushCMD(a) {
+     engine.channel.pushCMD(a);
+   }
+   def popCMO() {
+     return(engine.channel.popCMO());
+   }
+   def popString() {
+     return(engine.channel.popString());
+   }
+   def rpc_submit(func,ar) {
+      local n,i,one,comm;
+      if (! IsString(func)) {
+        Error("The first argument of rpc must be a string.");
+      }
+      if (! IsArray(ar)) {
+        Error("The second argument of rpc must be a list.");
+      }
+      one = IntegerToSm1Integer(1);
+      sm1(" getVlist2 toString /comm set ");
+      comm = AddString(["OxVlist=",comm,";"]);
+      this.pushCMO(comm);
+      this.pushCMD(SM_executeStringByLocalParser);
+      this.pushCMO("print(OxVlist);");
+      this.pushCMD(SM_executeStringByLocalParser);
+      n = Length(ar);
+      for (i=n-1; i>=0; i--) {
+        this.pushCMO(ar[i]);
+        this.pushCMO(one);
+        this.pushCMO("ox_dtop");
+        this.pushCMD(SM_executeFunction);
+      }
+      this.pushCMO(IntegerToSm1Integer(n));
+      this.pushCMO(func);
+      this.pushCMD(SM_executeFunction);
+   }
+   def rpc(func,ar) {
+      local one;
+      sm1(" /one 1 def ");
+      rpc_submit(func,ar);
+      this.pushCMO(one);
+      this.pushCMO("ox_ptod");
+      this.pushCMD(SM_executeFunction);
+      return(this.popCMO());
+   }
+   def rpc_str(func,ar) {
+      rpc_submit(func,ar);
+      return(this.popString());
+   }
+   def executeString(s) {
+      this.pushCMO(s);
+      this.pushCMD(SM_executeStringByLocalParser);
+   }
  }
+ /*
+   Example:
+      a = startAsir();
+      f = a.rpc("fctr",[x^10-1]);
+      Println(f);
+ */
+ def startAsir() {
+   return(Asir.generate());
  }
+ class Asir extends OX {
+   local ;
+   def generate(useX) {
+     local asirpeer,a;
+     if (Length(Arglist) == 0) { useX = true; }
+     this = new(OX.generate("ox_asir",null,useX));
+     a = this;
+     asirpeer = (a.getEngine()).getChannel();
+     Println(asirpeer);
+     sm1(" [asirpeer oxasirpath.asirlib] loadAsirFile ");
+     return(this);
+   }
+   def OnTimer() {
+     local a;
+     a = this;
+     a.executeString("K0_timer=time();");
+     a.popString();
+     a.executeString("K0_timer_CPU=K0_timer[0];");
+     a.popString();
+     a.executeString("K0_timer_GC=K0_timer[1];");
+     a.popString();
+   }
+   def OffTimer() {
+     local a;
+     a = this;
+     a.executeString("map(rtostr,[time()[0]-K0_timer_CPU,
+                                  time()[1]-K0_timer_GC]);");
+     return(a.popCMO());
+   }
+ }

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>