[github/fretlink/terraform-provider-statuscake.git] / vendor / github.com / fsouza / go-dockerclient / external / github.com / Sirupsen / logrus / writer.go

package logrus

import (
	"bufio"
	"io"
	"runtime"
)

func (logger *Logger) Writer() *io.PipeWriter {
	reader, writer := io.Pipe()

	go logger.writerScanner(reader)
	runtime.SetFinalizer(writer, writerFinalizer)

	return writer
}

func (logger *Logger) writerScanner(reader *io.PipeReader) {
	scanner := bufio.NewScanner(reader)
	for scanner.Scan() {
		logger.Print(scanner.Text())
	}
	if err := scanner.Err(); err != nil {
		logger.Errorf("Error while reading from Writer: %s", err)
	}
	reader.Close()
}

func writerFinalizer(writer *io.PipeWriter) {
	writer.Close()
}
Commit	Line	Data
9b12e4fe JC	1	package logrus
	2
	3	import (
	4	"bufio"
	5	"io"
	6	"runtime"
	7	)
	8
	9	func (logger Logger) Writer() io.PipeWriter {
	10	reader, writer := io.Pipe()
	11
	12	go logger.writerScanner(reader)
	13	runtime.SetFinalizer(writer, writerFinalizer)
	14
	15	return writer
	16	}
	17
	18	func (logger Logger) writerScanner(reader io.PipeReader) {
	19	scanner := bufio.NewScanner(reader)
	20	for scanner.Scan() {
	21	logger.Print(scanner.Text())
	22	}
	23	if err := scanner.Err(); err != nil {
	24	logger.Errorf("Error while reading from Writer: %s", err)
	25	}
	26	reader.Close()
	27	}
	28
	29	func writerFinalizer(writer *io.PipeWriter) {
	30	writer.Close()
	31	}