

DIRECTORY
BasicTime USING [Now],
CrRPC USING [CreateClientHandle, DestroyClientHandle, Error, Handle],
FilingP10V5 USING [Handle, Session],
PFinalize USING [EnableFinalization, FinalizationQueue, FQEmpty, FQNext, Handle, HandleToObject, NewFQ],
PFS USING [Error],
Rope USING [ROPE],
RuntimeError USING [],
XNSAuth USING [Conversation, GetNextVerifier],
XNSFilingOps USING [CallProtected, ContinueOp, GuardOp, LogoffOp, LogonOp, MountRootOp, ServerData],
XNSFilingSession USING [ServerHandle, ServerObject];

XNSFilingSessionImpl: CEDAR MONITOR
IMPORTS BasicTime, CrRPC, PFinalize, PFS, XNSAuth, XNSFilingOps
EXPORTS XNSFilingSession ~ {
OPEN FilingP10V5, XNSFilingOps, XNSFilingSession;
ROPE: TYPE ~ Rope.ROPE;
dfq: PFinalize.FinalizationQueue ~ PFinalize.NewFQ[--20--];

CollectLostHandles: PROC ~ {
WHILE ( NOT PFinalize.FQEmpty[dfq] ) DO
handle: PFinalize.Handle ~ PFinalize.FQNext[dfq];
object: REF ~ PFinalize.HandleToObject[handle];
mnt: ServerData ~ NARROW[object];
ReleaseState: PROC ~ { LogoffOp[mnt] };
CallProtected[mnt, ReleaseState];
ENDLOOP;
};
XNSSweepInner: ENTRY PROC [mnt: ServerData, seconds: CARD]
RETURNS [cleanUp: BOOL м FALSE] ~ {
ENABLE UNWIND => NULL;
SELECT TRUE FROM
( mnt.admin.trTTL > seconds ) => { mnt.admin.trTTL м mnt.admin.trTTL - seconds };
( NOT mnt.admin.active ) => { mnt.admin.trTTL м 0; cleanUp м TRUE };
ENDCASE => { NULL };
};

XNSSweep: PUBLIC PROC [h: ServerHandle, seconds: CARD] ~ {
mnt: ServerData ~ NARROW[h.mnt];
ReleaseState: PROC ~ { LogoffOp[mnt] };
cleanUp: BOOL ~ XNSSweepInner[mnt, seconds];
IF ( cleanUp ) THEN CallProtected[mnt, ReleaseState];
CollectLostHandles[];
};
TransportProblem: TYPE ~ {serverInaccessible, connectionTimedOut};
ReportTransportError: PROC [problem: TransportProblem, sH: ServerHandle] ~ {
ERROR;
};

GetConnection: PROC [sH: ServerHandle] RETURNS [crH: CrRPC.Handle] ~ {
mnt: ServerData ~ NARROW[sH.mnt];
crH м CrRPC.CreateClientHandle[$SPP, mnt.address
! CrRPC.Error => ReportTransportError[$serverInaccessible, sH] ];
IF ( NOT Revive[mnt, crH] ) THEN {
IF ( crH # NIL ) THEN CrRPC.DestroyClientHandle[crH ! CrRPC.Error => CONTINUE];
ReportTransportError[$connectionTimedOut, sH];
};
mnt.admin.active м TRUE;
};
initialConnectionTTL: CARD м 8;
credentialsErrorTTL: CARD м 30;
BogusAddress: ERROR ~ CODE;

allHandles: LIST OF PFinalize.Handle м NIL;

RememberObject: PROC [h: PFinalize.Handle] ~ {
};

EstablishConnection: PROC [server: ROPE] RETURNS [mnt: ServerData м NIL] ~ {
MountFileSystem: PROC ~ { mnt м LogonOp[server]; MountRootOp[mnt] };
hook: PFinalize.Handle;
GuardOp[MountFileSystem];
mnt.admin м [tktTTL: 10000, trTTL: initialConnectionTTL, callsOut: 0, files: 0, lastOp: BasicTime.Now[], downMsg: NIL, active: FALSE];
hook м PFinalize.EnableFinalization[mnt, dfq]; -- dropping handle!
RememberObject[hook];
};

XNSGetServer: PUBLIC PROC [server: ROPE]
RETURNS [h: ServerHandle м NIL, downMsg: ROPE м NIL] ~ {
downMsg м "can\'t connect";
{
mnt: ServerData м EstablishConnection[server];
h м NEW[ServerObject м [
--flavor: myFlavor, name: server, procs: myServerProcs,-- mnt: mnt]];
downMsg м NIL;
};
};
XNSValidate: PUBLIC ENTRY PROC [h: ServerHandle]
RETURNS [obsolete: BOOL, downMsg: ROPE] ~ {
ENABLE UNWIND => NULL;
mnt: ServerData ~ NARROW[h.mnt];
IF ( mnt.admin.trTTL > 0 ) THEN [] м ReviveInternal[mnt]; -- returns 0 on errors
RETURN [(mnt.admin.trTTL <= 0), NIL];
};

minStart: CARD м 10; -- seconds to allow credentials to get down to

Revive: ENTRY PROC [mnt: ServerData, crH: CrRPC.Handle м NIL]
RETURNS [ok: BOOL м FALSE] ~ {
ENABLE UNWIND => NULL;
IF ( mnt.admin.trTTL < minStart ) THEN RETURN[ReviveInternal[mnt]];
mnt.session.verifier м XNSAuth.GetNextVerifier[mnt.tkt];
mnt.admin.trTTL м mnt.timeToLive;
RETURN[TRUE];
};

ReviveInternal: INTERNAL PROC [mnt: ServerData]
RETURNS [ok: BOOL м FALSE] ~ {
ENABLE PFS.Error => { GOTO GiveUp };
PokeServer: PROC ~ { ContinueOp[mnt] };
CallProtected[mnt, PokeServer];
ok м TRUE;
EXITS GiveUp => { NULL };
};
Init: PROC = {
};

Init[];
}.
    XNSFilingSessionImpl.mesa
Copyright ╙ 1990, 1992 by Xerox Corporation.  All rights reserved.
Bill Jackson (bj), May 30, 1990 1:32 pm PDT
Server Data Management
Finalization ...
Server Data Management
there is no time left on the connection so kill it.
Transport management
Parameters
Communications Startup
Returns [NIL, NIL] if server doesn't exist.
Returns [NIL, msg] if server exists but is down.
Keep Alive activities
Initialization
PFinalize.EstablishFinalization[type: CODE[ServerDataObject], npr: 0, fq: dfq];
 Э╩░  Ц(cedarcode) styleХNewlineDelimiter
Ш ЪЬЩJЪЬ
╧eЬ7ЩBJЩ+IcodeШ ЧЪ╧k	Ш	KЪЬ
ЮЬШKЪЬЮЬ:ШEKЪЬЮЬШ$KЪЬ
ЮЬYШhKЪЮЬЮЬ	ШKЪЬЮЬЮЬШKЪЬЮЬШKЪЬЮЬ!Ш.KЪЬЮЬRШdKЪЬЮЬШ4KШ ЧЪ╧nЬЮЬЮШ#KЪЮЬЮЬШ?KЪЮЬШKЪЮЬ-Ш1KЪЮЬЮЬЮЬШheadЪ╧zЩKЪ╧bЬ0╧cЬШ;KШ ЪЯЬЮЬШJЩЪЮЬЮЬбЬЮШ'KЪЬ,бЬШ1KЪЬЮЬ$Ш/KЪЬЮЬ	Ш!KЪЯЬЮЬШ'KЪЬ!Ш!KЪЮЬШЧKШЧЧЪаЩЪЯЬЮЬЮЬЮЬЮЬЮЬЮЬШ^KЪЮЬЮЬЮЬШЪЮЬЮЬЮШKШQЪЬЮЬ8ЮЬШDJЪЬ3Щ3ЧKЪЮЬЮЬШЧKЪЬШKШ ЧЪЯЬЮЬЮЬЮЬШ:KЪЬЮЬШ KЪЯЬЮЬШ'KЪЬ	ЮЬШ,KЪЮЬЮЬ"Ш5KЪЬШKШЧЧhead2ЪаЩKЪЬЮЬ,ШBЪЯЬЮЬ2ШLKЪЮЬШKШKШ ЧЪЯЬЮЬЮЬШFKЪЬЮЬ	Ш!KШrЪЮЬЮЬЮЬШ"KЪЮЬ	ЮЬЮЬ0ЮЬШOKЪЬ.Ш.KШЧKЪЬЮЬШKЪЬШЧЧЪа
Щ
Icode1ЪЬЮЬШNЪЬЮЬШЧЪаЩKЪЯЬЮЬЮЬШKШ KЪЬЮЬЮЬЮЬШ+KШ ЪЯЬЮЬШ.KШKШ ЧЪ
ЯЬЮЬ
ЮЬЮЬЮЬШLKЪЯЬЮЬ/ШDKЪЬШKЪЬШKЪЬrЮЬ
ЮЬШЖKЪЬ)бЬвШBKШШKШ ЧЧЪЯЬЮЬЮЬ
ЮЬЮЬЮЬЮЬЮЬШaKЪЬ	ЮЬЮЬЩ+KЪЬ	ЮЬ$Щ0KШШKШ.KЪЬЮЬв9ЬШ^KЪЬ
ЮЬШKШЧKШЧЧЪаЩЪЯЬЮЬЮЬЮЬЮЬЮЬЮЬШ\KЪЮЬЮЬЮЬШKЪЬЮЬШ KЪЮЬЮЬвШPKЪЮЬЮЬШ%KШKШ ЧKЪЬ
ЮЬв.ШCKШ ЪЯЬЮЬЮЬ'ЮЬЮЬЮЬЮЬШ\KЪЮЬЮЬЮЬШKЪЮЬ ЮЬЮЬШCKШ8KШ!KЪЮЬЮЬШKЪЬШЧKШ ЪЯЬЮЬЮЬЮЬЮЬЮЬШNKЪЮЬЮЬЮЬ
Ш$KЪЯ
ЬЮЬШ'KЪЬШKЪЬЮЬШ
KЪЮЬЮЬШKЪЬШЧЧЪаЩЪЯЬЮЬШKЪЬ&ЮЬ бЬЩOKЪЬШKШ ЧЧЧKШKЪЬШЧ ЕЧ    Ш  T  