<<>> <> <> <> <<>> DIRECTORY CrRPC USING [Handle], IO USING [STREAM], PFS USING [FileType, Mutability, nullUniqueID, tUnspecified, UniqueID], PFSClass USING [AttachProc, CloseProc, CopyProc, DeleteProc, EnumerateClientPropertiesProc, EnumerateForInfoProc, EnumerateForNamesProc, FileInfoProc, FileManipulationProcs, FileManipulationProcsObject, FSHandle, FSObject, GetClientPropertyProc, GetHandleProc, GetInfoProc, LookupNameProc, MaintenanceProcs, MaintenanceProcsObject, OpenFile, OpenProc, ReadProc, Register, RenameProc, RetrieveProc, SetAttributesProc, SetByteCountAndUniqueIDProc, SetClientPropertyProc, StoreProc, SweepProc, ValidateProc, WriteProc], PFSNames USING [PATH], <> Rope USING [ROPE]; XNSViewImpl: CEDAR MONITOR LOCKS tr USING tr: Transport IMPORTS PFSClass ~ { ROPE: TYPE ~ Rope.ROPE; <> Transport: TYPE ~ REF TransportBody; TransportBody: TYPE ~ MONITORED RECORD [ crH: CrRPC.Handle, mnt: REF ]; TransportProc: TYPE ~ PROC [tr: Transport]; CallProtected: PROC [mnt: REF, inner: TransportProc] ~ { crH: CrRPC.Handle ~ NIL; link: Transport ~ NEW[TransportBody]; UnderLock: ENTRY TransportProc ~ { ENABLE UNWIND => { NULL }; inner[tr]; }; link.crH _ crH; link.mnt _ mnt; UnderLock[link]; }; <> xnsFlavor: ATOM ~ $XNS; VFS: TYPE ~ REF VFSInstance; VFSInstance: TYPE ~ RECORD [ fs: ROPE, flavorSpecified: BOOL ]; GetHandle: PFSClass.GetHandleProc ~ { instance: VFS ~ NEW[VFSInstance _ [fs: fs, flavorSpecified: flavorSpecified] ]; downMsg _ NIL; h _ NEW[PFSClass.FSObject _ vfs^]; <> h.data _ instance; }; vfs: PFSClass.FSHandle ~ NEW [PFSClass.FSObject _ [ flavor: xnsFlavor, name: NIL, -- filled in upon instantiation maintenanceProcs: mo, procs: fmo, data: NIL -- filled in upon instantiation ]]; <> mo: PFSClass.MaintenanceProcs ~ NEW [PFSClass.MaintenanceProcsObject _ [ sweep: Sweep, validate: Validate ]]; <> Sweep: PFSClass.SweepProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; NULL; }; Validate: PFSClass.ValidateProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; obsolete _ FALSE; downMsg _ NIL; IF ( FALSE ) THEN { obsolete _ TRUE; downMsg _ NIL }; IF ( FALSE ) THEN { obsolete _ FALSE; downMsg _ "downMsg" }; }; <> fmo: PFSClass.FileManipulationProcs ~ NEW[PFSClass.FileManipulationProcsObject _ [ delete: Delete, enumerateForInfo: EnumerateForInfo, enumerateForNames: EnumerateForNames, fileInfo: FileInfo, lookupName: Lookup, rename: Rename, copy: Copy, setAttributes: SetAttributes, setByteCountAndUniqueID: SetByteCountAndUniqueID, setClientProperty: SetClientProperty, getClientProperty: GetClientProperty, enumerateClientProperties: EnumerateClientProperties, read: Read, write: Write, open: Open, close: Close, store: Store, retrieve: Retrieve, attach: Attach, getInfo: GetInfo ]]; <> XNSDelete: PROC ~ { << fileH: FilingP10V5.Handle; withKids: BOOL; [fileH: fileH, withKids: withKids] _ FindFile[mnt, crH, file, wantedUniqueID, $delete]; IF ( withKids ) THEN { ENABLE UNWIND => { mnt.session.verifier _ XNSAuth.GetNextVerifier[mnt.conversation]; FilingP10V5.Close[h: crH, file: fileH, session: mnt.session^]; }; xx: ROPE ~ IO.PutFR["Directory %g has children", IO.rope[file] ]; PFSBackdoor.ProduceError[accessDenied, xx] }; { delete: BOOL _ IF ( proc = NIL ) THEN TRUE ELSE proc[fullName, uniqueID]; IF ( delete ) THEN { mnt.session.verifier _ XNSAuth.GetNextVerifier[mnt.conversation]; FilingP10V5.Delete[h: crH, file: fileH, session: mnt.session^]; <> <> }; }; mnt.active _ FALSE; ReturnConnection[crH]; >> }; Delete: PFSClass.DeleteProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; DeleteInner: TransportProc ~ { ENABLE UNWIND => { NULL }; fullName: PFSNames.PATH _ NIL; uniqueID: PFS.UniqueID _ PFS.nullUniqueID; continue: BOOL _ IF ( proc = NIL ) THEN TRUE ELSE proc[fullName, uniqueID]; }; CallProtected[mnt, DeleteInner]; }; XNSEnumerateForInfo: PROC ~ { << P: PROC [file: ROPE, bytes: INT, created: BasicTime.GMT, fileType: FileType, version: Version, fID: FileID, isDir: BOOL, withKids: BOOL, pathName: REF TEXT] RETURNS [continue: BOOL] = { continue _ proc[file, bytes, created, fileType]; }; InnerEnumerate[h, pattern, FALSE, P, $enumerate]; >> }; EnumerateForInfo: PFSClass.EnumerateForInfoProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; EnumerateForInfoInner: TransportProc ~ { ENABLE UNWIND => { NULL }; fullFName: PFSNames.PATH _ NIL; attachedTo: PFSNames.PATH _ NIL; uniqueID: PFS.UniqueID _ PFS.nullUniqueID; bytes: INT _ 0; mutability: PFS.Mutability _ immutable; fileType: PFS.FileType _ PFS.tUnspecified; continue: BOOL _ IF ( proc = NIL ) THEN TRUE ELSE proc[fullFName, attachedTo, uniqueID, bytes, mutability, fileType]; }; CallProtected[mnt, EnumerateForInfoInner]; }; EnumerateForNames: PFSClass.EnumerateForNamesProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; EnumerateForNamesInner: TransportProc ~ { ENABLE UNWIND => { NULL }; name: PFSNames.PATH; continue: BOOL _ IF ( proc = NIL ) THEN TRUE ELSE proc[name]; }; CallProtected[mnt, EnumerateForNamesInner]; }; FileInfo: PFSClass.FileInfoProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; FileInfoInner: TransportProc ~ { ENABLE UNWIND => { NULL }; version _ [none]; attachedTo _ NIL; bytes _ 0; uniqueID _ PFS.nullUniqueID; mutability _ immutable; fileType _ PFS.tUnspecified; }; CallProtected[mnt, FileInfoInner]; }; Lookup: PFSClass.LookupNameProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; path: PFSNames.PATH; LookupInner: TransportProc ~ { ENABLE UNWIND => { NULL }; path _ NIL; }; CallProtected[mnt, LookupInner]; RETURN[path]; }; Rename: PFSClass.RenameProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; RenameInner: TransportProc ~ { ENABLE UNWIND => { NULL }; done _ TRUE; }; CallProtected[mnt, RenameInner]; }; Copy: PFSClass.CopyProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; CopyInner: TransportProc ~ { ENABLE UNWIND => { NULL }; done _ TRUE; }; CallProtected[mnt, CopyInner]; }; SetAttributes: PFSClass.SetAttributesProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; SetAttributesInner: TransportProc ~ { ENABLE UNWIND => { NULL }; NULL; }; CallProtected[mnt, SetAttributesInner]; }; SetByteCountAndUniqueID: PFSClass.SetByteCountAndUniqueIDProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; SetByteCountAndUniqueIDInner: TransportProc ~ { ENABLE UNWIND => { NULL }; NULL; }; CallProtected[mnt, SetByteCountAndUniqueIDInner]; }; SetClientProperty: PFSClass.SetClientPropertyProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; SetClientPropertyInner: TransportProc ~ { ENABLE UNWIND => { NULL }; NULL; }; CallProtected[mnt, SetClientPropertyInner]; }; GetClientProperty: PFSClass.GetClientPropertyProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; GetClientPropertyInner: TransportProc ~ { ENABLE UNWIND => { NULL }; propertyValue _ NIL; }; CallProtected[mnt, GetClientPropertyInner]; }; EnumerateClientProperties: PFSClass.EnumerateClientPropertiesProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; EnumerateClientPropertiesInner: TransportProc ~ { ENABLE UNWIND => { NULL }; propertyName: ROPE; propertyValue: ROPE; continue: BOOL _ IF ( proc = NIL ) THEN TRUE ELSE proc[propertyName, propertyValue]; }; CallProtected[mnt, EnumerateClientPropertiesInner]; }; Open: PFSClass.OpenProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; of: PFSClass.OpenFile; OpenInner: TransportProc ~ { ENABLE UNWIND => { NULL }; of _ NIL; }; CallProtected[mnt, OpenInner]; RETURN[of]; }; Read: PFSClass.ReadProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; ReadInner: TransportProc ~ { ENABLE UNWIND => { NULL }; bytesRead _ 0; }; CallProtected[mnt, ReadInner]; }; Write: PFSClass.WriteProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; WriteInner: TransportProc ~ { ENABLE UNWIND => { NULL }; bytesWritten _ 0; }; CallProtected[mnt, WriteInner]; }; Close: PFSClass.CloseProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; CloseInner: TransportProc ~ { ENABLE UNWIND => { NULL }; NULL; }; CallProtected[mnt, CloseInner]; }; Store: PFSClass.StoreProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; StoreInner: TransportProc ~ { ENABLE UNWIND => { NULL }; fullName: PFSNames.PATH _ NIL; continue: BOOL _ IF ( proc = NIL ) THEN TRUE ELSE proc[fullName]; }; CallProtected[mnt, StoreInner]; }; Retrieve: PFSClass.RetrieveProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; RetrieveInner: TransportProc ~ { ENABLE UNWIND => { NULL }; fullFName: PFSNames.PATH _ NIL; bytes: INT _ 0; uniqueID: PFS.UniqueID _ PFS.nullUniqueID; s: IO.STREAM _ IF ( proc = NIL ) THEN NIL ELSE proc[fullFName, bytes, uniqueID]; IF ( s = NIL ) THEN ERROR; }; CallProtected[mnt, RetrieveInner]; }; Attach: PFSClass.AttachProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; AttachInner: TransportProc ~ { ENABLE UNWIND => { NULL }; toFName _ NIL; }; CallProtected[mnt, AttachInner]; }; GetInfo: PFSClass.GetInfoProc ~ { class: PFSClass.FSHandle ~ h; mnt: VFS ~ NARROW[class.data]; GetInfoInner: TransportProc ~ { ENABLE UNWIND => { NULL }; fullFName _ NIL; attachedTo _ NIL; uniqueID _ PFS.nullUniqueID; bytes _ 0; mutability _ immutable; fileType _ PFS.tUnspecified; }; CallProtected[mnt, GetInfoInner]; }; Init: PROC ~ { PFSClass.Register[xnsFlavor, GetHandle]; }; Init[]; }.