
DIRECTORY
Commander,
CommanderOps,
IO,
JoinApp,
LB,
List,
NameService,
Rope,
RPCService,
RuntimeError,
SimpleFeedback,
SunRPC,
SunRPCAuth,
SymTab,
ThisMachine,
UT;

RPCServiceImpl: CEDAR MONITOR
IMPORTS Commander, CommanderOps, IO, JoinApp, LB, List, NameService, Rope, RuntimeError, SimpleFeedback, SunRPCAuth, SymTab, ThisMachine
EXPORTS RPCService ~
BEGIN

ROPE: TYPE ~ Rope.ROPE;

RegistrationRec: TYPE = RECORD [
nmsInstance: ROPE,
cmd: ROPE,
doLBRegistrations: BOOLEAN,
uid: ROPE,
locations: LIST OF ROPE _ NIL
];
RegistrationInfo: TYPE = REF RegistrationRec;

RegistrationsTable: SymTab.Ref _ SymTab.Create[];

JoinAppRPC: SunRPC.Server;
JoinAppRPCBI: ROPE;

CedarWorldUid: ROPE;

CedarWorldName: ROPE;

HostName: ROPE _ ThisMachine.Name[];
CirioPort: CARD _ 4815;

LBCl: LB.LB1;


GetPortNum: PROC RETURNS[CARD]
= TRUSTED MACHINE CODE {"CirioNubLocalGetPort"};


Register: PUBLIC PROC [nmsInstance: ROPE, cmd: ROPE, doLBRegistrations: BOOLEAN _ FALSE, oldNmsInstance: ROPE _ NIL] =
BEGIN
ENABLE RuntimeError.UNCAUGHT => GO TO Oops;
reg: RegistrationInfo _ NEW [RegistrationRec];
SimpleFeedback.Append[$RPCService, oneLiner, $Debug, IO.PutFR["RegisterWithRPCService[%g, %g]\n", IO.rope[nmsInstance], IO.rope[cmd]]];
reg.nmsInstance _ nmsInstance;
reg.cmd _ cmd;
reg.doLBRegistrations _ doLBRegistrations;
[] _ SymTab.Store[RegistrationsTable, nmsInstance, reg];
[JoinAppRPCBI, reg.uid] _ NameService.ExportRPCSun[name: "JoinApp", sp: JoinAppRPC, prog: JoinApp.JoinAppPrognum, vers: JoinApp.version1, instance: nmsInstance,
appl: CONS[
List.DotCons["Command", cmd],
NIL]
];
EXITS Oops => {};
END;

ServerNoOpProc:  JoinApp.servernoopProc = {
};

JoinApplicationProc: JoinApp.joinapplicationProc = {
retVal: UT.ObjectDescription;
result: ROPE _ "";
instance: ROPE _ NIL;
xServer: ROPE _ NIL;
location: ROPE _ NIL;
cmd: ROPE _ NIL;
cmdArgs: ROPE _ NIL;
fullCmd: ROPE;
found: BOOLEAN;
val: REF;
reg: RegistrationInfo;
ls: ROPE _ "JoinApp.JoinApplication called: ";
FOR i: CARD IN [0..in.size) DO
ls _ Rope.Concat[ls, IO.PutFR["(%g, %g) ", IO.rope[in[i].key], IO.rope[in[i].value]]];
IF Rope.Equal[in[i].key, "XServer", FALSE] THEN xServer _ in[i].value
ELSE IF Rope.Equal[in[i].key, "Location", FALSE] THEN location _ in[i].value
ELSE IF Rope.Equal[in[i].key, "Instance", FALSE] THEN instance _ in[i].value
ELSE IF Rope.Equal[in[i].key, "Command", FALSE] THEN cmd _ in[i].value
ELSE IF Rope.Equal[in[i].key, "CommandArgs", FALSE] THEN cmdArgs _ in[i].value;
ENDLOOP;
ls _ Rope.Concat[ls, " called.\n"];
SimpleFeedback.Append[$RPCService, oneLiner, $Debug, ls];
IF cmd # NIL THEN 
{
fullCmd _ cmd;
IF cmdArgs # NIL THEN fullCmd _ Rope.Cat[fullCmd, " ", cmdArgs];
IF xServer # NIL THEN fullCmd _ Rope.Cat["X11 -server ", xServer, " -- ", fullCmd];
result _ DoCommand[fullCmd];
ls _ IO.PutFR["%g -> %g\n", IO.rope[fullCmd], IO.rope[result]];
SimpleFeedback.Append[$RPCService, oneLiner, $Test, ls];
};
IF instance # NIL THEN 
{
[found, val] _ SymTab.Fetch[RegistrationsTable, instance];
reg _ NARROW[val];
IF location # NIL AND reg.doLBRegistrations THEN reg.locations _ CONS[location, reg.locations];
IF reg.doLBRegistrations THEN 
{
SimpleFeedback.Append[$RPCService, oneLiner, $Debug, "About to call LB.AtLoc.\n"];
RegisterWithLocationBroker[reg, location];
SimpleFeedback.Append[$RPCService, oneLiner, $Debug, "Return from LB.AtLoc.\n"];
}
};
retVal _ NEW[UT.SeqType1Object[1]];
retVal[0].key _ "Result";
retVal[0].value _ result;
RETURN [NEW [JoinApp.JoinApplicationreturnObject.iluSuccess _ [iluSuccess[retVal]]]];
};

