DIRECTORY XNSCHName, Rope, AlpInstance, AlpineEnvironment, AlpineEnvironmentP2201V1, XNS, XNSCH, XNSAuth, AlpineP2202V1, AlpInstanceCourier, AuthenticationP14V2, UserCredentials, CrRPC, RPC, Booting; AlpInstanceCourierImpl: CEDAR MONITOR IMPORTS XNSCHName, Rope, CrRPC, XNSCH, XNSAuth, AlpineP2202V1, RPC, UserCredentials, Booting EXPORTS AlpInstance ~ BEGIN OPEN AE: AlpineEnvironment, AlpI: AlpInstance; objectCache: LIST OF CacheRec _ NIL; CacheRec: TYPE = RECORD [ object: AlpI.Handle _ NIL, caller: AE.Principal _ NIL ]; FindObjectInCache: INTERNAL PROCEDURE[fileStore: AE.FileStore, caller: AE.Principal, key: RPC.EncryptionKey, pwd: Rope.ROPE, identity: XNSAuth.Identity] RETURNS[handle: AlpI.Handle _ NIL] = BEGIN fileStoreName: XNSCHName.Name; connectionProblem: AlpineP2202V1.ConnectionProblem; authenticationProblem: AuthenticationP14V2.Problem; crReason: CrRPC.ErrorReason; realFileStore: Rope.ROPE _ fileStore; alpinePos: INT _ Rope.FindBackward[s1: fileStore, s2: ".alpine", case: FALSE]; IF fileStore.Length[] - alpinePos = 7 THEN realFileStore _ fileStore.Substr[len: alpinePos]; fileStoreName _ XNSCHName.NameFromRope[realFileStore]; realFileStore _ XNSCHName.RopeFromName[fileStoreName]; FOR list: LIST OF CacheRec _ objectCache, list.rest UNTIL list = NIL DO IF Rope.Equal[list.first.object.fileStore, fileStore, FALSE] THEN BEGIN IF Rope.Equal[list.first.caller, caller, FALSE] AND (key = list.first.object.key) THEN RETURN[list.first.object]; END; ENDLOOP; handle _ NEW[AlpI.Object _ [ trans: NIL, file: NIL, owner: NIL, volume: NIL, otherInterfaces: NIL, conversation: NIL, key: key, fileStore: fileStore]]; { ENABLE { AlpineP2202V1.ConnectionError => {connectionProblem _ problem; GOTO connection}; AlpineP2202V1.AuthenticationError => { authenticationProblem _ problem; GOTO auth }; CrRPC.Error => SELECT errorReason FROM unknown, unknownClass, argsError, resultsError, bulkDataError, notImplemented, unknownOperation, notServerHandle, notClientHandle, addressInappropriateForClass, other => REJECT; ENDCASE => { crReason _ errorReason; GOTO rpcErr}; }; serverAddress: REF XNS.Address ~ NEW[XNS.Address _ XNSCH.LookupAddressFromRope[realFileStore].address]; courierHandle: CrRPC.Handle ~ CrRPC.CreateClientHandle[$SPP, serverAddress]; authenticatedConversation: XNSAuth.Conversation ~ XNSAuth.Initiate[identity, fileStoreName]; credentials: XNSAuth.Credentials ~ XNSAuth.GetCredentials[authenticatedConversation]; verifier: XNSAuth.Verifier _ XNSAuth.GetNextVerifier[authenticatedConversation]; session: AlpineP2202V1.Session; [session, verifier] _ AlpineP2202V1.Logon[courierHandle, fileStoreName, credentials, [caller, pwd], verifier]; handle.otherInterfaces _ LIST[NEW[AlpInstanceCourier.InstanceObject _ [ , courierHandle, authenticatedConversation, credentials, session]]]; EXITS connection => ERROR RPC.ImportFailed[communications]; auth => ERROR RPC.AuthenticateFailed[badCaller]; -- no appropriate reason available. rpcErr => SELECT crReason FROM rejectedNoSuchProgram => ERROR RPC.ImportFailed[unbound]; rejectedNoSuchVersion, rejectedNoSuchProcedure => ERROR RPC.ImportFailed[wrongVersion]; communicationFailure, remoteClose, cantConnectToRemote => ERROR RPC.ImportFailed[communications]; courierVersionMismatch, rejectedInvalidArgument, rejectedUnspecified, remoteError, protocolError => ERROR RPC.ImportFailed[stubProtocol]; ENDCASE => ERROR; }; objectCache _ CONS[ [handle, caller], objectCache]; END; Create: PUBLIC ENTRY PROC [fileStore: AE.FileStore, caller: AE.Principal, key: RPC.EncryptionKey] RETURNS [handle: AlpI.Handle] ~ { ENABLE UNWIND => NULL; identity: XNSAuth.Identity; psw: Rope.ROPE; BEGIN [caller, psw] _ UserCredentials.Get[]; TRUSTED BEGIN key _ RPC.MakeKey[psw]; END; END; identity _ UserCredentials.GetIdentity[]; handle _ FindObjectInCache[fileStore, caller, key, psw, identity]; }; AlpRollbackProcedure: ENTRY Booting.RollbackProc = -- TYPE = PROC[clientData: REF ANY]; BEGIN ENABLE { UNWIND => NULL }; objectCache _ NIL; END; TRUSTED { Booting.RegisterProcs[c: , r: AlpRollbackProcedure]; }; END. "AlpInstanceCourierImpl.mesa Carl Hauser, November 11, 1987 6:43:24 pm PST Remove any .alpine from the name -- backward compatibility hack First, get a three part name for the fileStore (completing the domain and organization) subsequently, use the Rope version of the fully qualified name This is a terrible abuse of AlpInstance.Objects; for Courier we don't need trans, file, owner, and volume because we are never doing a local import. On the other hand, we need a place to hang our Courier handle and conversation so we'll use otherInterfaces in a stylized way. IF caller = NIL THEN have to ignore caller for now because can't make an RPC password out of a key. Change the Alpine interface so it takes a key instead of a password and this can change back. non system-fatal errors: none. Ê©˜šœ™Icode™-—J™šÏk ˜ Kšœ˜Kšœ˜Kšœ ˜ Kšœ˜K˜Kšœ˜Kšœ˜Kšœ ˜ Kšœ˜Kšœ˜Kšœ˜Kšœ˜K˜Kšœ˜Kšœ˜K˜—K˜Kšœ ˜%KšœU˜\Kšœ˜šœ˜K˜—Kšœœ'˜.K˜Kšœ œœœ˜$šœ œœ˜Kšœ˜Kšœœ ˜K˜—˜K˜—š Ïnœœ œœœ˜YKšœœœœ˜cš˜Kšœ˜Kšœ3˜3Kšœ3˜3Kšœ˜Kšœœ ˜%K™?Kšœœ9œ˜NKšœ$œ2˜\K™WKšœ6˜6K™>Kšœ6˜6š œœœ"œ˜Gšœ4œœ˜GKš œ'œœœœ˜rKšœ˜——Kšœ˜šœ œ˜K™•Kšœœ˜Kšœœ˜ Kšœœ˜Kšœœ˜Kšœœ˜Kšœœ˜K˜ K˜—˜šœ˜Kšœ?œ ˜PKšœ<œœ˜Tšœœ˜&Kšœªœ˜±Kšœœ ˜2—Kšœ˜—Kšœœœœœœ/˜gKšœL˜LKšœ\˜\KšœU˜UKšœP˜PK˜Kšœn˜nKšœœœk˜Œš˜Kšœœ"˜5Kšœœœ!Ïc#˜Ušœ œ œ˜Kšœœœ˜:Kšœ2œœ˜YKšœ:œœ˜bKšœdœœ˜‰Kšœœ˜——K˜—Kšœœ!˜3—šœ˜K˜K˜——šžœœœœ œœ˜NKšœœ˜4Kšœœœ˜K˜Kšœ œ˜šœ œ™K™šœ˜K˜&Kšœœœœ˜*Kšœ˜——Kšœ)˜)KšœB˜BK˜K˜—šœœŸ$˜WKšœ™Kšœ™š˜šœ˜Jšœ˜J˜—Kšœœ˜—šœ˜K˜K˜——Kšœœ8˜AK˜K˜Kšœ˜—…—úÅ