sarama/protocol/response_header.go

package protocol

import "math"
import enc "sarama/encoding"

type responseHeader struct {
	length         int32
	correlation_id int32
}

func (r *responseHeader) Decode(pd enc.PacketDecoder) (err error) {
	r.length, err = pd.GetInt32()
	if err != nil {
		return err
	}
	if r.length <= 4 || r.length > 2*math.MaxUint16 {
		return enc.DecodingError
	}

	r.correlation_id, err = pd.GetInt32()
	return err
}