run.go

   1 /*
   2 goredo -- djb's redo implementation on pure Go
   3 Copyright (C) 2020-2022 Sergey Matveev <stargrave@stargrave.org>
   4
   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.
   8
   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.
  13
  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/>.
  16 */
  17
  18 // Targets runner
  19
  20 package main
  21
  22 import (
  23         "bufio"
  24         "crypto/rand"
  25         "encoding/hex"
  26         "errors"
  27         "flag"
  28         "fmt"
  29         "io"
  30         "log"
  31         "os"
  32         "os/exec"
  33         "path"
  34         "path/filepath"
  35         "strconv"
  36         "strings"
  37         "sync"
  38         "syscall"
  39         "time"
  40
  41         "go.cypherpunks.ru/recfile"
  42         "go.cypherpunks.ru/tai64n/v2"
  43         "golang.org/x/sys/unix"
  44 )
  45
  46 const (
  47         EnvDepFd        = "REDO_DEP_FD"
  48         EnvDirPrefix    = "REDO_DIRPREFIX"
  49         EnvDepCwd       = "REDO_DEP_CWD"
  50         EnvBuildUUID    = "REDO_BUILD_UUID"
  51         EnvStderrPrefix = "REDO_STDERR_PREFIX"
  52         EnvTrace        = "REDO_TRACE"
  53         EnvStderrKeep   = "REDO_LOGS"
  54         EnvStderrSilent = "REDO_SILENT"
  55         EnvNoSync       = "REDO_NO_SYNC"
  56         EnvStopIfMod    = "REDO_STOP_IF_MODIFIED"
  57
  58         RedoDir      = ".redo"
  59         LockSuffix   = ".lock"
  60         DepSuffix    = ".rec"
  61         TmpPrefix    = ".redo."
  62         LogSuffix    = ".log"
  63         LogRecSuffix = ".log-rec"
  64 )
  65
  66 var (
  67         NoSync       = false
  68         StderrKeep   = false
  69         StderrSilent = false
  70         StderrPrefix string
  71         StopIfMod    = false
  72         Jobs         sync.WaitGroup
  73
  74         flagTrace          *bool
  75         flagTraceAll       *bool
  76         flagStderrKeep     *bool
  77         flagStderrSilent   *bool
  78         flagForcedIfchange *bool
  79
  80         TracedAll bool
  81
  82         RunningProcs  = map[int]*os.Process{}
  83         RunningProcsM sync.Mutex
  84
  85         Err1WasTouched = errors.New("$1 was explicitly touched")
  86 )
  87
  88 func init() {
  89         cmdName := CmdName()
  90         if !(cmdName == CmdNameRedo || cmdName == CmdNameRedoIfchange) {
  91                 return
  92         }
  93         flagTrace = flag.Bool("x", false, "trace (sh -x) current targets")
  94         flagTraceAll = flag.Bool("xx", false,
  95                 fmt.Sprintf("trace (sh -x) all targets (%s=1)", EnvTrace))
  96         flagStderrKeep = flag.Bool("k", false,
  97                 fmt.Sprintf("keep job's stderr (%s=1)", EnvStderrKeep))
  98         flagStderrSilent = flag.Bool("s", false,
  99                 fmt.Sprintf("silent, do not print job's stderr (%s=1)", EnvStderrSilent))
 100         flagForcedIfchange = flag.Bool("f", false, "forced redo-ifchange")
 101 }
 102
 103 type RunError struct {
 104         Tgt      string
 105         DoFile   string
 106         Started  *time.Time
 107         Finished *time.Time
 108         Err      error
 109 }
 110
 111 func (e *RunError) Name() string {
 112         var name string
 113         if e.DoFile == "" {
 114                 name = e.Tgt
 115         } else {
 116                 name = fmt.Sprintf("%s (%s)", e.Tgt, e.DoFile)
 117         }
 118         if e.Finished == nil {
 119                 return name
 120         }
 121         return fmt.Sprintf("%s (%.3fs)", name, e.Finished.Sub(*e.Started).Seconds())
 122 }
 123
 124 func (e RunError) Error() string {
 125         return fmt.Sprintf("%s: %s", e.Name(), e.Err)
 126 }
 127
 128 func mkdirs(pth string) error {
 129         if _, err := os.Stat(pth); err == nil {
 130                 return nil
 131         }
 132         return os.MkdirAll(pth, os.FileMode(0777))
 133 }
 134
 135 func isModified(cwd, redoDir, tgt string) (bool, *Inode, string, error) {
 136         fdDep, err := os.Open(path.Join(redoDir, tgt+DepSuffix))
 137         if err != nil {
 138                 if os.IsNotExist(err) {
 139                         return false, nil, "", nil
 140                 }
 141                 return false, nil, "", err
 142         }
 143         defer fdDep.Close()
 144         r := recfile.NewReader(fdDep)
 145         var modified bool
 146         var ourInode *Inode
 147         var hshPrev string
 148         for {
 149                 m, err := r.NextMap()
 150                 if err != nil {
 151                         if errors.Is(err, io.EOF) {
 152                                 break
 153                         }
 154                         return false, nil, "", err
 155                 }
 156                 if m["Type"] != DepTypeIfchange || m["Target"] != tgt {
 157                         continue
 158                 }
 159                 fd, err := os.Open(path.Join(cwd, tgt))
 160                 if err != nil {
 161                         if os.IsNotExist(err) {
 162                                 return false, nil, "", nil
 163                         }
 164                         return false, nil, "", err
 165                 }
 166                 ourInode, err = inodeFromFile(fd)
 167                 fd.Close()
 168                 if err != nil {
 169                         return false, nil, "", err
 170                 }
 171                 theirInode, err := inodeFromRec(m)
 172                 if err != nil {
 173                         return false, nil, "", err
 174                 }
 175                 hshPrev = m["Hash"]
 176                 modified = !ourInode.Equals(theirInode)
 177                 break
 178         }
 179         return modified, ourInode, hshPrev, nil
 180 }
 181
 182 func syncDir(dir string) error {
 183         fd, err := os.Open(dir)
 184         if err != nil {
 185                 return err
 186         }
 187         err = fd.Sync()
 188         fd.Close()
 189         return err
 190 }
 191
 192 func runScript(tgtOrig string, errs chan error, traced bool) error {
 193         cwd, tgt := cwdAndTgt(tgtOrig)
 194         redoDir := path.Join(cwd, RedoDir)
 195         if err := mkdirs(redoDir); err != nil {
 196                 return TgtError{tgtOrig, err}
 197         }
 198
 199         shCtx := fmt.Sprintf("sh: %s: cwd:%s", tgtOrig, cwd)
 200         jsToken := jsAcquire(shCtx)
 201         jsNeedsRelease := true
 202         defer func() {
 203                 if jsNeedsRelease {
 204                         jsRelease(shCtx, jsToken)
 205                 }
 206         }()
 207
 208         // Acquire lock
 209         fdLock, err := os.OpenFile(
 210                 path.Join(redoDir, tgt+LockSuffix),
 211                 os.O_WRONLY|os.O_TRUNC|os.O_CREATE,
 212                 os.FileMode(0666),
 213         )
 214         if err != nil {
 215                 return TgtError{tgtOrig, err}
 216         }
 217         flock := unix.Flock_t{
 218                 Type:   unix.F_WRLCK,
 219                 Whence: io.SeekStart,
 220         }
 221         lockRelease := func() {
 222                 tracef(CLock, "LOCK_UN: %s", fdLock.Name())
 223                 flock.Type = unix.F_UNLCK
 224                 if err := unix.FcntlFlock(fdLock.Fd(), unix.F_SETLK, &flock); err != nil {
 225                         log.Fatalln(err)
 226                 }
 227                 fdLock.Close()
 228         }
 229         tracef(CLock, "LOCK_NB: %s", fdLock.Name())
 230
 231         // Waiting for job completion, already taken by someone else
 232         if err = unix.FcntlFlock(fdLock.Fd(), unix.F_SETLK, &flock); err != nil {
 233                 if uintptr(err.(syscall.Errno)) != uintptr(unix.EAGAIN) {
 234                         fdLock.Close()
 235                         return TgtError{tgtOrig, err}
 236                 }
 237                 Jobs.Add(1)
 238                 if err = unix.FcntlFlock(fdLock.Fd(), unix.F_GETLK, &flock); err != nil {
 239                         log.Fatalln(err)
 240                 }
 241                 tracef(CDebug, "waiting: %s (pid=%d)", tgtOrig, flock.Pid)
 242                 if FdStatus != nil {
 243                         if _, err = FdStatus.Write([]byte{StatusWait}); err != nil {
 244                                 log.Fatalln(err)
 245                         }
 246                 }
 247                 go func() {
 248                         defer Jobs.Done()
 249                         tracef(CLock, "LOCK_EX: %s", fdLock.Name())
 250                         if err := unix.FcntlFlock(fdLock.Fd(), unix.F_SETLKW, &flock); err != nil {
 251                                 log.Fatalln(err)
 252                         }
 253                         lockRelease()
 254                         tracef(CDebug, "waiting done: %s", tgtOrig)
 255                         if FdStatus != nil {
 256                                 if _, err = FdStatus.Write([]byte{StatusWaited}); err != nil {
 257                                         log.Fatalln(err)
 258                                 }
 259                         }
 260                         var depInfo *DepInfo
 261                         fdDep, err := os.Open(path.Join(redoDir, tgt+DepSuffix))
 262                         if err != nil {
 263                                 if os.IsNotExist(err) {
 264                                         err = errors.New("was not built: no .rec")
 265                                 }
 266                                 goto Finish
 267                         }
 268                         defer fdDep.Close()
 269                         depInfo, err = depRead(fdDep)
 270                         if err != nil {
 271                                 goto Finish
 272                         }
 273                         if depInfo.build != BuildUUID {
 274                                 err = errors.New("was not built: build differs")
 275                         }
 276                 Finish:
 277                         if err != nil {
 278                                 err = TgtError{tgtOrig, err}
 279                                 fdLock.Close()
 280                         }
 281                         errs <- err
 282                 }()
 283                 return nil
 284         }
 285
 286         // Check if target is not modified externally
 287         modified, inodePrev, hshPrev, err := isModified(cwd, redoDir, tgt)
 288         if err != nil {
 289                 lockRelease()
 290                 return TgtError{tgtOrig, err}
 291         }
 292         if modified {
 293                 lockRelease()
 294                 if StopIfMod {
 295                         return fmt.Errorf("%s externally modified", tgtOrig)
 296                 }
 297                 tracef(CWarn, "%s externally modified: not redoing", tgtOrig)
 298                 go func() {
 299                         errs <- nil
 300                 }()
 301                 return nil
 302         }
 303
 304         // Start preparing .rec
 305         fdDep, err := tempfile(redoDir, tgt+DepSuffix)
 306         if err != nil {
 307                 lockRelease()
 308                 return TgtError{tgtOrig, err}
 309         }
 310         fdDepPath := fdDep.Name()
 311         cleanup := func() {
 312                 lockRelease()
 313                 fdDep.Close()
 314                 os.Remove(fdDep.Name())
 315         }
 316         if _, err = recfile.NewWriter(fdDep).WriteFields(
 317                 recfile.Field{Name: "Build", Value: BuildUUID},
 318         ); err != nil {
 319                 cleanup()
 320                 return TgtError{tgtOrig, err}
 321         }
 322
 323         // Find .do
 324         doFile, upLevels, err := findDo(fdDep, cwd, tgt)
 325         if err != nil {
 326                 cleanup()
 327                 return TgtError{tgtOrig, err}
 328         }
 329         if doFile == "" {
 330                 cleanup()
 331                 return TgtError{tgtOrig, errors.New("no .do found")}
 332         }
 333
 334         // Determine basename and DIRPREFIX
 335         doFileRelPath := doFile
 336         ents := strings.Split(cwd, "/")
 337         ents = ents[len(ents)-upLevels:]
 338         dirPrefix := path.Join(ents...)
 339         cwdOrig := cwd
 340         for i := 0; i < upLevels; i++ {
 341                 cwd = path.Join(cwd, "..")
 342                 doFileRelPath = path.Join("..", doFileRelPath)
 343         }
 344         cwd = path.Clean(cwd)
 345         doFilePath := path.Join(cwd, doFile)
 346         basename := tgt
 347         runErr := RunError{Tgt: tgtOrig}
 348         if strings.HasPrefix(doFile, "default.") {
 349                 basename = tgt[:len(tgt)-(len(doFile)-len("default.")-len(".do"))-1]
 350                 runErr.DoFile = doFileRelPath
 351         }
 352
 353         if err = depWrite(fdDep, cwdOrig, doFileRelPath, ""); err != nil {
 354                 cleanup()
 355                 return TgtError{tgtOrig, err}
 356         }
 357         fdDep.Close()
 358         tracef(CWait, "%s", runErr.Name())
 359
 360         // Prepare command line
 361         var cmdName string
 362         var args []string
 363         if err = unix.Access(doFilePath, unix.X_OK); err == nil {
 364                 cmdName = doFilePath
 365                 args = make([]string, 0, 3)
 366         } else {
 367                 cmdName = "/bin/sh"
 368                 if traced || TracedAll {
 369                         args = append(args, "-ex")
 370                 } else {
 371                         args = append(args, "-e")
 372                 }
 373                 args = append(args, doFile)
 374         }
 375
 376         // Temporary file for stdout
 377         fdStdout, err := tempfile(cwdOrig, tgt)
 378         if err != nil {
 379                 cleanup()
 380                 return TgtError{tgtOrig, err}
 381         }
 382         stdoutPath := fdStdout.Name()
 383         fdStdout.Close()
 384         tmpPath := stdoutPath + ".3" // and for $3
 385         tmpPathRel, err := filepath.Rel(cwd, tmpPath)
 386         if err != nil {
 387                 panic(err)
 388         }
 389         args = append(
 390                 args,
 391                 path.Join(dirPrefix, tgt),
 392                 path.Join(dirPrefix, basename),
 393                 tmpPathRel,
 394         )
 395         shCtx = fmt.Sprintf(
 396                 "sh: %s: %s %s cwd:%s dirprefix:%s",
 397                 tgtOrig, cmdName, args, cwd, dirPrefix,
 398         )
 399
 400         cmd := exec.Command(cmdName, args...)
 401         cmd.Dir = cwd
 402         // cmd.Stdin reads from /dev/null by default
 403         cmd.Env = append(os.Environ(), fmt.Sprintf("%s=%d", EnvLevel, Level+1))
 404         cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%s", EnvDirPrefix, dirPrefix))
 405         cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%s", EnvBuildUUID, BuildUUID))
 406
 407         childStderrPrefixRaw := make([]byte, 8)
 408         if _, err = io.ReadFull(rand.Reader, childStderrPrefixRaw); err != nil {
 409                 panic(err)
 410         }
 411         childStderrPrefix := hex.EncodeToString(childStderrPrefixRaw)
 412         cmd.Env = append(cmd.Env, fmt.Sprintf(
 413                 "%s=%s", EnvStderrPrefix, childStderrPrefix,
 414         ))
 415
 416         fdNum := 0
 417         cmd.ExtraFiles = append(cmd.ExtraFiles, FdOODTgts)
 418         cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%d", EnvOODTgtsFd, 3+fdNum))
 419         fdNum++
 420         cmd.ExtraFiles = append(cmd.ExtraFiles, FdOODTgtsLock)
 421         cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%d", EnvOODTgtsLockFd, 3+fdNum))
 422         fdNum++
 423
 424         if FdStatus == nil {
 425                 cmd.Env = append(cmd.Env, fmt.Sprintf("%s=NO", EnvStatusFd))
 426         } else {
 427                 cmd.ExtraFiles = append(cmd.ExtraFiles, FdStatus)
 428                 cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%d", EnvStatusFd, 3+fdNum))
 429                 fdNum++
 430         }
 431
 432         // Preparing stderr
 433         var fdStderr *os.File
 434         if StderrKeep {
 435                 fdStderr, err = os.OpenFile(
 436                         path.Join(redoDir, tgt+LogSuffix),
 437                         os.O_WRONLY|os.O_CREATE|os.O_TRUNC,
 438                         os.FileMode(0666),
 439                 )
 440                 if err != nil {
 441                         cleanup()
 442                         return TgtError{tgtOrig, err}
 443                 }
 444         }
 445         tracef(CDebug, "%s", shCtx)
 446
 447         jsNeedsRelease = false
 448         Jobs.Add(1)
 449         go func() {
 450                 if JSR == nil {
 451                         // infinite jobs
 452                         cmd.Env = append(cmd.Env, fmt.Sprintf("%s=NO", EnvJobs))
 453                 } else {
 454                         cmd.ExtraFiles = append(cmd.ExtraFiles, JSR)
 455                         cmd.ExtraFiles = append(cmd.ExtraFiles, JSW)
 456                         makeFlags := fmt.Sprintf(
 457                                 "%s %s%d,%d", MakeFlags, MakeJSArg, 3+fdNum+0, 3+fdNum+1,
 458                         )
 459                         makeFlags = strings.Trim(makeFlags, " ")
 460                         cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%s", MakeFlagsName, makeFlags))
 461                         fdNum += 2
 462                         cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%d", EnvJSToken, jsToken))
 463                 }
 464
 465                 if FdStatus != nil {
 466                         if _, err = FdStatus.Write([]byte{StatusRun}); err != nil {
 467                                 log.Fatalln(err)
 468                         }
 469                 }
 470
 471                 defer jsRelease(shCtx, jsToken)
 472
 473                 var finished time.Time
 474                 var exitErr *exec.ExitError
 475                 started := time.Now()
 476                 runErr.Started = &started
 477                 fdStdout, err = os.OpenFile(stdoutPath, os.O_RDWR, os.FileMode(0666))
 478                 if err != nil {
 479                         if fdStderr != nil {
 480                                 fdStderr.Close()
 481                         }
 482                         runErr.Err = err
 483                         errs <- runErr
 484                         return
 485                 }
 486                 cmd.Stdout = fdStdout
 487                 fdDep, err = os.OpenFile(fdDepPath, os.O_WRONLY|os.O_APPEND, os.FileMode(0666))
 488                 if err != nil {
 489                         if fdStderr != nil {
 490                                 fdStderr.Close()
 491                         }
 492                         fdStdout.Close()
 493                         runErr.Err = err
 494                         errs <- runErr
 495                         return
 496                 }
 497                 cmd.ExtraFiles = append(cmd.ExtraFiles, fdDep)
 498                 cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%d", EnvDepFd, 3+fdNum))
 499                 fdNum++
 500                 cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%s", EnvDepCwd, cwd))
 501
 502                 defer func() {
 503                         fdDep.Close()
 504                         fdStdout.Close()
 505                         if fdStderr != nil {
 506                                 fdStderr.Close()
 507                                 logRecPath := path.Join(redoDir, tgt+LogRecSuffix)
 508                                 if fdStderr, err = os.OpenFile(
 509                                         logRecPath,
 510                                         os.O_WRONLY|os.O_CREATE|os.O_TRUNC,
 511                                         os.FileMode(0666),
 512                                 ); err == nil {
 513                                         fields := []recfile.Field{
 514                                                 {Name: "Build", Value: BuildUUID},
 515                                                 {Name: "PPID", Value: strconv.Itoa(os.Getpid())},
 516                                                 {Name: "Cwd", Value: cwd},
 517                                         }
 518                                         if cmd.Process != nil {
 519                                                 fields = append(fields, recfile.Field{
 520                                                         Name: "PID", Value: strconv.Itoa(cmd.Process.Pid),
 521                                                 })
 522                                         }
 523                                         ts := new(tai64n.TAI64N)
 524                                         ts.FromTime(started)
 525                                         fields = append(fields,
 526                                                 recfile.Field{Name: "Started", Value: tai64n.Encode(ts[:])},
 527                                         )
 528                                         ts.FromTime(finished)
 529                                         fields = append(fields,
 530                                                 recfile.Field{Name: "Finished", Value: tai64n.Encode(ts[:])})
 531                                         fields = append(fields, recfile.Field{
 532                                                 Name:  "Duration",
 533                                                 Value: strconv.FormatInt(finished.Sub(started).Nanoseconds(), 10),
 534                                         })
 535                                         fields = append(fields, recfile.Field{Name: "Cmd", Value: cmdName})
 536                                         for _, arg := range args {
 537                                                 fields = append(fields, recfile.Field{Name: "Arg", Value: arg})
 538                                         }
 539                                         for _, env := range cmd.Env {
 540                                                 fields = append(fields, recfile.Field{Name: "Env", Value: env})
 541                                         }
 542                                         if exitErr != nil {
 543                                                 fields = append(fields, recfile.Field{
 544                                                         Name:  "ExitCode",
 545                                                         Value: strconv.Itoa(exitErr.ProcessState.ExitCode()),
 546                                                 })
 547                                         }
 548                                         w := bufio.NewWriter(fdStderr)
 549
 550                                         var depInfo *DepInfo
 551                                         fdDep, err := os.Open(fdDepPath)
 552                                         if err != nil {
 553                                                 goto Err
 554                                         }
 555                                         depInfo, err = depRead(fdDep)
 556                                         fdDep.Close()
 557                                         if err != nil {
 558                                                 goto Err
 559                                         }
 560                                         for _, dep := range depInfo.ifchanges {
 561                                                 fields = append(fields, recfile.Field{
 562                                                         Name:  "Ifchange",
 563                                                         Value: dep["Target"],
 564                                                 })
 565                                         }
 566                                         _, err = recfile.NewWriter(w).WriteFields(fields...)
 567                                         if err != nil {
 568                                                 goto Err
 569                                         }
 570                                         err = w.Flush()
 571                                 Err:
 572                                         if err != nil {
 573                                                 log.Println(err)
 574                                                 os.Remove(logRecPath)
 575                                         }
 576                                         fdStderr.Close()
 577                                 } else {
 578                                         log.Println("can not open", logRecPath, ":", err)
 579                                 }
 580                         }
 581                         lockRelease()
 582                         os.Remove(fdDep.Name())
 583                         os.Remove(fdStdout.Name())
 584                         os.Remove(tmpPath)
 585                         os.Remove(fdLock.Name())
 586                         if FdStatus != nil {
 587                                 if _, err = FdStatus.Write([]byte{StatusDone}); err != nil {
 588                                         log.Fatalln(err)
 589                                 }
 590                         }
 591                         Jobs.Done()
 592                 }()
 593                 stderr, err := cmd.StderrPipe()
 594                 if err != nil {
 595                         runErr.Err = err
 596                         errs <- runErr
 597                         return
 598                 }
 599                 started = time.Now()
 600                 err = cmd.Start()
 601                 if err != nil {
 602                         runErr.Err = err
 603                         errs <- runErr
 604                         return
 605                 }
 606                 RunningProcsM.Lock()
 607                 RunningProcs[cmd.Process.Pid] = cmd.Process
 608                 RunningProcsM.Unlock()
 609                 pid := fmt.Sprintf("[%d]", cmd.Process.Pid)
 610                 tracef(CDebug, "%s runs %s", tgtOrig, pid)
 611
 612                 stderrTerm := make(chan struct{})
 613                 go func() {
 614                         scanner := bufio.NewScanner(stderr)
 615                         var line string
 616                         ts := new(tai64n.TAI64N)
 617                         for scanner.Scan() {
 618                                 line = scanner.Text()
 619                                 if strings.HasPrefix(line, childStderrPrefix) {
 620                                         line = line[len(childStderrPrefix):]
 621                                         os.Stderr.WriteString(StderrPrefix + line + "\n")
 622                                         continue
 623                                 }
 624                                 if fdStderr != nil {
 625                                         ts.FromTime(time.Now())
 626                                         LogMutex.Lock()
 627                                         fmt.Fprintln(fdStderr, tai64n.Encode(ts[:]), line)
 628                                         LogMutex.Unlock()
 629                                 }
 630                                 if StderrSilent {
 631                                         continue
 632                                 }
 633                                 if MyPid == 0 {
 634                                         tracef(CNone, "%s", line)
 635                                 } else {
 636                                         tracef(CNone, "%s %s", pid, line)
 637                                 }
 638                         }
 639                         close(stderrTerm)
 640                 }()
 641
 642                 // Wait for job completion
 643                 <-stderrTerm
 644                 err = cmd.Wait()
 645                 RunningProcsM.Lock()
 646                 delete(RunningProcs, cmd.Process.Pid)
 647                 RunningProcsM.Unlock()
 648                 finished = time.Now()
 649                 runErr.Finished = &finished
 650                 if err != nil {
 651                         exitErr = err.(*exec.ExitError)
 652                         runErr.Err = err
 653                         errs <- runErr
 654                         return
 655                 }
 656
 657                 // Was $1 touched?
 658                 if fd, err := os.Open(path.Join(cwdOrig, tgt)); err == nil {
 659                         if inodePrev == nil {
 660                                 fd.Close()
 661                                 runErr.Err = Err1WasTouched
 662                                 errs <- runErr
 663                                 return
 664                         }
 665                         inode, err := inodeFromFile(fd)
 666                         fd.Close()
 667                         if err != nil {
 668                                 runErr.Err = err
 669                                 errs <- runErr
 670                                 return
 671                         }
 672                         if !inode.Equals(inodePrev) {
 673                                 runErr.Err = Err1WasTouched
 674                                 errs <- runErr
 675                                 return
 676                         }
 677                 }
 678
 679                 if inodePrev != nil {
 680                         if fd, err := os.Open(path.Join(cwdOrig, tgt)); err == nil {
 681                                 inode, err := inodeFromFile(fd)
 682                                 fd.Close()
 683                                 if err == nil && !inode.Equals(inodePrev) {
 684                                         runErr.Err = Err1WasTouched
 685                                         errs <- runErr
 686                                         return
 687                                 }
 688                         }
 689                 }
 690
 691                 // Does it produce both stdout and tmp?
 692                 fiStdout, err := os.Stat(fdStdout.Name())
 693                 if err != nil {
 694                         runErr.Err = err
 695                         errs <- runErr
 696                         return
 697                 }
 698                 tmpExists := false
 699                 _, err = os.Stat(tmpPath)
 700                 if err == nil {
 701                         if fiStdout.Size() > 0 {
 702                                 runErr.Err = errors.New("created both tmp and stdout")
 703                                 errs <- runErr
 704                                 return
 705                         }
 706                         tmpExists = true
 707                 } else if !os.IsNotExist(err) {
 708                         runErr.Err = err
 709                         errs <- runErr
 710                         return
 711                 }
 712
 713                 // Determine what file we must process at last
 714                 var fd *os.File
 715                 if tmpExists {
 716                         fd, err = os.Open(tmpPath)
 717                         if err != nil {
 718                                 goto Finish
 719                         }
 720                         defer fd.Close()
 721                 } else if fiStdout.Size() > 0 {
 722                         fd = fdStdout
 723                 }
 724
 725                 // Do we need to ifcreate it, or ifchange with renaming?
 726                 if fd == nil {
 727                         os.Remove(path.Join(cwdOrig, tgt))
 728                         err = ifcreate(fdDep, tgt)
 729                         if err != nil {
 730                                 goto Finish
 731                         }
 732                 } else {
 733                         var hsh string
 734                         if hshPrev != "" {
 735                                 _, err = fd.Seek(0, io.SeekStart)
 736                                 if err != nil {
 737                                         goto Finish
 738                                 }
 739                                 hsh, err = fileHash(fd)
 740                                 if err != nil {
 741                                         goto Finish
 742                                 }
 743                                 if hsh == hshPrev {
 744                                         tracef(CDebug, "%s has same hash, not renaming", tgtOrig)
 745                                         err = os.Remove(fd.Name())
 746                                         if err != nil {
 747                                                 goto Finish
 748                                         }
 749                                         err = os.Chtimes(path.Join(cwdOrig, tgt), finished, finished)
 750                                         if err != nil {
 751                                                 goto Finish
 752                                         }
 753                                         if !NoSync {
 754                                                 err = syncDir(cwdOrig)
 755                                                 if err != nil {
 756                                                         goto Finish
 757                                                 }
 758                                         }
 759                                         err = depWrite(fdDep, cwdOrig, tgt, hshPrev)
 760                                         if err != nil {
 761                                                 goto Finish
 762                                         }
 763                                         goto RecCommit
 764                                 }
 765                         }
 766                         if !NoSync {
 767                                 err = fd.Sync()
 768                                 if err != nil {
 769                                         goto Finish
 770                                 }
 771                         }
 772                         err = os.Rename(fd.Name(), path.Join(cwdOrig, tgt))
 773                         if err != nil {
 774                                 goto Finish
 775                         }
 776                         if !NoSync {
 777                                 err = syncDir(cwdOrig)
 778                                 if err != nil {
 779                                         goto Finish
 780                                 }
 781                         }
 782                         err = depWrite(fdDep, cwdOrig, tgt, hsh)
 783                         if err != nil {
 784                                 goto Finish
 785                         }
 786                 }
 787
 788         RecCommit:
 789                 // Commit .rec
 790                 if !NoSync {
 791                         err = fdDep.Sync()
 792                         if err != nil {
 793                                 goto Finish
 794                         }
 795                 }
 796                 fdDepPath = path.Join(redoDir, tgt+DepSuffix)
 797                 err = os.Rename(fdDep.Name(), fdDepPath)
 798                 if err != nil {
 799                         goto Finish
 800                 }
 801                 if !NoSync {
 802                         err = syncDir(redoDir)
 803                         if err != nil {
 804                                 goto Finish
 805                         }
 806                 }
 807
 808                 // Post-commit .rec sanitizing
 809                 fdDep.Close()
 810                 if fdDepR, err := os.Open(fdDepPath); err == nil {
 811                         depInfo, err := depRead(fdDepR)
 812                         fdDepR.Close()
 813                         if err != nil {
 814                                 goto Finish
 815                         }
 816                         ifchangeSeen := make(map[string]struct{}, len(depInfo.ifchanges))
 817                         for _, dep := range depInfo.ifchanges {
 818                                 ifchangeSeen[dep["Target"]] = struct{}{}
 819                         }
 820                         for _, dep := range depInfo.ifcreates {
 821                                 if _, exists := ifchangeSeen[dep]; exists {
 822                                         tracef(CWarn, "simultaneous ifcreate and ifchange records: %s", tgt)
 823                                 }
 824                         }
 825                 }
 826
 827         Finish:
 828                 runErr.Err = err
 829                 errs <- runErr
 830         }()
 831         return nil
 832 }
 833
 834 func isOkRun(err error) bool {
 835         if err == nil {
 836                 return true
 837         }
 838         var runErr RunError
 839         if errors.As(err, &runErr) && runErr.Err == nil {
 840                 tracef(CRedo, "%s", runErr.Name())
 841                 return true
 842         }
 843         tracef(CErr, "%s", err)
 844         return false
 845 }