diff options
author | Jeff Bean <bean@uber.com> | 2018-06-22 19:41:59 -0700 |
---|---|---|
committer | Jeff Bean <bean@uber.com> | 2018-06-22 19:41:59 -0700 |
commit | fb034c3aba46e318fcbd748cef02796a05305aa2 (patch) | |
tree | 5fb3b56a723dac39a28589d941caad123a1f4f7e /packet | |
parent | 154650594c5b40b2905eb73b90f52de72f6ced16 (diff) |
fixing some typos and found one conversion bug
Diffstat (limited to 'packet')
-rw-r--r-- | packet/bgp/bgp.go | 8 | ||||
-rw-r--r-- | packet/bgp/bgp_test.go | 9 | ||||
-rw-r--r-- | packet/bgp/validate_test.go | 6 |
3 files changed, 14 insertions, 9 deletions
diff --git a/packet/bgp/bgp.go b/packet/bgp/bgp.go index b882f9a6..145f7d99 100644 --- a/packet/bgp/bgp.go +++ b/packet/bgp/bgp.go @@ -1573,7 +1573,7 @@ func (l *MPLSLabelStack) DecodeFromBytes(data []byte) error { } } - if foundBottom { + if !foundBottom { l.Labels = []uint32{} return nil } @@ -1850,13 +1850,13 @@ func (l *LabeledIPAddrPrefix) DecodeFromBytes(data []byte, options ...*Marshalli l.Length = uint8(data[0]) data = data[1:] l.Labels.DecodeFromBytes(data) + if int(l.Length)-8*(l.Labels.Len()) < 0 { l.Labels.Labels = []uint32{} } restbits := int(l.Length) - 8*(l.Labels.Len()) data = data[l.Labels.Len():] - l.decodePrefix(data, uint8(restbits), l.addrlen) - return nil + return l.decodePrefix(data, uint8(restbits), l.addrlen) } func (l *LabeledIPAddrPrefix) Serialize(options ...*MarshallingOption) ([]byte, error) { @@ -9258,10 +9258,12 @@ func (msg *BGPHeader) DecodeFromBytes(data []byte, options ...*MarshallingOption if uint16(len(data)) < BGP_HEADER_LENGTH { return NewMessageError(BGP_ERROR_MESSAGE_HEADER_ERROR, BGP_ERROR_SUB_BAD_MESSAGE_LENGTH, nil, "not all BGP message header") } + msg.Len = binary.BigEndian.Uint16(data[16:18]) if int(msg.Len) < BGP_HEADER_LENGTH { return NewMessageError(BGP_ERROR_MESSAGE_HEADER_ERROR, BGP_ERROR_SUB_BAD_MESSAGE_LENGTH, nil, "unknown message type") } + msg.Type = data[18] return nil } diff --git a/packet/bgp/bgp_test.go b/packet/bgp/bgp_test.go index 555369db..a4801f27 100644 --- a/packet/bgp/bgp_test.go +++ b/packet/bgp/bgp_test.go @@ -19,6 +19,7 @@ import ( "bytes" "encoding/binary" "net" + "reflect" "strconv" "testing" @@ -53,15 +54,17 @@ func Test_Message(t *testing.T) { for _, m1 := range l { buf1, err := m1.Serialize() - require.NoError(t, err) + assert.NoError(t, err) t.Log("LEN =", len(buf1)) m2, err := ParseBGPMessage(buf1) - require.NoError(t, err) + assert.NoError(t, err) // FIXME: shouldn't but workaround for some structs. + _, err = m2.Serialize() + assert.NoError(t, err) - assert.Equal(t, m1, m2) + assert.True(t, reflect.DeepEqual(m1, m2)) } } diff --git a/packet/bgp/validate_test.go b/packet/bgp/validate_test.go index f780b5cc..8bdec550 100644 --- a/packet/bgp/validate_test.go +++ b/packet/bgp/validate_test.go @@ -56,12 +56,12 @@ func Test_Validate_CapV6(t *testing.T) { assert := assert.New(t) message := bgpupdateV6().Body.(*BGPUpdate) res, err := ValidateUpdateMsg(message, map[RouteFamily]BGPAddPathMode{RF_IPv6_UC: BGP_ADD_PATH_BOTH}, false, false) - assert.Equal(true, res) assert.NoError(err) + assert.True(res) res, err = ValidateUpdateMsg(message, map[RouteFamily]BGPAddPathMode{RF_IPv4_UC: BGP_ADD_PATH_BOTH}, false, false) - require.NoError(t, err) - assert.Equal(false, res) + assert.Error(err) + assert.False(res) } func Test_Validate_OK(t *testing.T) { |