[BACK]Return to ox.k CVS log [TXT][DIR] Up to [local] / OpenXM / src / k097 / lib / ox

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

version 1.10, 2001/01/13 12:40:57 version 1.11, 2001/01/26 12:24:57
Line 1 
Line 1 
 /* $OpenXM: OpenXM/src/k097/lib/ox/ox.k,v 1.9 2000/12/27 10:16:12 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"])],  /* Load_sm1(["ox.sm1",AddString([GetEnv("OpenXM_HOME"),"/lib/sm1/ox.sm1"])],
          "ox.sm1.loaded"); */           "ox.sm1.loaded"); */
Line 62  class OXcontrol extends Object {
Line 62  class OXcontrol extends Object {
   def getControl() {    def getControl() {
     return(control);      return(control);
   }    }
   def generate(c) {    def generate(c,useX) {
        if (Length(Arglist) <= 1) {
          useX = true;
        }
      if (Tag(c) != 0) {       if (Tag(c) != 0) {
        control = c;         control = c;
        return(this);         return(this);
      }else{       }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;
       if (Length(Arglist) == 0) {
          useX = true;
       }
       if (useX) {
           xopt = " -x ";
       }else{
           xopt = "  ";
       }
     this = new(Object.new0());      this = new(Object.new0());
     sm1(" [(oxGenPass)] extension /pass set ");      sm1(" [(oxGenPass)] extension /pass set ");
     sm1(" [(oxGetPort1) (localhost)] extension /peer set ");      sm1(" [(oxGetPort1) (localhost)] extension /peer set ");
Line 79  class OXcontrol extends Object {
Line 90  class OXcontrol extends Object {
     s = AddString(      s = AddString(
       [GetEnv("OpenXM_HOME"),        [GetEnv("OpenXM_HOME"),
        "/bin/oxc",         "/bin/oxc",
        " -c ", pass, " -h "," localhost ", " -p ", data, " -x ",         " -c ", pass, " -h "," localhost ", " -p ", data, xopt,
        " & "]);         " & "]);
     sm1(" [ (/bin/csh -c \") s (\") ] cat /stmp set ");      sm1(" [ (/bin/csh -c \") s (\") ] cat /stmp set ");
     sm1(" stmp message ");      sm1(" stmp message ");
Line 117  class OX extends OXcontrol {
Line 128  class OX extends OXcontrol {
      return(engineIDs);       return(engineIDs);
   }    }
   /* OX.generate("ox_sm1"); or OX.generate("ox_sm1",null) */    /* OX.generate("ox_sm1"); or OX.generate("ox_sm1",null) */
   def generate(name,control) {    def generate(name,control,useX) {
     local c,e, pass, peer, data, s, stmp, engineID;      local c,e, pass, peer, data, s, stmp, engineID,nn;
     if (Length(Arglist) == 0) {      nn = Length(Arglist);
       name = "ox_sm1";  control = null;      if (nn == 0) {
         name = "ox_sm1";  control = null; useX = true;
     }      }
     if (Length(Arglist) == 1) {      if (nn == 1) {
       control = null;        control = null; useX = true;
     }      }
     this = new(OXcontrol.generate(control));      if (nn == 2) {
         useX = true;
       }
       this = new(OXcontrol.generate(control,useX));
     control = this.getControl();      control = this.getControl();
     sm1(" [(oxGetPort1) (localhost)] extension /peer set ");      sm1(" [(oxGetPort1) (localhost)] extension /peer set ");
     sm1(" /data peer 1 get def ");      sm1(" /data peer 1 get def ");
Line 214  class OX extends OXcontrol {
Line 229  class OX extends OXcontrol {
      Println(f);       Println(f);
 */  */
 def startAsir() {  def startAsir() {
   local a,asirpeer;    return(Asir.generate());
   a = OX.generate("ox_asir");  
   asirpeer = (a.getEngine()).getChannel();  
   Println(asirpeer);  
   sm1(" [asirpeer oxasirpath.asirlib] loadAsirFile ");  
   return(a);  
 }  }
   
 class Asir extends OX {  class Asir extends OX {
   local ;    local ;
   def generate() {    def generate(useX) {
     local asirpeer,a;      local asirpeer,a;
     this = new(OX.generate("ox_asir",null));      if (Length(Arglist) == 0) { useX = true; }
       this = new(OX.generate("ox_asir",null,useX));
     a = this;      a = this;
     asirpeer = (a.getEngine()).getChannel();      asirpeer = (a.getEngine()).getChannel();
     Println(asirpeer);      Println(asirpeer);
     sm1(" [asirpeer oxasirpath.asirlib] loadAsirFile ");      sm1(" [asirpeer oxasirpath.asirlib] loadAsirFile ");
     return(this);      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());
   }    }
 }  }
Legend:
Removed from v.1.10  
changed lines
  Added in v.1.11
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>