INNER CODE UNIT · Go

readToBuf

kubernetes/dns · cmd/sidecar-e2e/main.go:143

func readToBuf(lock *sync.Mutex, out *string, reader io.Reader) {
	for {
		buf := make([]byte, 4096)
		n, err := io.ReadAtLeast(reader, buf, 1)
		if err != nil {
			return
		}

		lock.Lock()
		*out += string(buf[0:n])
		lock.Unlock()
	}
}

func startDumpToBuf(lock *sync.Mutex, out *string, cmd *exec.Cmd) {
	if pipe, err := cmd.StdoutPipe(); err == nil {
		go readToBuf(lock, out, pipe)
	} else {

View source record →