Function newTextprotoReader

textproto_reader.go:41–70

NewReader returns a new textprotoReader reading from r. To avoid denial of service attacks, the provided bufio.Reader should be reading from an io.LimitReader or similar textprotoReader to bound the size of responses.

(r *bufio.Reader, ds dump.Dumpers)

// should be reading from an io.LimitReader or similar textprotoReader to bound
// the size of responses.
func newTextprotoReader(r *bufio.Reader, ds dump.Dumpers) *textprotoReader {
	commonHeaderOnce.Do(initCommonHeader)
	t := &textprotoReader{R: r}

	if ds.ShouldDump() {
		t.readLine = func() (line []byte, isPrefix bool, err error) {
			line, err = t.R.ReadSlice('\n')
			if len(line) == 0 {
				if err != nil {
					line = nil
				}
				return
			}
			err = nil
			ds.DumpResponseHeader(line)
			if line[len(line)-1] == '\n' {
				drop := 1
				if len(line) > 1 && line[len(line)-2] == '\r' {
					drop = 2
				}
				line = line[:len(line)-drop]
			}
			return
		}
	} else {
		t.readLine = t.R.ReadLine
	}

	return t
}

// ReadLine reads a single line from r,
// eliding the final \n or \r\n from the returned string.