b82471ad6d
This adds a new status package that merges the running of "actions" (ninja calls them edges) of multiple tools into one view of the current state, and gives that to a number of different outputs. For inputs: Kati's output parser has been rewritten (and moved) to map onto the StartAction/FinishAction API. A byproduct of this is that the build servers should be able to extract errors from Kati better, since they look like the errors that Ninja used to write. Ninja is no longer directly connected to the terminal, but its output is read via the protobuf frontend API, so it's just another tool whose output becomes merged together. multiproduct_kati loses its custom status routines, and uses the common one instead. For outputs: The primary output is the ui/terminal.Status type, which along with ui/terminal.Writer now controls everything about the terminal output. Today, this doesn't really change any behaviors, but having all terminal output going through here allows a more complicated (multi-line / full window) status display in the future. The tracer acts as an output of the status package, tracing all the action start / finish events. This replaces reading the .ninja_log file, so it now properly handles multiple output files from a single action. A new rotated log file (out/error.log, or out/dist/logs/error.log) just contains a description of all of the errors that happened during the current build. Another new compressed and rotated log file (out/verbose.log.gz, or out/dist/logs/verbose.log.gz) contains the full verbose (showcommands) log of every execution run by the build. Since this is now written on every build, the showcommands argument is now ignored -- if you want to get the commands run, look at the log file after the build. Test: m Test: <built-in tests> Test: NINJA_ARGS="-t list" m Test: check the build.trace.gz Test: check the new log files Change-Id: If1d8994890d43ef68f65aa10ddd8e6e06dc7013a
101 lines
2.7 KiB
Go
101 lines
2.7 KiB
Go
// Copyright 2017 Google Inc. All rights reserved.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package terminal
|
|
|
|
import (
|
|
"bytes"
|
|
"io"
|
|
"os"
|
|
"syscall"
|
|
"unsafe"
|
|
)
|
|
|
|
func isTerminal(w io.Writer) bool {
|
|
if f, ok := w.(*os.File); ok {
|
|
var termios syscall.Termios
|
|
_, _, err := syscall.Syscall6(syscall.SYS_IOCTL, f.Fd(),
|
|
ioctlGetTermios, uintptr(unsafe.Pointer(&termios)),
|
|
0, 0, 0)
|
|
return err == 0
|
|
}
|
|
return false
|
|
}
|
|
|
|
func termWidth(w io.Writer) (int, bool) {
|
|
if f, ok := w.(*os.File); ok {
|
|
var winsize struct {
|
|
ws_row, ws_column uint16
|
|
ws_xpixel, ws_ypixel uint16
|
|
}
|
|
_, _, err := syscall.Syscall6(syscall.SYS_IOCTL, f.Fd(),
|
|
syscall.TIOCGWINSZ, uintptr(unsafe.Pointer(&winsize)),
|
|
0, 0, 0)
|
|
return int(winsize.ws_column), err == 0
|
|
}
|
|
return 0, false
|
|
}
|
|
|
|
// stripAnsiEscapes strips ANSI control codes from a byte array in place.
|
|
func stripAnsiEscapes(input []byte) []byte {
|
|
// read represents the remaining part of input that needs to be processed.
|
|
read := input
|
|
// write represents where we should be writing in input.
|
|
// It will share the same backing store as input so that we make our modifications
|
|
// in place.
|
|
write := input
|
|
|
|
// advance will copy count bytes from read to write and advance those slices
|
|
advance := func(write, read []byte, count int) ([]byte, []byte) {
|
|
copy(write, read[:count])
|
|
return write[count:], read[count:]
|
|
}
|
|
|
|
for {
|
|
// Find the next escape sequence
|
|
i := bytes.IndexByte(read, 0x1b)
|
|
// If it isn't found, or if there isn't room for <ESC>[, finish
|
|
if i == -1 || i+1 >= len(read) {
|
|
copy(write, read)
|
|
break
|
|
}
|
|
|
|
// Not a CSI code, continue searching
|
|
if read[i+1] != '[' {
|
|
write, read = advance(write, read, i+1)
|
|
continue
|
|
}
|
|
|
|
// Found a CSI code, advance up to the <ESC>
|
|
write, read = advance(write, read, i)
|
|
|
|
// Find the end of the CSI code
|
|
i = bytes.IndexFunc(read, func(r rune) bool {
|
|
return (r >= 'a' && r <= 'z') || (r >= 'A' && r <= 'Z')
|
|
})
|
|
if i == -1 {
|
|
// We didn't find the end of the code, just remove the rest
|
|
i = len(read) - 1
|
|
}
|
|
|
|
// Strip off the end marker too
|
|
i = i + 1
|
|
|
|
// Skip the reader forward and reduce final length by that amount
|
|
read = read[i:]
|
|
input = input[:len(input)-i]
|
|
}
|
|
|
|
return input
|
|
}
|