Plan 9 from Bell Labs’s /n/sources/contrib/ericvh/go-plan9/src/pkg/crypto/tls/record_read.go

Copyright © 2009 Alcatel-Lucent.
Distributed under the Lucent Public License version 1.02.
Download the Plan 9 distribution.


// 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[0:]);
		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};
	}
}

(This is a user-contributed directory and
should not be interpreted as statement by Alcatel-Lucent.)

Bell Labs OSI certified Powered by Plan 9

(Return to Plan 9 Home Page)

Copyright © 2009 Alcatel-Lucent. All Rights Reserved.
Comments to webmaster@plan9.bell-labs.com.