khenaidoo | ac63710 | 2019-01-14 15:44:34 -0500 | [diff] [blame] | 1 | package sarama |
2 | |||||
3 | import "fmt" | ||||
4 | |||||
5 | type responseHeader struct { | ||||
6 | length int32 | ||||
7 | correlationID int32 | ||||
8 | } | ||||
9 | |||||
10 | func (r *responseHeader) decode(pd packetDecoder) (err error) { | ||||
11 | r.length, err = pd.getInt32() | ||||
12 | if err != nil { | ||||
13 | return err | ||||
14 | } | ||||
15 | if r.length <= 4 || r.length > MaxResponseSize { | ||||
16 | return PacketDecodingError{fmt.Sprintf("message of length %d too large or too small", r.length)} | ||||
17 | } | ||||
18 | |||||
19 | r.correlationID, err = pd.getInt32() | ||||
20 | return err | ||||
21 | } |