File: [local] / OpenXM / src / k097 / lib / ox / ox.k (download)
Revision 1.4, Mon Dec 11 13:53:28 2000 UTC (23 years, 6 months ago) by takayama
Branch: MAIN
Changes since 1.3: +19 -2
lines
OX.generate(null,servername) starts the control server and an engine
"servername" and returns an OX object. The OpenXM RFC 101 protocol
is used.
|
/* $OpenXM: OpenXM/src/k097/lib/ox/ox.k,v 1.4 2000/12/11 13:53:28 takayama Exp $ */
Load_sm1(["ox.sm1",AddString([GetEnv("OpenXM_HOME"),"/lib/sm1/ox.sm1"])],
"ox.sm1.loaded");
def void Error(s) {
sm1(" s error ");
}
class OXchannel extends Object {
local channel;
/* Just add a tag. */
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);
}
}
class OXcontrol extends Object {
local control;
def generate(c) {
if (Tag(c) != 0) {
control = c;
return(this);
}else{
return(start());
}
}
def start() {
local c,e, pass, peer, data, s, stmp;
this = new(super.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",
" -c ", pass, " -h "," localhost ", " -p ", data, " -x ",
" & "]);
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 = 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());
}
}
/* How to debug?
sm1(" OX { vname } sendmsg /aaa set ");
Get the value of vname in the context OX and set it to aaa.
*/
class OX extends OXcontrol {
local engine;
/* OX.generate(null,"ox_sm1"); */
def generate(control,name) {
local c,e, pass, peer, data, s, stmp, engineID;
this = new(super.generate(control));
control = this.control;
sm1(" [(oxGetPort1) (localhost)] extension /peer set ");
sm1(" /data peer 1 get def ");
control.pushCMO(data);
control.pushCMO(name);
control.pushCMD(SM_control_spawn_server);
engineID = control.popCMO();
print("engineID=");Println(engineID);
HOGE = control;
sm1(" [(oxCreateEngine_RFC_101) peer 0 (Empty) engineID] extension /c set ");
engine = OXchannel.generate(c);
return(this);
}
}