Use SIGWINCH to update terminal size

Instead of reading the terminal size on every status update, register
for SIGWINCH to read and store the size when it changes.

Test: status_test.go
Change-Id: I555ad21a31a2c924ab0ca681e0c8f00df42a370a
This commit is contained in:
Colin Cross 2019-06-11 23:01:36 -07:00
parent 00bdfd8476
commit 49036be407
2 changed files with 54 additions and 11 deletions

View File

@ -17,8 +17,11 @@ package terminal
import ( import (
"fmt" "fmt"
"io" "io"
"os"
"os/signal"
"strings" "strings"
"sync" "sync"
"syscall"
"android/soong/ui/status" "android/soong/ui/status"
) )
@ -30,18 +33,29 @@ type smartStatusOutput struct {
lock sync.Mutex lock sync.Mutex
haveBlankLine bool haveBlankLine bool
termWidth int
sigwinch chan os.Signal
} }
// NewSmartStatusOutput returns a StatusOutput that represents the // NewSmartStatusOutput returns a StatusOutput that represents the
// current build status similarly to Ninja's built-in terminal // current build status similarly to Ninja's built-in terminal
// output. // output.
func NewSmartStatusOutput(w io.Writer, formatter formatter) status.StatusOutput { func NewSmartStatusOutput(w io.Writer, formatter formatter) status.StatusOutput {
return &smartStatusOutput{ s := &smartStatusOutput{
writer: w, writer: w,
formatter: formatter, formatter: formatter,
haveBlankLine: true, haveBlankLine: true,
sigwinch: make(chan os.Signal),
} }
s.updateTermSize()
s.startSigwinch()
return s
} }
func (s *smartStatusOutput) Message(level status.MsgLevel, message string) { func (s *smartStatusOutput) Message(level status.MsgLevel, message string) {
@ -101,6 +115,8 @@ func (s *smartStatusOutput) Flush() {
s.lock.Lock() s.lock.Lock()
defer s.lock.Unlock() defer s.lock.Unlock()
s.stopSigwinch()
s.requestLine() s.requestLine()
} }
@ -137,16 +153,8 @@ func (s *smartStatusOutput) statusLine(str string) {
// Limit line width to the terminal width, otherwise we'll wrap onto // Limit line width to the terminal width, otherwise we'll wrap onto
// another line and we won't delete the previous line. // another line and we won't delete the previous line.
// if s.termWidth > 0 {
// Run this on every line in case the window has been resized while str = s.elide(str)
// we're printing. This could be optimized to only re-run when we get
// SIGWINCH if it ever becomes too time consuming.
if max, ok := termWidth(s.writer); ok {
if len(str) > max {
// TODO: Just do a max. Ninja elides the middle, but that's
// more complicated and these lines aren't that important.
str = str[:max]
}
} }
// Move to the beginning on the line, turn on bold, print the output, // Move to the beginning on the line, turn on bold, print the output,
@ -156,3 +164,35 @@ func (s *smartStatusOutput) statusLine(str string) {
fmt.Fprint(s.writer, start, str, end) fmt.Fprint(s.writer, start, str, end)
s.haveBlankLine = false s.haveBlankLine = false
} }
func (s *smartStatusOutput) elide(str string) string {
if len(str) > s.termWidth {
// TODO: Just do a max. Ninja elides the middle, but that's
// more complicated and these lines aren't that important.
str = str[:s.termWidth]
}
return str
}
func (s *smartStatusOutput) startSigwinch() {
signal.Notify(s.sigwinch, syscall.SIGWINCH)
go func() {
for _ = range s.sigwinch {
s.lock.Lock()
s.updateTermSize()
s.lock.Unlock()
}
}()
}
func (s *smartStatusOutput) stopSigwinch() {
signal.Stop(s.sigwinch)
close(s.sigwinch)
}
func (s *smartStatusOutput) updateTermSize() {
if w, ok := termWidth(s.writer); ok {
s.termWidth = w
}
}

View File

@ -17,6 +17,7 @@ package terminal
import ( import (
"bytes" "bytes"
"fmt" "fmt"
"syscall"
"testing" "testing"
"android/soong/ui/status" "android/soong/ui/status"
@ -260,6 +261,8 @@ func TestSmartStatusOutputWidthChange(t *testing.T) {
runner.startAction(action) runner.startAction(action)
smart.termWidth = 30 smart.termWidth = 30
// Fake a SIGWINCH
stat.(*smartStatusOutput).sigwinch <- syscall.SIGWINCH
runner.finishAction(result) runner.finishAction(result)
stat.Flush() stat.Flush()