MODULE; IMPORT Attic, CVProto, FileAttr, FileStatus, FileUpdater, Logger, OSError, Pathname, Rd, Receive, SupFileRec, SupMisc, Thread, TokScan, Wr; REVEAL T = Public BRANDED OBJECT attr: FileAttr.T; isFixup: BOOLEAN; OVERRIDES init := Init; update := Update; END; PROCEDURE RegularCreator Init (self: T; attr: FileAttr.T; isFixup: BOOLEAN): T = BEGIN self.attr := attr; self.isFixup := isFixup; RETURN self; END Init; PROCEDUREUpdate (self: T; sfr: SupFileRec.T; name: Pathname.T; toAttic: BOOLEAN; <*UNUSED*> proto: CVProto.T; trace: Logger.T; protoRd: Rd.T; wr: Wr.T; VAR status: FileUpdater.Status) RAISES {FileUpdater.FixupNeeded, Rd.EndOfFile, Rd.Failure, Thread.Alerted, TokScan.Error, Wr.Failure} = VAR srcPath := SupMisc.CatPath(sfr.clientPrefix, name); origPath := srcPath; traceKind: TEXT; wantSum: TEXT; defaultAttr: FileAttr.T := NIL; BEGIN TRY defaultAttr := Attic.FileAttrFromPathname(srcPath, follow := FALSE); EXCEPT OSError.E => (* Ignore *) END; IF self.isFixup THEN status.updateType := FileUpdater.UpdateType.Fixup; traceKind := "Fixup"; ELSIF defaultAttr # NIL THEN status.updateType := FileUpdater.UpdateType.Replace; traceKind := "Replace"; ELSE status.updateType := FileUpdater.UpdateType.Create; traceKind := "Create"; END; IF toAttic THEN Logger.Notice(trace, " " & traceKind & " " & name & " -> Attic"); ELSE Logger.Notice(trace, " " & traceKind & " " & name); END; IF defaultAttr # NIL THEN (* Default from the existing file. *) self.attr := FileAttr.Merge(self.attr, defaultAttr); ELSE (* Creating a new file. *) self.attr := FileAttr.Umask(self.attr, sfr.umask); self.attr := FileAttr.MergeDefault(self.attr); END; TRY wantSum := Receive.Counted(protoRd, wr, FileAttr.GetSize(self.attr), withChecksum := TRUE); EXCEPT Receive.Error(msg) => RAISE FileUpdater.FixupNeeded(msg); END; status.fs := NEW(FileStatus.T, name := name, clientAttr := self.attr, serverAttr := self.attr); IF toAttic THEN status.fs.type := FileStatus.Type.FileDead; ELSE status.fs.type := FileStatus.Type.FileLive; END; status.fromAttic := srcPath # origPath; status.modified := TRUE; status.wantSum := wantSum; END Update; BEGIN END RegularCreator.