2 goredo -- djb's redo implementation on pure Go
3 Copyright (C) 2020-2023 Sergey Matveev <stargrave@stargrave.org>
5 This program is free software: you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published by
7 the Free Software Foundation, version 3 of the License.
9 This program is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 GNU General Public License for more details.
14 You should have received a copy of the GNU General Public License
15 along with this program. If not, see <http://www.gnu.org/licenses/>.
29 deps map[string]map[string]struct{},
32 cwd, tgt := cwdAndTgt(path.Join(cwd, tgtOrig))
33 depPath := path.Join(cwd, RedoDir, tgt+DepSuffix)
34 fdDep, err := os.Open(depPath)
38 depInfo, err := depRead(fdDep)
45 tgtRel := cwdMustRel(cwd, tgt)
47 if depInfo.build == BuildUUID {
49 CDebug, "ood: %s%s always, but already build",
50 strings.Repeat(". ", level), tgtOrig,
54 tracef(CDebug, "ood: %s%s always", strings.Repeat(". ", level), tgtOrig)
55 alwayses = append(alwayses, tgtRel)
59 for _, m := range depInfo.ifchanges {
67 if !includeSrc && isSrc(cwd, dep) {
71 depRel := cwdMustRel(cwd, dep)
72 if m, ok := deps[depRel]; ok {
73 m[tgtRel] = struct{}{}
75 m = map[string]struct{}{}
76 m[tgtRel] = struct{}{}
81 collectDeps(cwd, dep, level+1, deps, includeSrc)...,
88 func buildDependants(tgts []string) map[string]struct{} {
90 tracef(CDebug, "collecting deps")
91 seen := map[string]struct{}{}
92 deps := map[string]map[string]struct{}{}
93 for _, tgtInitial := range tgts {
94 for _, tgt := range collectDeps(Cwd, tgtInitial, 0, deps, false) {
95 if tgt != tgtInitial {
96 seen[tgt] = struct{}{}
109 tracef(CDebug, "building %d alwayses: %v", len(seen), seen)
110 errs := make(chan error, len(seen))
111 for tgt := range seen {
112 if err := runScript(tgt, errs, false); err != nil {
113 tracef(CErr, "always run error: %s, skipping dependants", err)
118 for i := 0; i < len(seen); i++ {
119 ok = isOkRun(<-errs) && ok
124 tracef(CDebug, "alwayses failed, skipping dependants")
128 queueSrc := make([]string, 0, len(seen))
129 for tgt := range seen {
130 queueSrc = append(queueSrc, tgt)
132 if len(queueSrc) == 0 {
137 tracef(CDebug, "checking %d dependant targets: %v", len(queueSrc), queueSrc)
138 queue := map[string]struct{}{}
139 for _, tgt := range queueSrc {
140 for dep := range deps[tgt] {
141 queue[dep] = struct{}{}
145 tracef(CDebug, "building %d dependant targets: %v", len(queue), queue)
146 errs = make(chan error, len(queue))
148 queueSrc = []string{}
149 for tgt := range queue {
150 ood, err := isOODWithTrace(Cwd, tgt, 0, seen)
152 tracef(CErr, "dependant error: %s, skipping dependants", err)
158 if err := runScript(tgt, errs, false); err != nil {
159 tracef(CErr, "dependant error: %s, skipping dependants", err)
162 queueSrc = append(queueSrc, tgt)
163 seen[tgt] = struct{}{}
166 for i := 0; i < jobs; i++ {
167 ok = isOkRun(<-errs) && ok
170 tracef(CDebug, "dependants failed, skipping them")
182 func ifchange(tgts []string, forced, traced bool) (bool, error) {
183 // only unique elements
184 m := make(map[string]struct{})
185 for _, t := range tgts {
190 tgts = append(tgts, t)
196 defer jsAcquire("ifchange exiting")
199 seen := buildDependants(tgts)
204 tracef(CDebug, "building %d targets: %v", len(tgts), tgts)
206 errs := make(chan error, len(tgts))
209 for _, tgt := range tgts {
210 if _, ok := seen[tgt]; ok {
211 tracef(CDebug, "%s was already build as a dependant", tgt)
216 ood, err = isOODWithTrace(Cwd, tgt, 0, seen)
225 tracef(CDebug, "%s is source, not redoing", tgt)
228 if err = runScript(tgt, errs, traced); err != nil {
234 for ; jobs > 0; jobs-- {
235 ok = isOkRun(<-errs) && ok