tc_program

README

• 外部パッケージの github.com/vishvananda/netlink が何らか利用できない状態になって、RST パケットがドロップできないとなっても、回避策はある（ref）

  $ sudo iptables -A OUTPUT -s 127.0.0.1 -d 127.0.0.1 -p tcp --tcp-flags RST RST -j DROP
  

• 初回 go generate 前に、以下あたりを確認しておく

  • https://ebpf-go.dev/guides/getting-started/#ebpf-c-program
  • 2. Linuxカーネルヘッダーのインストール
    • だと、ちょっとうまくいかなかった。自分の環境が悪かったか。
  • 以下を新しいPCで初回実行で go generate できるようになった。

    $ sudo apt search linux-headers
    # ↑の結果から↓へ指定
    $ sudo apt install linux-headers-6.1.0-21-amd64
    $ sudo ln -s /usr/include/x86_64-linux-gnu/asm /usr/include/asm
    $ cd ~/github.com/ddddddO/packemon/tc_program
    $ go generate
    

Documentation

Index

• Constants
• func AddClsactQdisc(attachTo string) (*netlink.GenericQdisc, error)
• func Close(ebpfProg *tc_programObjects, qdisc *netlink.GenericQdisc, ...) error
• func InitializeTCProgram() (*tc_programObjects, error)
• func PrepareAnalyzingIngressPackets(nwInterface string, objs *tc_programObjects) (*netlink.BpfFilter, error)
• func PrepareDropingRSTPacket(nwInterface string, objs *tc_programObjects) (*netlink.BpfFilter, error)
• type AnalyzedPackets
  • func GetAnalyzedPackets(analysisMap *ebpf.Map) (*AnalyzedPackets, error)

Constants

const (
	// ebpfプログラム側と合わせること。ただ、現状のWSL2だと同一mapに複数のkey指定できない？みたいだった
	SUM_COUNT_KEY = uint32(0)
)

Functions

func AddClsactQdisc

func AddClsactQdisc(attachTo string) (*netlink.GenericQdisc, error)

func Close

func Close(ebpfProg *tc_programObjects, qdisc *netlink.GenericQdisc, filters ...*netlink.BpfFilter) error

TODO: err即returnではなくすべての処理してからerr返すようにしたほうがいいかも

func InitializeTCProgram

func InitializeTCProgram() (*tc_programObjects, error)

func PrepareAnalyzingIngressPackets

func PrepareAnalyzingIngressPackets(nwInterface string, objs *tc_programObjects) (*netlink.BpfFilter, error)

func PrepareDropingRSTPacket

func PrepareDropingRSTPacket(nwInterface string, objs *tc_programObjects) (*netlink.BpfFilter, error)

Types

type AnalyzedPackets

type AnalyzedPackets struct {
	Sum uint64
}

func GetAnalyzedPackets

func GetAnalyzedPackets(analysisMap *ebpf.Map) (*AnalyzedPackets, error)