| // Copyright 2009 The Go Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style |
| // license that can be found in the LICENSE file. |
| |
| package tls |
| |
| // The record reader handles reading from the connection and reassembling TLS |
| // record structures. It loops forever doing this and writes the TLS records to |
| // it's outbound channel. On error, it closes its outbound channel. |
| |
| import ( |
| "io" |
| "bufio" |
| ) |
| |
| // recordReader loops, reading TLS records from source and writing them to the |
| // given channel. The channel is closed on EOF or on error. |
| func recordReader(c chan<- *record, source io.Reader) { |
| defer close(c) |
| buf := bufio.NewReader(source) |
| |
| for { |
| var header [5]byte |
| n, _ := buf.Read(&header) |
| if n != 5 { |
| return |
| } |
| |
| recordLength := int(header[3])<<8 | int(header[4]) |
| if recordLength > maxTLSCiphertext { |
| return |
| } |
| |
| payload := make([]byte, recordLength) |
| n, _ = buf.Read(payload) |
| if n != recordLength { |
| return |
| } |
| |
| c <- &record{recordType(header[0]), header[1], header[2], payload} |
| } |
| } |