Brought more of ozai over to get started.

master
Zed A. Shaw 3 weeks ago
parent 186b7eeda0
commit 02f0d904de
  1. 18
      .ttarpit.json
  2. 10
      main.go
  3. 6
      tools/cmd/tester/main.go

@ -4,5 +4,23 @@
"Command": "tester",
"Args": ["-count", "100", "-id", "1"]
}
},
"Processes": {
"tester2": {
"Command": "tester",
"Args": ["-count", "100", "-id", "2"]
}
},
"Processes": {
"tester3": {
"Command": "tester",
"Args": ["-count", "100", "-id", "3"]
}
},
"Processes": {
"tester4": {
"Command": "tester",
"Args": ["-count", "100", "-id", "4"]
}
}
}

@ -8,6 +8,7 @@ import (
"os"
"errors"
"lcthw.dev/go/ttarpit/config"
"sync"
)
func LaunchLogger(in io.Reader, out io.Writer, err error) {
@ -52,6 +53,8 @@ func LaunchProcess(proc *config.Process) {
func main() {
config.Load()
var wg sync.WaitGroup
fmt.Println("CONFIG:", config.Settings.ConfigPath)
fmt.Println("COMMANDs:", config.Settings.Processes)
@ -59,8 +62,11 @@ func main() {
fmt.Println("PROCESS:", name)
proc.Ready = make(chan string)
go LaunchProcess(&proc)
wg.Go(func() {
LaunchProcess(&proc)
})
}
fmt.Println("WAITING....")
wg.Wait()
}

@ -3,8 +3,10 @@ package main
import (
"fmt"
"time"
"os"
"flag"
"sync"
"math/rand"
)
func Worker(name string, count int, done chan<- int, stop <-chan int) {
@ -16,7 +18,11 @@ func Worker(name string, count int, done chan<- int, stop <-chan int) {
return
default:
time.Sleep(1 * time.Second)
if rand.Int() % 2 == 0 {
fmt.Println("TESTER #", name)
} else {
os.Stderr.Write([]byte(fmt.Sprintf("TESTER ERR # %s\n", name)))
}
}
}

Loading…
Cancel
Save