kjuulh/dagger
Archived
1
0
Fork 0
Code Issues 1 Pull Requests 1 Projects Releases Wiki Activity

logger: fix concurrency issue

Browse Source 
Signed-off-by: Andrea Luzzardi <aluzzardi@gmail.com>
This commit is contained in:
Andrea Luzzardi 2021-04-08 16:31:37 -07:00
parent b4c530653c
commit 10e676923c
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cmd/dagger/logger/console.go
View File

@ -7,6 +7,7 @@ import (
"hash/adler32" "hash/adler32"
"io" "io"
"strings" "strings"
"sync"
"time" "time"
"github.com/mitchellh/colorstring" "github.com/mitchellh/colorstring"
@ -21,6 +22,7 @@ var colorize = colorstring.Colorize{
type Console struct { type Console struct {
Out io.Writer Out io.Writer
maxLength int maxLength int
l sync.Mutex
} }
func (c *Console) Write(p []byte) (n int, err error) { func (c *Console) Write(p []byte) (n int, err error) {
@ -31,9 +33,12 @@ func (c *Console) Write(p []byte) (n int, err error) {
} }
source := c.parseSource(event) source := c.parseSource(event)
c.l.Lock()
if len(source) > c.maxLength { if len(source) > c.maxLength {
c.maxLength = len(source) c.maxLength = len(source)
} }
c.l.Unlock()
return fmt.Fprintln(c.Out, return fmt.Fprintln(c.Out,
colorize.Color(fmt.Sprintf("%s %s %s%s%s", colorize.Color(fmt.Sprintf("%s %s %s%s%s",