<> <> <> <<>> <> <<>> DIRECTORY Camelot, CamelotRecoverable, IO USING [int, PutFR], Mach, Process USING [Detach, MsecToTicks, Pause], Rope, YggBuffMan, YggDIDMap, YggdrasilInit, YggEnvironment; <<>> YggdrasilInitImpl: CEDAR PROGRAM IMPORTS Camelot, CamelotRecoverable, Mach, IO, Process, YggBuffMan, YggDIDMap, YggdrasilInit EXPORTS YggdrasilInit, YggEnvironment ~ BEGIN <> dsPort: PUBLIC Mach.portT; serverID: PUBLIC Camelot.serverIdT; tsPort: PUBLIC Mach.portT; mPort: PUBLIC Mach.portT; sPort: PUBLIC Mach.portT; dsqSharedMemAddr: PUBLIC Mach.vmAddressT; tPort: PUBLIC Mach.portT; aPort: PUBLIC Mach.portT; atPort: PUBLIC Mach.portT; taPort: PUBLIC Mach.portT; applicationID: PUBLIC Camelot.applicationIdT; <> camlibServerPort: Mach.portT; CamelotRecoveryComplete: BOOL _ FALSE; ReadyForRecovery: PUBLIC BOOL _ FALSE; <> <<>> InitSeqDescList: Camelot.ListOfSegmentDesc; InitSeqPortList: Mach.ListOfPorts; InitializePart1: PUBLIC PROC [] ~ { <> <> <> fullSeqDescList: Camelot.ListOfSegmentDesc; fullSeqPortList: Mach.ListOfPorts; firstTime: BOOL _ FALSE; kernCode: Mach.kernReturnT; { -- InitializeGlobalData calling to ServerInit dsPort _ GetTheDSPort[]; [serverID: serverID, tsPort: tsPort, mPort: mPort, sPort: sPort, sharedMemAddr: dsqSharedMemAddr, seqDescList: InitSeqDescList, seqPortList: InitSeqPortList, kernCode: kernCode] _ Camelot.DSInitialize[dsPort: dsPort, raiseSignal: TRUE]; Camelot.DSQInit[dsqSharedMemAddr]; }; TRUSTED {Process.Detach[FORK NotifyHandlerProcess[]];}; -- CamlibInitServerInternal [fullSeqDescList, fullSeqPortList] _ CamelotRecoverable.CamelotRecoverableInit[]; IF fullSeqDescList = NIL THEN fullSeqDescList _ InitSeqDescList ELSE { FOR fsdl: Camelot.ListOfSegmentDesc _ fullSeqDescList, fsdl.rest UNTIL fsdl = NIL DO IF fsdl.rest = NIL THEN {fsdl.rest _ InitSeqDescList; EXIT}; ENDLOOP; }; IF fullSeqPortList = NIL THEN fullSeqPortList _ InitSeqPortList ELSE { FOR lop: Mach.ListOfPorts _ fullSeqPortList, lop.rest UNTIL lop = NIL DO IF lop.rest = NIL THEN {lop.rest _ InitSeqPortList; EXIT}; ENDLOOP; }; firstTime _ RecoverSegments[fullSeqDescList, fullSeqPortList, TRUE]; -- CamlibInitServerInternal }; InitializePart2: PUBLIC PROC [serverName: Rope.ROPE, applName: Rope.ROPE] RETURNS [firstTime: BOOL _ FALSE] ~ { firstTime _ RecoverSegments[InitSeqDescList, InitSeqPortList, FALSE]; -- CamlibInitServerInternal [] _ Mach.portRestrict[Mach.taskSelf[], sPort, TRUE]; -- CamlibInitServerInternal TRUSTED {Process.Detach[FORK SystemMessageHandler[]];}; -- CamlibInitServerInternal { -- PublicizeService [newPort: camlibServerPort] _ Mach.portAllocate[Mach.taskSelf[], TRUE]; [] _ Mach.netnameCheckIn[Mach.nameServerPort[], serverName, Mach.taskSelf[], camlibServerPort, TRUE]; }; [] _ Mach.portUnrestrict[Mach.taskSelf[], camlibServerPort, TRUE]; TRUSTED {Process.Detach[FORK RequestHandler[]];}; <> ReadyForRecovery _ TRUE; WHILE ~CamelotRecoveryComplete DO Process.Pause[Process.MsecToTicks[50]] ENDLOOP; { -- TA_AddApplication setup tPortList: Mach.ListOfPorts; [portList: tPortList] _ Camelot.CALookup[Mach.nameServerPort[], "TranPort", "", 1, 1, TRUE]; IF tPortList = NIL THEN ERROR; IF tPortList.rest # NIL THEN ERROR; tPort _ tPortList.first; [newPort: atPort] _ Mach.portAllocate[Mach.taskSelf[], TRUE]; [] _ Mach.portRestrict[Mach.taskSelf[], atPort, TRUE]; [applicationID: applicationID, taPort: taPort] _ Camelot.TAAddApplication[tPort: tPort, atPort: atPort, authName: applName, raiseSignal: TRUE]; TRUSTED {Process.Detach[FORK ApplSysMsgHandler[]];}; }; YggDIDMap.InitDIDMap[firstTime]; -- call after recovery completes and TAAddApplication }; <<>> RecoveryComplete: PUBLIC PROC [] ~ { CamelotRecoveryComplete _ TRUE; }; <<>> <> <<>> RecoverSegments: PROC [seqDescList: Camelot.ListOfSegmentDesc, seqPortList: Mach.ListOfPorts, firstPass: BOOL] RETURNS [firstTime : BOOL ] ~ { <