DoCommand: PROC [cmd: ROPE] RETURNS [result: ROPE] =
BEGIN
ENABLE RuntimeError.UNCAUGHT => GO TO Oops;
r: REF;
result _ "ERROR";
[result, r] ¬ CommanderOps.DoCommandRope[cmd, NIL, NIL];
EXITS Oops => {};
END;

RegisterWithLocationBroker: PROC [reg: RegistrationInfo, location: ROPE] ~ {
object: UT.Objct;
loc: REF LB.LocationObject.LocationVLocRoom _ NEW [LB.LocationObject.LocationVLocRoom];
res: LB.AtLocreturn;

SimpleFeedback.Append[$RPCService, oneLiner, $Debug, "RegisterWithLocationBroker\n"];
object.binding _ JoinAppRPCBI;
object.rock _ Rope.ToRefText[Rope.Cat[reg.nmsInstance, ":", location]];
object.description _ NEW [UT.SeqType1Object[3]];
object.description[0].key _ "type";
object.description[0].value _ "JoinApp";
object.description[1].key _ "Name";
object.description[1].value _ reg.nmsInstance;
object.description[2].key _ "Command";
object.description[2].value _ reg.cmd;
loc.vLocRoom _ location;
res _ LBCl.atloc[LBCl, object, loc];
IF res.returnCode # iluSuccess THEN ERROR;
};

ConnectToLocationBroker: PROC [] =
BEGIN
ENABLE RuntimeError.UNCAUGHT => GO TO Oops;
h: SunRPC.Handle;
r: NameService.Registration;
[h, r] _ NameService.ImportRPCSun["LocationBroker"];
LBCl _ LB.MakeLB1Client[h, SunRPCAuth.Initiate[]]; 
EXITS Oops => {};
END;

ExportJoinAppInterface: PROC [] =
BEGIN
ENABLE RuntimeError.UNCAUGHT => GO TO Oops;
com: ROPE _ "Command";
xcom: ROPE _ "XCommander";
SimpleFeedback.Append[$RPCService, oneLiner, $Debug, "ExportJoinAppInterface\n"];
JoinAppRPC _ JoinApp.MakeJoinApp1Server[NIL, ServerNoOpProc, JoinApplicationProc];
CirioPort _ GetPortNum[];
CedarWorldName _ IO.PutFR["CedarWorld:%g:%g", IO.rope[HostName], IO.card[CirioPort]];
[JoinAppRPCBI, CedarWorldUid] _ NameService.ExportRPCSun[name: "JoinApp", sp: JoinAppRPC, prog: JoinApp.JoinAppPrognum, vers: JoinApp.version1, instance: CedarWorldName,
appl: CONS[
List.DotCons[com, xcom],
NIL]
];
EXITS Oops => {};
END;

