X-Git-Url: http://www.git.cypherpunks.ru/?p=goredo.git;a=blobdiff_plain;f=dep.go;h=bbd7310171fb5d43183e544425f5676d91fe381d;hp=0c5b6348740393340435a7c81a3d9c85b5274324;hb=fa0728d6bc790672982ba006961077371d2b552d;hpb=760f49298dd70c3b1e4ba75f9704444b4d94ed1d diff --git a/dep.go b/dep.go index 0c5b634..bbd7310 100644 --- a/dep.go +++ b/dep.go @@ -1,5 +1,5 @@ /* -goredo -- redo implementation on pure Go +goredo -- djb's redo implementation on pure Go Copyright (C) 2020-2021 Sergey Matveev This program is free software: you can redistribute it and/or modify @@ -23,14 +23,12 @@ import ( "bufio" "encoding/hex" "errors" - "fmt" "io" "os" "path" "path/filepath" "go.cypherpunks.ru/recfile" - "golang.org/x/sys/unix" "lukechampine.com/blake3" ) @@ -75,15 +73,6 @@ func stamp(fdDep, src *os.File) error { ) } -func fileCtime(fd *os.File) (string, error) { - var stat unix.Stat_t - if err := unix.Fstat(int(fd.Fd()), &stat); err != nil { - return "", err - } - sec, nsec := stat.Ctim.Unix() - return fmt.Sprintf("%d.%d", sec, nsec), nil -} - func fileHash(fd *os.File) (string, error) { h := blake3.New(32, nil) if _, err := io.Copy(h, bufio.NewReader(fd)); err != nil { @@ -106,7 +95,7 @@ func writeDep(fdDep *os.File, cwd, tgt string) error { if fi.IsDir() { return nil } - ts, err := fileCtime(fd) + inode, err := inodeFromFile(fd) if err != nil { return err } @@ -114,39 +103,44 @@ func writeDep(fdDep *os.File, cwd, tgt string) error { if err != nil { return err } - return recfileWrite( - fdDep, - recfile.Field{Name: "Type", Value: DepTypeIfchange}, - recfile.Field{Name: "Target", Value: tgt}, - recfile.Field{Name: "Ctime", Value: ts}, - recfile.Field{Name: "Hash", Value: hsh}, - ) + fields := []recfile.Field{ + {Name: "Type", Value: DepTypeIfchange}, + {Name: "Target", Value: tgt}, + {Name: "Hash", Value: hsh}, + } + fields = append(fields, inode.RecfileFields()...) + return recfileWrite(fdDep, fields...) } -func writeDeps(fdDep *os.File, tgts []string) error { +func writeDeps(fdDep *os.File, tgts []string) (err error) { if fdDep == nil { trace(CDebug, "no opened fdDep: %s", tgts) return nil } for _, tgt := range tgts { - if _, err := os.Stat(tgt); err == nil { - tgtAbs, err := filepath.Abs(tgt) - if err != nil { - panic(err) - } - tgtDir := path.Join(Cwd, DirPrefix) - tgtRel, err := filepath.Rel(tgtDir, tgtAbs) - if err != nil { - panic(err) - } - if err = writeDep(fdDep, tgtDir, tgtRel); err != nil { - return err - } + tgtAbs, err := filepath.Abs(tgt) + if err != nil { + panic(err) + } + tgtDir := path.Join(Cwd, DirPrefix) + tgtRel, err := filepath.Rel(tgtDir, tgtAbs) + if err != nil { + panic(err) + } + if _, errStat := os.Stat(tgt); errStat == nil { + err = writeDep(fdDep, tgtDir, tgtRel) } else { - trace(CDebug, "skipping dep record, can not stat: %s", tgt) + trace(CDebug, "ifchange: %s <- %s (unexisting)", fdDep.Name(), tgtRel) + fields := []recfile.Field{ + {Name: "Type", Value: DepTypeIfchange}, + {Name: "Target", Value: tgtRel}, + } + inodeDummy := Inode{} + fields = append(fields, inodeDummy.RecfileFields()...) + err = recfileWrite(fdDep, fields...) } } - return nil + return } type DepInfo struct { @@ -165,7 +159,7 @@ func depRead(fdDep *os.File) (*DepInfo, error) { } depInfo := DepInfo{} if b := m["Build"]; b == "" { - return nil, errors.New(".dep missing Build:") + return nil, errors.New(".rec missing Build:") } else { depInfo.build = b } @@ -183,7 +177,7 @@ func depRead(fdDep *os.File) (*DepInfo, error) { case DepTypeIfcreate: dep := m["Target"] if dep == "" { - return nil, errors.New("invalid format of .dep") + return nil, errors.New("invalid format of .rec") } depInfo.ifcreates = append(depInfo.ifcreates, dep) case DepTypeIfchange: @@ -192,11 +186,11 @@ func depRead(fdDep *os.File) (*DepInfo, error) { case DepTypeStamp: hsh := m["Hash"] if hsh == "" { - return nil, errors.New("invalid format of .dep") + return nil, errors.New("invalid format of .rec") } depInfo.stamp = hsh default: - return nil, errors.New("invalid format of .dep") + return nil, errors.New("invalid format of .rec") } } return &depInfo, nil