
DIRECTORY
Basics,
Convert,
IO,
RefText,
Rope,
XNS,
XNSRouter;

XNSRouterImpl: CEDAR MONITOR
IMPORTS Basics, Convert, IO, RefText, Rope
EXPORTS XNSRouter
~ {
smallBufSize: CARD ~ 100; -- this is big enough for most things ...
largeBufSize: CARD ~ 4096; -- this is the largest buffer Unix(tm) stream ioctl accepts ...
byteAddressedOrElse: BOOL[TRUE..TRUE] м (BYTES[CARD32] = UNITS[CARD32]);
smallBuf: REF TEXT м RefText.New[smallBufSize];
largeBuf: REF TEXT м RefText.New[largeBufSize];
Hops: TYPE ~ XNSRouter.Hops;
maxHops: Hops ~ XNSRouter.maxHops;
unreachable: Hops ~ XNSRouter.unreachable;
Net: TYPE ~ XNS.Net;
unknownNet: Net ~ XNS.unknownNet;
RoutingTableEntry: TYPE ~ XNSRouter.RoutingTableEntry;
ROPE: TYPE ~ Rope.ROPE;
XNSRouterHandle: TYPE ~ RECORD[h: INT]; -- opaque
ReturnCode: TYPE ~ INT;
BytePtr: TYPE ~ LONG POINTER TO BYTE;

IsError: PROC [rc: ReturnCode] RETURNS [err: BOOL] ~ INLINE { err м (rc < 0) };

ReturnCodeFromHandle: PROC [h: XNSRouterHandle] RETURNS [ReturnCode] ~ INLINE { RETURN [MIN[0, h.h]] };

XRCreateXNSRouterHandle: PROC RETURNS [h: XNSRouterHandle] ~ TRUSTED MACHINE CODE { "XR_CreateXNSRouterHandle" };

XRDestroyXNSRouterHandle: PROC [h: XNSRouterHandle] ~ TRUSTED MACHINE CODE { "XR_DestroyXNSRouterHandle" };

XRGetXNSRouterParameter: UNSAFE PROC [h: XNSRouterHandle, buf: BytePtr, nBytes: CARD32] RETURNS [rc: ReturnCode] ~ UNCHECKED MACHINE CODE { "XR_GetXNSRouterParameter" };

XRSetXNSRouterParameter: PROC [h: XNSRouterHandle, buf: BytePtr, nBytes: CARD32] RETURNS [rc: ReturnCode] ~ TRUSTED MACHINE CODE { "XR_SetXNSRouterParameter" };
ConvertDotCardFromCLiteral: PROC [r: ROPE, defaultBase: Convert.Base м 10]
RETURNS [ans: CARD] ~ {
pos, len, lim: INT;
pos м Rope.SkipTo[r, 0, "0123456789"];
len м Rope.Length[r];
IF pos >= len THEN ERROR Convert.Error[syntax, len];
lim м Rope.SkipOver[r, pos, "0123456789abcdefABCDEFxX"];
IF (pos > 0) OR (lim < len) THEN r м Rope.Substr[r, pos, lim-pos];
SELECT TRUE FROM
Rope.IsPrefix["0x", r, FALSE] => {
ans м Convert.CardFromRope[Rope.Substr[r, 2], 16];
};
(Rope.Fetch[r, 0] = '0) => {
ans м Convert.CardFromRope[r, 8];
};
ENDCASE => {
ans м Convert.CardFromRope[r, defaultBase];
};
};

ConvertDotCLiteralFromCard: PROC [card: CARD, base: CARD м 10] RETURNS [r: ROPE] ~ {
IF card = 0 THEN RETURN ["0"];
SELECT base FROM
8 => r м IO.PutFR1["0%%b", IO.card[card]];
10 => r м IO.PutFR1["%d", IO.card[card]];
16 => r м IO.PutFR1["0x%x", IO.card[card]];
ENDCASE => ERROR Convert.Error[invalidBase, 0];
};
NetFromNDString: PROC [nds: ROPE] RETURNS [net: Net] ~ {
net м Basics.FFromCard32[Convert.CardFromRope[nds, 16]];
};

NDStringFromNet: PROC [net: Net] RETURNS [ndString: ROPE] ~ {
temp: ROPE м IO.PutFR1["%x", IO.card[Basics.Card32FromF[net]]];
len: INT м Rope.Length[temp];
ndString м IF len >= 8 THEN temp ELSE Rope.Replace["00000000", 8-len, len, temp];
};

AppendWord: PROC [t: REF TEXT, w: ROPE] RETURNS [new: REF TEXT] ~ {
new м RefText.AppendRope[to~t, from~w];
new м RefText.AppendChar[to~new, from~VAL[0]];
};

FetchWord: PROC [t: REF TEXT, start: CARD] RETURNS [next: CARD, w: ROPE] ~ {
IF start >= t.length THEN RETURN[start, NIL];
FOR next м start, next.SUCC WHILE (next < t.length) AND (t[next] # VAL[0]) DO NULL ENDLOOP;
RETURN[w~Rope.FromRefText[t, start, (next-start)], next~next.SUCC];
};
GetRouterParameterInternal: INTERNAL PROC [h: XNSRouterHandle, buf: REF TEXT, key: ROPE, subKey: ROPE м NIL] RETURNS [ok: BOOL м FALSE] ~ {
rc: ReturnCode;
buf.length м 0;
buf м AppendWord[buf, key];
buf м AppendWord[buf, subKey];
buf м AppendWord[buf, NIL]; -- n.b. appending two NILs is okay ...
{ temp: REF TEXT;
temp м RefText.Append[to~RefText.New[buf.length], from~buf];
};
TRUSTED {
rc м XRGetXNSRouterParameter[ h, LOOPHOLE[buf, BytePtr]+BYTES[TEXT[0]], buf.maxLength];
};
IF NOT IsError[rc] THEN {
buf.length м buf.maxLength;
ok м TRUE;
};
};

NewGetHops: PUBLIC ENTRY PROC [net: Net] RETURNS [hops: Hops] ~ {
h: XNSRouterHandle;
hops м unreachable;
h м XRCreateXNSRouterHandle[];
IF NOT IsError[ReturnCodeFromHandle[h]] THEN {
{ ENABLE Convert.Error => {
CONTINUE;
};
netLiteral, r: ROPE;
netLiteral м NDStringFromNet[net];
IF GetRouterParameterInternal[h, smallBuf, "xr_hops", netLiteral].ok THEN {
[w~r] м FetchWord[smallBuf, 0];
hops м Convert.CardFromDecimalLiteral[r];
};
};
XRDestroyXNSRouterHandle[h];
};
};

NewGetRouting: PUBLIC ENTRY PROC [net: Net] RETURNS [rte: RoutingTableEntry] ~ {
h: XNSRouterHandle;
rte м [hops~unreachable, immediate~unknownNet, delay~CARD.LAST];
h м XRCreateXNSRouterHandle[];
IF NOT IsError[ReturnCodeFromHandle[h]] THEN {
{
r, netRope: ROPE;
netRope м NDStringFromNet[net];
IF GetRouterParameterInternal[h, smallBuf, "xr_hops", netRope].ok THEN {
ENABLE Convert.Error => CONTINUE;
[w~r] м FetchWord[smallBuf, 0];
rte.hops м Convert.CardFromDecimalLiteral[r];
};
IF GetRouterParameterInternal[h, smallBuf, "xr_dest_relative_netid", netRope].ok THEN {
ENABLE Convert.Error => CONTINUE;
[w~r] м FetchWord[smallBuf, 0];
rte.immediate м NetFromNDString[r];
};
IF GetRouterParameterInternal[h, smallBuf, "xr_rtt", netRope].ok THEN {
ENABLE Convert.Error => CONTINUE;
[w~r] м FetchWord[smallBuf, 0];
rte.delay м ConvertDotCardFromCLiteral[r];
};
};
XRDestroyXNSRouterHandle[h];
};
};


EnumerateInner: INTERNAL PROC [low, high: Hops, proc: PROC[Net, RoutingTableEntry]  RETURNS [BOOL]] ~ {
h: XNSRouterHandle;
rte: RoutingTableEntry;
pos: INT;
netRope: ROPE;

h м XRCreateXNSRouterHandle[];
IF NOT IsError[ReturnCodeFromHandle[h]] THEN {
directlyConnectedNet: Net;
IF NOT GetRouterParameterInternal[h, largeBuf, "xr_nets_at_hop", "0"].ok
THEN GOTO Out;
[w~netRope] м FetchWord[largeBuf, 0];

directlyConnectedNet м NetFromNDString[netRope ! Convert.Error => GOTO Out];
FOR hops: Hops IN [low .. high] DO -- for each distance
hopsLiteral: ROPE м ConvertDotCLiteralFromCard[hops];
IF GetRouterParameterInternal[h, largeBuf, "xr_nets_at_hop", hopsLiteral].ok THEN {
pos м 0;
DO -- for each net at that distance
[pos, netRope] м FetchWord[largeBuf, pos];
IF Rope.IsEmpty[netRope] THEN EXIT;
rte м [hops~hops, immediate~unknownNet, delay~CARD.LAST];
rte.immediate м directlyConnectedNet; -- TEMPORARY KLUDGE
rte.delay м 1000 * hops + 500; -- TEMPORARY KLUDGE
{ ENABLE Convert.Error => CONTINUE;
net: Net м NetFromNDString[netRope];
IF NOT proc[ net, rte ] THEN GOTO Out
};
ENDLOOP; -- for each net at that distance
};
ENDLOOP; -- for each distance
GOTO Out;
EXITS
Out => XRDestroyXNSRouterHandle[h];
};
};

Enumerate: PUBLIC ENTRY PROC [low, high: Hops, proc: PROC[Net, RoutingTableEntry]] ~ {
ENABLE UNWIND => NULL;
MyProc: PROC [n: Net, rte: RoutingTableEntry] RETURNS [continue: BOOL] ~ {
proc[n, rte];
RETURN[TRUE];
};
EnumerateInner[low, high, MyProc];
};

GetHops: PUBLIC ENTRY PROC [net: Net] RETURNS [hops: Hops м unreachable] ~ {
ENABLE UNWIND => NULL;
MyProc: PROC [n: Net, rte: RoutingTableEntry] RETURNS[BOOL] ~ {
IF n = net THEN { hops м rte.hops; RETURN [FALSE] };
RETURN [TRUE];
};
EnumerateInner[0, maxHops, MyProc];
};

GetRouting: PUBLIC ENTRY PROC [net: Net] RETURNS [entry: RoutingTableEntry] ~ {
ENABLE UNWIND => NULL;
MyProc: PROC [n: Net, rte: RoutingTableEntry] RETURNS[BOOL] ~ {
IF n = net THEN { entry м rte; RETURN [FALSE] };
RETURN [TRUE];
};
entry м [unreachable, unknownNet, CARD.LAST];
EnumerateInner[0, maxHops, MyProc];
};

GetNetsAtHops: ENTRY PROC [hops: Hops] RETURNS [list: LIST OF ROPE м NIL] ~ {
ENABLE UNWIND => NULL;
MyProc: PROC [n: Net, rte: RoutingTableEntry] RETURNS [BOOL] ~ {
list м CONS[NDStringFromNet[n], list];
RETURN [TRUE];
};
EnumerateInner[hops, hops, MyProc];
};
}.
   №  
XNSRouterImpl.mesa
Copyright ╙ 1989, 1991, 1992 by Xerox Corporation.  All rights reserved.
Demers, October 19, 1990 11:44 am PDT
Tim Diebert: November 29, 1989 7:01:13 am PST
Willie-s, January 9, 1992 1:13 pm PST
ToDo
This is an interim implementation that tries to work around an apparent bug in the Mentat router code (it seems to return the info for the wrong network in response to any query except "xr_nets_at_hop").  Here everything is implemented by enumerating the nets by distance, assuming there's only one connected network (so the "immediate" field an a RoutingTableEntry is uninteresting) and using the default 0.5 sec overhead and 1.0 sec internet hop delay time values.  The commented procs below ought to be used when the Mentat code gets fixed.
ConvertDotCardFromCLiteral and ConvertDotCLiteralFromCard ought to move to Convert.
Parameters and global data
Types
Glue
Utilities that ought to be in Convert
Private Procs
DBMsg[NIL, IO.PutFR["NetFromNDString %s", IO.rope[nds]]];
Exported to XNSRouter
DBMsg[temp, "calling GetRouterParameterInternal"];
DBMsg[smallBuf, "convert.err"];
IF GetRouterParameterInternal[h, smallBuf, "xr_dest_relative_netid", netRope].ok THEN {
immRope: ROPE;
[w~immRope] _ FetchWord[smallBuf, 0];
rte.immediate _ NetFromNDString[immRope ! Convert.Error => CONTINUE];
};
IF GetRouterParameterInternal[h, smallBuf, "xr_rtt", netRope].ok THEN {
delayRope: ROPE;
[w~delayRope] _ FetchWord[smallBuf, 0];
rte.delay _ ConvertDotCardFromCLiteral[delayRope ! Convert.Error => CONTINUE];
};
Э╩
и  Ц(cedarcode) styleХNewlineDelimiter
Щ codeЩKЪЬ
╧eЬ=ЩHJЩ%KЩ-KЩ%KШ ЧЪ╧k	Ш	KШKШKЪЮЬШKШKШKЪЮЬШKЪЬ
Ш
KШ ЧЪ╧nЬЮЬЮШKЪЮЬЮЬШ*KЪЮЬ
ШKШheadЩKЩЯKЩSЧЩKЪЬЮЬ╧c)ШCKЪЬЮЬ	а"╨cuаШZKЪЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬШHKЪЬ
ЮЬЮЬШ/KЪЬ
ЮЬЮЬШ/ЧЩЪЬЮЬШKЪЬ"Ш"KЪЬ*Ш*ЧЪЬЮЬЮЬШKЪЬЮЬШ!ЧKЪЬЮЬШ6KЪЮЬЮЬЮЬШЧЩKЪЬЮЬЮЬЮЬа	Ш1KЪЬЮЬЮЬШKЪЬ	ЮЬЮЬЮЬЮЬЮЬШ%KШ Ъ
ЯЬЮЬЮЬЮЬЮЬШOKШ ЧKЪЯЬЮЬЮЬЮЬЮЬЮЬШgKШ ЪЯЬЮЬЮЬЮЬЮЬЮЬ ШqKШ ЧKЪ
ЯЬЮЬЮЬЮЬЮЬ!ШkKШ ЪЯЬЮЬ,ЮЬЮЬЮ	ЬЮЬЮЬ ШйKШ ЧKЪЯЬЮЬ,ЮЬЮЬЮЬЮЬЮЬ ШаЧЩ%Ъ
ЯЬЮЬЮЬ"ЮЬЮЬШbKЪЬЮЬШKШ&KЪЬШKЪЮЬЮЬЮЬШ4KШ8KЪЮЬЮЬЮЬ"ШBЪЮЬЮЬЮШЪЬЮЬШ"KШ2KШЧЪЬШKШ!KШЧЪЮЬШKШ+KШЧЧKШKШ ЧЪЯЬЮЬЮЬЮЬЮЬЮЬШTKЪЮЬ
ЮЬЮЬШЪЮЬЮШKЪЬ	ЮЬЮЬШ*KЪЬ
ЮЬЮЬШ)KЪЬ
ЮЬЮЬШ+KЪЮЬЮЬШ/ЧKШЧЧЩЪЯЬЮЬЮЬЮЬШ8KЪЬЮЬЮЬЮЬЩ9KШ8KШKШ ЧЪЯЬЮЬЮЬЮЬШ=KЪЬЮЬЮЬЮЬ Ш?KЪЬЮЬШKЪЬЮЬ
ЮЬЮЬ,ШQKШKШ ЧЪЯ
ЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬШCKШ'KЪЬ&ЮЬШ.KШKШ ЧЪЯ	ЬЮЬЮЬЮЬ	ЮЬЮЬЮЬЮЬШLKЪЮЬЮЬЮЬЮЬШ-KЪЮЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬШ[KЪЮЬ7ЮЬШCKШЧЧЩЪЯЬЮЬЮЬЮЬЮЬЮЬ
ЮЬЮЬЮЬЮЬЮЬШЛKШKШKШKЪЬШKЪЬЮЬа&ШBЪЬЮЬЮЬШKШ<KЪЬ2Щ2KШЧЪЮЬШ	KЪЬ!ЮЬЮЬЮЬШWKШЧЪЮЬЮЬЮЬШKШKЪЬЮЬШ
KШЧKШKШ ЧЪ
Я
ЬЮЬЮЬЮЬЮЬШAKШKШKЪЬШЪЮЬЮЬ"ЮЬШ.ЪЬЮЬШKЪЬЩKЪЮЬШ	KЪЬШKЪЬЮЬШKЪЬ"Ш"ЪЮЬCЮЬШKKЪЬШKЪЬ)Ш)KШЧKШЧKШKШЧKШKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШPKШKЪЬ5ЮЬЮЬШ@KЪЬШЪЮЬЮЬ"ЮЬШ.ЪЬШKЪЬЮЬШKЪЬШЪЮЬ@ЮЬШHKЪЮЬЮЬШ!KЪЬШKЪЬ-Ш-KШЧЪЮЬOЮЬШWKЪЮЬЮЬШ!KЪЬШKЪЬ#Ш#KШЧЪЮЬ?ЮЬШGKЪЮЬЮЬШ!KЪЬШKЪЬ*Ш*KШЧKШЧKШKШЧKШKШ ЧKШ ЪЯЬЮЬЮЬЮЬЮЬЮЬШgKШKЪЬШKЪЬЮЬШ	KЪЬ	ЮЬШKШ KЪЬШЪЮЬЮЬ"ЮЬШ.KШKЪЮЬЮЬCЮЬЮЬШWKЪЬ%Ш%KШ KЪЬBЮЬШLЪЮЬЮЬЮЬаШ7KЪЬЮЬ$Ш5ЪЮЬKЮЬШSKЪЬШЪЮЬа Ш#KЪЬ*Ш*KЪЮЬЮЬЮЬШ#KЪЬ.ЮЬЮЬШ9ЪЮЬOЮЬЩWKЪЬ	ЮЬЩKЪЬ%Щ%KЪЬ;ЮЬЩEKЩЧKЪЬ&аШ9ЪЮЬ?ЮЬЩGKЪЬЮЬЩKЪЬ'Щ'KЪЬDЮЬЩNKЩЧKЪЬаШ2ЪЬЮЬЮЬШ#KШ$KЪЮЬЮЬЮЬЮЬШ%KШЧKЪЮЬа Ш)ЧKШЧKЪЮЬШЧKЪЮЬШ	ЪЮШKШ#ЧKШЧKШKШ ЧЪ
Я	ЬЮЬЮЬЮЬЮЬШVKЪЮЬЮЬЮЬШЪЯЬЮЬ"ЮЬЮЬШJKЪЬШKЪЮЬЮЬШKШЧKШ"KШKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШLKЪЮЬЮЬЮЬШЪЯЬЮЬ"ЮЬЮЬШ?KЪЮЬ	ЮЬЮЬЮЬШ4KЪЮЬЮЬШKШЧKЪЬ#Ш#KШKШ ЧЪ
Я
ЬЮЬЮЬЮЬЮЬШOKЪЮЬЮЬЮЬШЪЯЬЮЬ"ЮЬЮЬШ?KЪЮЬ	ЮЬЮЬЮЬШ0KЪЮЬЮЬШKШЧKЪЬ"ЮЬЮЬШ-KЪЬ#Ш#KШKШ ЧЪЯЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬШMKЪЮЬЮЬЮЬШЪЯЬЮЬ"ЮЬЮЬШ@KЪЬЮЬШ&KЪЮЬЮЬШKШЧKЪЬ#Ш#KШЧЧKЪЬШЧЧ ЕЧ    А  .$  