| 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 | } | ||||