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/>.
28 deps map[string]map[string]struct{},
30 seen map[string]struct{},
32 cwd, tgt := cwdAndTgt(path.Join(cwd, tgtOrig))
33 tgtFull := path.Join(cwd, tgt)
34 if _, ok := seen[tgtFull]; ok {
37 depPath := path.Join(cwd, RedoDir, tgt+DepSuffix)
38 depInfo, err := depRead(depPath)
42 // DepInfoCache[depPath] = depInfo
43 seen[tgtFull] = struct{}{}
46 tgtRel := cwdMustRel(cwd, tgt)
48 if depInfo.build == BuildUUID {
50 CDebug, "ood: %s%s always, but already build",
51 strings.Repeat(". ", level), tgtOrig,
55 tracef(CDebug, "ood: %s%s always", strings.Repeat(". ", level), tgtOrig)
56 alwayses = append(alwayses, tgtRel)
60 for _, dep := range depInfo.ifchanges {
64 if !includeSrc && isSrc(cwd, dep.tgt) {
68 depRel := cwdMustRel(cwd, dep.tgt)
69 if m, ok := deps[depRel]; ok {
70 m[tgtRel] = struct{}{}
72 m = map[string]struct{}{}
73 m[tgtRel] = struct{}{}
76 alwayses = append(alwayses,
77 collectDeps(cwd, dep.tgt, level+1, deps, includeSrc, seen)...)
83 func buildDependants(tgts []string) map[string]struct{} {
85 tracef(CDebug, "collecting deps")
86 seen := map[string]struct{}{}
87 deps := map[string]map[string]struct{}{}
88 collectDepsSeen := make(map[string]struct{})
89 for _, tgtInitial := range tgts {
90 for _, tgt := range collectDeps(Cwd, tgtInitial, 0, deps, false, collectDepsSeen) {
91 if tgt != tgtInitial {
92 seen[tgt] = struct{}{}
106 tracef(CDebug, "building %d alwayses: %v", len(seen), seen)
107 errs := make(chan error, len(seen))
109 okChecker := make(chan struct{})
111 for err := range errs {
112 ok = isOkRun(err) && ok
116 for tgt := range seen {
117 if err := runScript(tgt, errs, false, false); err != nil {
118 tracef(CErr, "always run error: %s, skipping dependants", err)
128 tracef(CDebug, "alwayses failed, skipping dependants")
132 queueSrc := make([]string, 0, len(seen))
133 for tgt := range seen {
134 queueSrc = append(queueSrc, tgt)
136 if len(queueSrc) == 0 {
141 tracef(CDebug, "checking %d dependant targets: %v", len(queueSrc), queueSrc)
142 queue := map[string]struct{}{}
143 for _, tgt := range queueSrc {
144 for dep := range deps[tgt] {
145 queue[dep] = struct{}{}
149 tracef(CDebug, "building %d dependant targets: %v", len(queue), queue)
150 errs = make(chan error, len(queue))
151 okChecker = make(chan struct{})
153 queueSrc = []string{}
155 for err := range errs {
156 ok = isOkRun(err) && ok
160 for tgt := range queue {
161 ood, err := isOODWithTrace(Cwd, tgt, 0, seen)
163 tracef(CErr, "dependant error: %s, skipping dependants", err)
169 if err := runScript(tgt, errs, false, false); err != nil {
170 tracef(CErr, "dependant error: %s, skipping dependants", err)
173 queueSrc = append(queueSrc, tgt)
174 seen[tgt] = struct{}{}
181 tracef(CDebug, "dependants failed, skipping them")
191 func ifchange(tgts []string, forced, traced bool) (bool, error) {
192 // only unique elements
193 m := make(map[string]struct{})
194 for _, t := range tgts {
199 tgts = append(tgts, t)
205 defer jsAcquire("ifchange exiting")
207 seen := buildDependants(tgts)
213 tracef(CDebug, "building %d targets: %v", len(tgts), tgts)
217 okChecker := make(chan struct{})
218 errs := make(chan error, len(tgts))
220 for err := range errs {
221 ok = isOkRun(err) && ok
225 for _, tgt := range tgts {
226 if _, ok := seen[tgt]; ok {
227 tracef(CDebug, "%s was already build as a dependant", tgt)
232 ood, err = isOODWithTrace(Cwd, tgt, 0, seen)
236 return false, ErrLine(err)
243 tracef(CDebug, "%s is source, not redoing", tgt)
246 if err = runScript(tgt, errs, forced, traced); err != nil {
249 return false, ErrLine(err)