mirror of
https://github.com/wader/fq.git
synced 2024-12-01 19:12:34 +03:00
e8dc7112b6
Refactor to use groups between network layers to make them less coupled and reusable: link_frame (ethernet etc) inet_packet (ipv4,ipv6 etc) ip_packet (tcp packet (not stream), udp segment etc) Rename data to payload as i think it makes more sense for network data
68 lines
1.9 KiB
Go
68 lines
1.9 KiB
Go
package inet
|
|
|
|
// SLL stands for sockaddr_ll
|
|
// https://www.tcpdump.org/linktypes/LINKTYPE_LINUX_SLL2.html
|
|
|
|
import (
|
|
"github.com/wader/fq/format"
|
|
"github.com/wader/fq/format/registry"
|
|
"github.com/wader/fq/pkg/decode"
|
|
"github.com/wader/fq/pkg/scalar"
|
|
)
|
|
|
|
var sllPacket2InetPacketGroup decode.Group
|
|
|
|
func init() {
|
|
registry.MustRegister(decode.Format{
|
|
Name: format.SLL2_PACKET,
|
|
Description: "Linux cooked capture encapsulation v2",
|
|
Groups: []string{format.LINK_FRAME},
|
|
Dependencies: []decode.Dependency{
|
|
{Names: []string{format.INET_PACKET}, Group: &sllPacket2InetPacketGroup},
|
|
},
|
|
DecodeFn: decodeSLL2,
|
|
})
|
|
}
|
|
|
|
func decodeSLL2(d *decode.D, in interface{}) interface{} {
|
|
if lfi, ok := in.(format.LinkFrameIn); ok {
|
|
if lfi.Type != format.LinkTypeLINUX_SLL2 {
|
|
d.Fatalf("wrong link type %d", lfi.Type)
|
|
}
|
|
}
|
|
|
|
protcolType := d.FieldU16("protocol_type", format.EtherTypeMap, scalar.Hex)
|
|
d.FieldU16("reserved")
|
|
d.FieldU32("interface_index")
|
|
arpHdrType := d.FieldU16("arphdr_type", arpHdrTypeMAp)
|
|
d.FieldU8("packet_type", sllPacketTypeMap)
|
|
addressLength := d.FieldU8("link_address_length", d.ValidateURange(0, 8))
|
|
// "If there are more than 8 bytes, only the first 8 bytes are present"
|
|
if addressLength > 8 {
|
|
addressLength = 8
|
|
}
|
|
// TODO: maybe skip padding and always read 8 bytes?
|
|
d.FieldU("link_address", int(addressLength)*8)
|
|
addressDiff := 8 - addressLength
|
|
if addressDiff > 0 {
|
|
d.FieldRawLen("padding", int64(addressDiff)*8)
|
|
}
|
|
|
|
// TODO: handle other arphdr types
|
|
switch arpHdrType {
|
|
case arpHdrTypeLoopback, arpHdrTypeEther:
|
|
_ = d.FieldMustGet("link_address").TryScalarFn(mapUToEtherSym, scalar.Hex)
|
|
if dv, _, _ := d.TryFieldFormatLen(
|
|
"payload",
|
|
d.BitsLeft(),
|
|
sllPacket2InetPacketGroup,
|
|
format.LinkFrameIn{Type: int(protcolType)}); dv == nil {
|
|
d.FieldRawLen("payload", d.BitsLeft())
|
|
}
|
|
default:
|
|
d.FieldRawLen("payload", d.BitsLeft())
|
|
}
|
|
|
|
return nil
|
|
}
|