<<>> <> <> <> <> <> <> <> <> DIRECTORY AdobeIO USING [LocalAndDomain], AdobeOps USING [ARSystemHandle], ARAccess USING [ARStorage, DataTable, ErrorCode], <> Convert USING [RopeFromCard], <> <> IO USING [Close, EndOfStream, Error, GetChar, STREAM], <> <> <> <> <> <> <> <> <> <> <> <> <> PFS USING [AbsoluteName, Close, Error, ErrorDesc, Open, OpenFile, PATH, PathFromRope, StreamFromOpenFile], <> RefText USING [AppendChar, ObtainScratch, ReleaseScratch], Rope USING [Cat, Concat, FromRefText, Length, ROPE, Text]; <> <> <> <> ARAccessImpl: CEDAR MONITOR --LOCKS session USING session: Session IMPORTS AdobeIO, Convert, IO, RefText, Rope, PFS --Auth, Courier, MSegment, NSDataStream, NSFile, NSName, NSString, --Process, Stream, String EXPORTS ARAccess = BEGIN OPEN ARAccess; <<-- -- -- -- -- -- -->> <> <<-- -- -- -- -- -- -->> Session: TYPE = AdobeOps.ARSystemHandle; <> <> <> <> <> <> <> <> <> <> <> <> ARHandle: TYPE = REF ARObject; ARObject: PUBLIC TYPE = RECORD [ password: CARDINAL ¬ ARPassword, <> fH: PFS.OpenFile ¬ NIL, --NSFile.Handle ¬ NSFile.nullHandle, sH: IO.STREAM ¬ NIL, name: Rope.ROPE ¬ NIL, --NSFile.String ¬ NSFile.nullString, number: CARDINAL ¬ LAST[CARDINAL], checkedOut: BOOLEAN ¬ FALSE]; CommandType: TYPE = {get, examine, checkout, checkin, submit, null}; SessionPassword: CARDINAL = 567B; ARPassword: CARDINAL = 234B; maxFileName: CARDINAL = 100; maxDigits: CARDINAL = 5; -- constant length of an AR filename secondsToWaitForCheckedOutAR: CARD --Process.Seconds-- = 0; <<-- -- -- -- -- -- -->> <> <<-- -- -- -- -- -- -->> Error: PUBLIC ERROR [session: Session, why: ErrorCode] = CODE; <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <<>> <> <> <> <> <> <> <> <> <<>> <> <> <> <> <> <> <> <> GetAR: PUBLIC PROCEDURE [session: Session, arNumber: CARDINAL] RETURNS [arH: ARHandle] = <> BEGIN getAR: PROC = { arH ¬ NEW[ARObject ¬ [ fH: OpenFileHandleOnAR[session, arNumber], number: arNumber]]; }; CatchErrors[session, getAR, get]; RETURN[arH] END; OpenFileHandleOnAR: PROCEDURE [ session: Session, arNumber: CARDINAL] RETURNS [fH: PFS.OpenFile --NSFile.Handle--] = { arFileName: Rope.ROPE ¬ NIL; --[maxFileName]; dH: PFS.PATH ¬ OpenSubDirectory[session, arNumber]; fH ¬ PFS.Open[ name: PFS.AbsoluteName[ARNumberToFileName[arNumber], dH]]; <> <> <> <> <> <> <<** with current impl of OpenSubDirectory, for now don't close;>> -- CloseFile[@dH, session] -- }; FreeAR: PUBLIC PROCEDURE [session: Session, arH: ARHandle] RETURNS [nil: ARHandle] = { <> <> IF arH.checkedOut THEN ERROR Error[session, youMustFirstCheckIn]; CloseFile[arH--@arH.fH--, session]; <> RETURN[NIL]; }; ExamineAR: PUBLIC PROCEDURE [session: Session, arH: ARHandle] RETURNS [to: ARAccess.ARStorage] = { Sink: PROC [source: ARHandle] = { ENABLE UNWIND => IO.Close[source.sH]; to ¬ CopyAR[session: session, from: source ! UNWIND => IO.Close[source.sH]]; }; examineAR: PROC = { Sink[arH]; CloseFile[arH, session]; }; CatchErrors[session, examineAR, examine] }; <> <> <> <> <> <> < CONTINUE;>> < Stream.Delete[source]};>> <<[] _ CopyAR[>> <> <>> <> < CONTINUE]];>> <<>> <> < CONTINUE]>> <> <> <> <> <<};>> <> <> <> <> <> <> <> <> <> < CONTINUE;>> < Stream.Delete[source]};>> <<[] _ CopyAR[>> <> <>> <> < CONTINUE]];>> <> < CONTINUE]>> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <<};>> <> <> <> <<};>> <> <> <> <> <> <> <> < Stream.Delete[sink];>> < CONTINUE};>> <<[] _ CopyAR[>> <> < NSDataStream.Abort[sink! NSDataStream.Aborted => CONTINUE]]>> <> < CONTINUE]>> <> <> <> <<[name[arH.name]], [type[NSAssignedTypes.tText]]];>> <> <<[fileID[arH.parentID]]];>> <> <> <> <> <> <> <> <> <> <> <> <> <<};>> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> < Stream.Delete[sink];>> < CONTINUE};>> <<[] _ CopyAR[>> <> < NSDataStream.Abort[sink ! NSDataStream.Aborted => CONTINUE]]>> <> < CONTINUE]>> <> <> <> <> <> <<[name[ARNumberToFileName[arNumber, fileName]]], [>> <> <> <> <> <> <<** with current impl of OpenSubDirectory, for now don't close;>> <> <> <> <> <<-- -- -- -- -- -- -->> <> <<-- -- -- -- -- -- -->> CatchErrors: PROCEDURE [session: Session, proc: PROC, type: CommandType] = BEGIN ENABLE { <> PFS.Error => PFSError[session, error]; IO.Error => ERROR Error[session, communicationError] }; proc[]; <> <>> <> <> < KillProbingProcess[session];>> <> END; <> <> <> <> < NSError[session, error];>> < ERROR Error[session, communicationError]};>> <> <> <> <> <> <> <> <>> <> <> < KillProbingProcess[session];>> <> <> <> <> <> <> <>> <> < ERROR Error[session, communicationError];>> <> <> <> <> <>> <> <>> <> <>> <> < ERROR Error[session, currentlyCheckedOut];>> < ERROR Error[session, arNotFound];>> < ERROR Error[session, communicationError];>> <>> <> <> <>> <> < ERROR Error[session, authError];>> <>> <> <> <> <> <> < ERROR Error[session, communicationError];>> <> PFSError: PROC [session: Session, error: PFS.ErrorDesc] = BEGIN SELECT error.group FROM bug => SELECT error.code FROM $inconsistent => ERROR Error[session, unknown]; ENDCASE => ERROR Error[session, unknown]; environment => SELECT error.code FROM $accessDenied => ERROR Error[session, accessDenied]; $quotaExceeded => ERROR Error[session, directoryFull]; $volumeFull => Error[session, fileServerFull]; ENDCASE => ERROR Error[session, authError]; client => SELECT error.code FROM $unkownFile =>ERROR Error[session, arNotFound]; ENDCASE => ERROR Error[session, unknown]; user => SELECT error.code FROM $versionSpecified => Error[session, invalidARNumber]; ENDCASE => ERROR Error[session, communicationError]; ENDCASE => ERROR Error[session, communicationError]; END; <> <> <> <<[fileID[session.referenceToARs.fileID]]];>> <> <> <> <> <> <> <> <> <> <> < CONTINUE]};>> <> <> <> <> <> <> <> < EXIT;>> <> <> <> <>> < GOTO error ENDCASE;>> < GOTO error] / 2;>> <> <> <> < SetSessionError[session, TRUE];>> <> ARNumberToFileName: PROCEDURE [number: CARDINAL--, name: Rope.ROPE--] RETURNS [PFS.PATH] = { temp: Rope.ROPE ¬ NIL; --[maxFileName]; temp ¬ temp.Concat[Convert.RopeFromCard[number, 10, FALSE]]; <> FOR i: CARDINAL IN [0..maxDigits - temp.Length) DO temp ¬ Rope.Concat["0", temp]; <> ENDLOOP; <> temp ¬ temp.Concat[".AR"]; <> RETURN[PFS.PathFromRope[temp]] <> }; <> <> <> <> <> <> <> <> AddPairToTable: PROCEDURE [arS: ARAccess.ARStorage, field, value: Rope.ROPE] RETURNS [newARS: ARAccess.ARStorage ¬ NIL] = { oldLen: CARD ¬ IF arS # NIL THEN arS.index ELSE 0; newARS ¬ NEW[ARAccess.DataTable[oldLen + 1]]; FOR i: CARD IN [0..oldLen) DO newARS[i] ¬ arS[i]; ENDLOOP; newARS[oldLen] ¬ [field, value]; newARS.index ¬ oldLen + 1; }; AppendChar: PUBLIC PROCEDURE [r: Rope.ROPE, c: CHAR] RETURNS [Rope.ROPE] = { scratch: REF TEXT = RefText.ObtainScratch[3]; result: Rope.Text = Rope.FromRefText[RefText.AppendChar[scratch, c]]; RefText.ReleaseScratch[scratch]; RETURN[r.Concat[result]]; }; CopyAR: PROC [session: Session, from: ARHandle] RETURNS [to: ARAccess.ARStorage] = { field, value: Rope.ROPE ¬ NIL; c: CHAR; { ENABLE IO.EndOfStream => { IO.Close[from.sH]; IF (field # NIL) THEN to ¬ AddPairToTable[to, field, value]; GOTO done; }; from.sH ¬ PFS.StreamFromOpenFile[from.fH]; DO c ¬ IO.GetChar[from.sH ! IO.EndOfStream => {IO.Close[from.sH]; GOTO done}]; WHILE c # ': DO IF c = '' THEN c ¬ IO.GetChar[from.sH]; field ¬ AppendChar[field, c]; c ¬ IO.GetChar[from.sH]; ENDLOOP; c ¬ IO.GetChar[from.sH]; c ¬ IO.GetChar[from.sH]; WHILE c # ('J - 75B) DO IF c = '' THEN c ¬ IO.GetChar[from.sH]; value ¬ AppendChar[value, c]; c ¬ IO.GetChar[from.sH]; ENDLOOP; c ¬ IO.GetChar[from.sH]; to ¬ AddPairToTable[to, field, value]; field ¬ value ¬ NIL; ENDLOOP; EXITS done => {}; } }; <> <> <> <> <> <> <> <> <> <<[bytesTransferred, why, savedSST] _ from.get[>> <> < {>> <> <> <> <> <> <> <> <> <> <> <> <> CloseFile: PROC [arH: ARHandle --fH: REF NSFile.Handle--, session: Session] = { IF arH.fH # NIL THEN { PFS.Close[arH.fH ! PFS.Error => CONTINUE]; arH.fH ¬ NIL } <> <> <> < CONTINUE];>> <> }; <> <<{>> <> <<[] _ NSFile.Probe[>> <> <>> <> <> <>> <> <> <> <> < CONTINUE];>> <> <> <> <> <> <<{RETURN[session.sessionError]};>> <> <> OpenSubDirectory: PROCEDURE [session: Session, arNumber: CARDINAL] RETURNS [dH: PFS.PATH --NSFile.Handle--] = { pathRope: Rope.ROPE ¬ NIL; <> pathRope ¬ Rope.Cat[ AdobeIO.LocalAndDomain[session.host], "-XNS:/", session.directory, "/"]; RETURN[PFS.PathFromRope[pathRope]] -- ** for now ** -- }; END... 24-Jul-87 17:31:11 - rlc - fix NSDataStream catch phrases