RPCServiceCommand: Commander.CommandProc =
BEGIN
SimpleFeedback.Append[$RPCService, oneLiner, $Launch, "RPCService launched.\n"];
END;

ExportJoinAppInterface[];
ConnectToLocationBroker[];
Commander.Register["RPCService", RPCServiceCommand, "Commander access service via SunRPC"];
END.
  †  
RPCServiceImpl.mesa
Copyright Ó 1993 by Xerox Corporation.  All rights reserved.
Created by Theimer, December 17, 1992 7:58:24 am PST
Theimer, May 15, 1993 1:08 pm PDT
UID returned from NMS registration.
RPC handle for our exported JoinApp interface.
String binding handle for exported JoinApp interface.
NMS uid for the registration of this Cedar world in the NMS.
Instance name used for this Cedar world in the NMS.  Consists of CedarWorld:<hostname>:<worldId>
RPC handle for the LocationBroker.
Catch error caused if there is no NMS running.
Catch error caused if there is no NMS running.
Catch error caused if there is no NMS running.
Ê_  •NewlineDelimiter
™ ™J™<J™4J™!—J˜ codešÏk	˜	K˜
K˜K˜K˜K˜K˜K˜K˜K˜K˜K˜K˜K˜K˜K˜K˜—K˜ šÏbœœ˜Kšœ˜ˆJšœ˜—š˜K˜ Kšœœœ˜K˜ šœœœ˜ Kšœœ˜Kšœœ˜
Kšœ˜šœ˜
K™#—Kšœ˜K˜—Kšœœœ˜-K˜ K˜1K˜ ˜K™.—šœœ˜K™5—K˜ šœœ˜K™<—K˜ šœœ˜K™`—K˜ Kšœ
œ˜$Kšœœ˜K˜ ˜K™"—K˜ K˜ šÏn
œœœœ˜Kšœœœœ˜0—K˜ K˜ K˜ šŸœœœœœœœœ˜vKš˜šœœœœ˜+K™.—Kšœœ˜.K˜‡K˜K˜K˜*K˜8˜ šœœ˜˜Kšœ˜——K˜—Kšœ˜Kšœ˜—K˜ šÐbnœ˜+K˜—K˜ š œ!˜4Kšœœ˜Kšœœœ˜Kšœ
œœ˜Kšœ	œœ˜Kšœ

œ˜Kšœœœ˜Kšœ	œœ˜Kšœ	œ˜Kšœœ˜Kšœ˜	K˜Kšœœ&˜.šœœœ˜Kšœœœœ˜VKšœ"œœ˜EKšœœ#œœ˜LKšœœ#œœ˜LKšœœ"œœ˜FKšœœ&œœ˜OKšœ˜—K˜#K˜9šœœœ˜K˜K˜Kšœœœ+˜@Kšœœœ>˜SK˜K˜?K˜8K˜—šœœœ˜K˜K˜:Kšœœ˜Kš
œœœœœ˜_šœœ˜K˜K˜RK˜*K˜PK˜—K˜—Kšœ	œœ˜#K˜K˜KšœœJ˜UK˜—K˜ š
Ÿ	œœœœ
œ˜4Kš˜Kšœœœœ˜+Kšœœ˜K˜Kšœ.œœ˜8Kšœ˜Kšœ˜—K˜ š œœ#œ˜LKšœœ˜Kš	œœœ#œœ"˜WKšœœ˜K˜ K˜UK˜K˜GKšœœœ˜0K˜#K˜(K˜#K˜.K˜&K˜&K˜K˜$Kšœœœ˜*K˜——˜ šžœœ˜"Kš˜šœœœœ˜+K™.—K˜K˜K˜4K˜3Kšœ˜Kšœ˜—K˜ šžœœ˜!Kš˜šœœœœ˜+K™.—Kšœœ˜Kšœœ˜K˜QKšœ(œ'˜RK˜K˜U˜©šœœ˜˜Kšœ˜——K˜—Kšœ˜Kšœ˜—K˜ šžœ˜*Kš˜K˜PKšœ˜—K˜ K˜K˜K˜[—Kšœ˜— …—    \  A  