GenSImpl:
PUBLIC
PROC [] ~ {
failure: BOOLEAN;
programKey: ROPE;
programKeyWD: ROPE;
sImplStream: IO.STREAM;
allTheTables: TABLES;
uniqueNo: NAT ← 0;
h: SiroccoPrivate.Handle;
GenerateProcBlock: HashTable.EachPairAction ~ {
entry: REF DirectoryEntry ← NARROW [value];
name: ROPE ← NARROW [key];
id: ROPE;
list: CComponent;
successful: BOOLEAN;
type: CType;
value1: Value;
code: ROPE;
args: ROPE;
res: ROPE;
proc index
IO.PutF[sImplStream, Nest["%g => { -- %g", 3],
IO.rope[entry.constant],
IO.rope[name],
];
[successful, value1] ← HashTable.Fetch[allTheTables.condensedTypeTable, entry.type];
type ← NARROW[value1];
IF (type.children #
NIL)
THEN {
Set Context
list ← type.children;
uniqueNo ← 0;
Argument Construction (while writing required temps)
args ← "[h";
FOR loopindex:
CARD
IN [0..type.bound)
DO
IO.PutF[sImplStream, Nest["%g: %g;", 3],
IO.rope[list.name],
IO.rope[SiroccoPrivate.UnDo[list.type, h.programKey]]
];
args ← Rope.Cat[args, ", ", list.name];
list ← list.sibling;
ENDLOOP;
args ← Rope.Concat[args, "]" ];
Result Construction (while writing required temps)
res ← "[";
WHILE (list #
NIL)
DO
IO.PutF[sImplStream, Nest["%g: %g;", 3],
IO.rope[list.name],
IO.rope[SiroccoPrivate.UnDo[list.type, h.programKey]]
];
res ← Rope.Concat[res, list.name];
list ← list.sibling;
IF list # NIL THEN res ← Rope.Concat[res, ", "];
ENDLOOP;
res ← Rope.Concat[res, "]"];
Reset Context
list ← type.children;
uniqueNo ← 0;
IO.PutF[sImplStream, Nest["", 3]];
Acquring Arguments
FOR loopindex:
CARD
IN [0..type.bound)
DO
code ← "";
[successful, value1] ← HashTable.Fetch[allTheTables.condensedTypeTable, list.type];
type ← NARROW [value1];
IF ((type.class = bulkDataSource)
OR (type.class = bulkDataSink))
THEN {
IO.PutF[sImplStream, Nest["TRUSTED {", 4]];
[code, id] ← SiroccoPrivate.UnMarshal[h, type, list.type, list.name, code, uniqueNo, 4];
IO.PutF[sImplStream, Nest["%g", 4],
IO.rope[code]
];
code ← "};";
}
ELSE {
[code, id] ← SiroccoPrivate.UnMarshal[h, type, list.type, list.name, code, uniqueNo, 3];
};
IO.PutF[sImplStream, Nest["%g", 3],
IO.rope[code]
];
list ← list.sibling;
ENDLOOP;
Perform local Call
IO.PutF[sImplStream, Nest["", 3]];
IO.PutF[sImplStream, Nest["%g ← %g%g;", 3],
IO.rope[res],
IO.rope[name],
IO.rope[args]
];
IO.PutF[sImplStream, Nest["", 3]];
Transmit results
IO.PutF[sImplStream, Nest["beginReturn[h];", 3]];
IO.PutF[sImplStream, Nest["", 3]];
uniqueNo ← 0;
WHILE (list #
NIL)
DO
code ← "";
[successful, value1] ← HashTable.Fetch[allTheTables.condensedTypeTable, list.type];
type ← NARROW [value1];
[code, id] ← SiroccoPrivate.Marshal[h, type, list.type, list.name, code, uniqueNo, 3];
IO.PutF[sImplStream, Nest["%g", 3],
IO.rope[code]
];
list ← list.sibling;
ENDLOOP;
}
ELSE {
IO.PutF[sImplStream, Nest["NULL;", 3]];
};
IO.PutF[sImplStream, Nest["};", 2]];
};
GenerateErrorBlock: HashTable.EachPairAction ~ {
entry: REF DirectoryEntry ← NARROW [value];
name: ROPE ← NARROW [key];
id: ROPE;
list: CComponent;
successful: BOOLEAN;
type: CType;
value1: Value;
IF Rope.Equal[entry.constant, ""] THEN RETURN;
IO.PutF[sImplStream, Nest["%g%g => { -- (%g)", 3],
IO.rope[h.programKey],
IO.rope[name],
IO.rope[entry.constant]
];
IO.PutF[sImplStream, Nest["beginError[h, %g];", 3],
IO.rope[entry.constant]
];
[successful, value1] ← HashTable.Fetch[allTheTables.condensedTypeTable, entry.type];
type ← NARROW[value1];
list ← type.children;
WHILE (list #
NIL)
DO {
code: Rope.ROPE;
[successful, value1] ← HashTable.Fetch[allTheTables.condensedTypeTable, list.type];
[code, id] ← SiroccoPrivate.Marshal[h, NARROW[value1], list.type, list.name, code, uniqueNo, 3];
IO.PutF[sImplStream, Nest["%g", 3],
IO.rope[code]
];
list ← list.sibling;
}
ENDLOOP;
IO.PutF[sImplStream, Nest["", 2]];
IO.PutF[sImplStream, Nest["GO TO Finished;", 3]];
IO.PutF[sImplStream, Nest["};", 2]];
};
Heading:
PROC [out:
IO.
STREAM] ~ {
PutDirectory: HashTable.EachPairAction ~ {
interface: ROPE ~ NARROW [value];
IO.PutF[out, Nest["%g,", 1],
IO.rope[interface]
];
};
SiroccoPrivate.FileHeader[out, Rope.Concat[programKeyWD,"ServerImpl.Mesa"]];
IO.PutF[out, Nest["DIRECTORY", 1]];
IO.PutF[out, Nest["CrRPC,", 1]];
IO.PutF[out, Nest["CrRPCFriends,", 1]];
failure ← HashTable.Pairs[allTheTables.directory, PutDirectory];
IO.PutF[out, Nest["%g;", 0], IO.rope[programKeyWD]];
IO.PutF[out, Nest["", 0]];
IO.PutF[out, Nest["%gServerImpl: CEDAR PROGRAM", 1], IO.rope[programKeyWD]];
IO.PutF[out, Nest["IMPORTS CrRPC, %g ~ {", 1], IO.rope[programKeyWD],];
IO.PutF[out, Nest["OPEN %g;", 0], IO.rope[programKeyWD]];
IO.PutF[out, Nest["", 0]];
};
GenSImpl MAIN
h ← SIGNAL SiroccoPrivate.AquireState[];
allTheTables ← h.allTheTables;
programKey ← h.programKey;
programKeyWD ←
IO.PutFR["%gP%gV%g",
IO.rope[h.programName],
IO.int[h.programNo],
IO.int[h.versionNo]
];
sImplStream ← FS.StreamOpen[Rope.Concat[programKeyWD,"ServerImpl.Mesa"], $create];
Heading[sImplStream];
IO.PutF[sImplStream, Nest["Server: CrRPC.ServerProc ~ {", 1]];
IO.PutF[sImplStream, Nest["-- [h: Handle, pgm: CARD, pgmVersion: CARDINAL, proc: CARDINAL, beginReturn: BeginReturnProc, beginError: BeginErrorProc, beginReject: BeginRejectProc]", 1]];
IO.PutF[sImplStream, Nest["", 1]];
IO.PutF[sImplStream, Nest["ENABLE {", 2]];
failure ← HashTable.Pairs[allTheTables.errors, GenerateErrorBlock];
IO.PutF[sImplStream, Nest["};", 1]];
IO.PutF[sImplStream, Nest["", 1]];
IO.PutF[sImplStream, Nest["IF (pgmVersion # %g) THEN {", 2],
IO.int[h.versionNo]
];
IO.PutF[sImplStream, Nest["beginReject[h, CrRPC.noSuchVersion];", 2]];
IO.PutF[sImplStream, Nest["CrRPC.PutCARDINAL[h, %g]; --low", 2],
IO.int[h.versionNo]
];
IO.PutF[sImplStream, Nest["CrRPC.PutCARDINAL[h, %g]; --high", 2],
IO.int[h.versionNo]
];
IO.PutF[sImplStream, Nest["RETURN", 2]];
IO.PutF[sImplStream, Nest["};", 1]];
IO.PutF[sImplStream, Nest["", 1]];
IO.PutF[sImplStream, Nest["SELECT proc FROM", 2]];
failure ← HashTable.Pairs[allTheTables.procedures, GenerateProcBlock];
IO.PutF[sImplStream, Nest["ENDCASE => {", 3]];
IO.PutF[sImplStream, Nest["beginReject[h, CrRPC.noSuchProcedure];", 3]];
IO.PutF[sImplStream, Nest["};", 1]];
IO.PutF[sImplStream, Nest["", 1]];
IO.PutF[sImplStream, Nest["EXITS", 2]];
IO.PutF[sImplStream, Nest["Finished => { NULL };", 1]];
IO.PutF[sImplStream, Nest["};", 0]];
IO.PutF[sImplStream, Nest["", 1]];
IO.PutF[sImplStream, Nest["CrRPC.RegisterServerProc[pgm~%g, serverProc~Server, pgmVersion~%g];", 1],
IO.int[h.programNo],
IO.int[h.versionNo]
];
IO.PutF[sImplStream, Nest["CrRPC.EnsureListener[class~$SPP];", 0]];
IO.PutF[sImplStream, Nest["}...", 0]];
IO.Close[sImplStream];
};