Skip to content

Commit d761e4e

Browse files
ymym
committed
feat(lldp): implement rx
1 parent 1674a66 commit d761e4e

File tree

11 files changed

+605
-25
lines changed

11 files changed

+605
-25
lines changed

‎.devcontainer/devcontainer.json‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "JetKVM",
3-
"image": "mcr.microsoft.com/devcontainers/go:1-1.23-bookworm",
3+
"image": "mcr.microsoft.com/devcontainers/go:1-1.24-bookworm",
44
"features": {
55
"ghcr.io/devcontainers/features/node:1": {
66
// Should match what is defined in ui/package.json

‎Makefile‎

Lines changed: 24 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,9 @@ VERSION := 0.4.4
88
PROMETHEUS_TAG := github.com/prometheus/common/version
99
KVM_PKG_NAME := github.com/jetkvm/kvm
1010

11+
BUILDKIT_FLAVOR := arm-rockchip830-linux-uclibcgnueabihf
12+
BUILDKIT_PATH ?= /opt/jetkvm-native-buildkit
13+
1114
GO_BUILD_ARGS := -tags netgo
1215
GO_RELEASE_BUILD_ARGS := -trimpath $(GO_BUILD_ARGS)
1316
GO_LDFLAGS := \
@@ -17,7 +20,19 @@ GO_LDFLAGS := \
1720
-X $(PROMETHEUS_TAG).Revision=$(REVISION) \
1821
-X $(KVM_PKG_NAME).builtTimestamp=$(BUILDTS)
1922

20-
GO_CMD := GOOS=linux GOARCH=arm GOARM=7 go
23+
GO_ARGS := GOOS=linux GOARCH=arm GOARM=7
24+
# if BUILDKIT_PATH exists, use buildkit to build
25+
ifneq ($(wildcard $(BUILDKIT_PATH)),)
26+
GO_ARGS := $(GO_ARGS) \
27+
CGO_CFLAGS="-I$(BUILDKIT_PATH)/$(BUILDKIT_FLAVOR)/include -I$(BUILDKIT_PATH)/$(BUILDKIT_FLAVOR)/sysroot/usr/include" \
28+
CGO_LDFLAGS="-L$(BUILDKIT_PATH)/$(BUILDKIT_FLAVOR)/lib -L$(BUILDKIT_PATH)/$(BUILDKIT_FLAVOR)/sysroot/usr/lib" \
29+
CC="$(BUILDKIT_PATH)/bin/$(BUILDKIT_FLAVOR)-gcc" \
30+
LD="$(BUILDKIT_PATH)/bin/$(BUILDKIT_FLAVOR)-ld" \
31+
CGO_ENABLED=1
32+
endif
33+
34+
GO_CMD := $(GO_ARGS) go
35+
2136
BIN_DIR := $(shell pwd)/bin
2237

2338
TEST_DIRS := $(shell find . -name "*_test.go" -type f -exec dirname {} \; | sort -u)
@@ -32,6 +47,13 @@ build_dev: hash_resource
3247
$(GO_RELEASE_BUILD_ARGS) \
3348
-o $(BIN_DIR)/jetkvm_app cmd/main.go
3449

50+
build_afpacket:
51+
@echo "Building..."
52+
$(GO_CMD) build \
53+
-ldflags="$(GO_LDFLAGS) -X $(KVM_PKG_NAME).builtAppVersion=$(VERSION_DEV)" \
54+
$(GO_RELEASE_BUILD_ARGS) \
55+
-o $(BIN_DIR)/afpacket internal/lldp/cmd/afp.go
56+
3557
build_test2json:
3658
$(GO_CMD) build -o $(BIN_DIR)/test2json cmd/test2json
3759

@@ -86,4 +108,4 @@ release:
86108
@echo "Uploading release..."
87109
@shasum -a 256 bin/jetkvm_app | cut -d ' ' -f 1 > bin/jetkvm_app.sha256
88110
rclone copyto bin/jetkvm_app r2://jetkvm-update/app/$(VERSION)/jetkvm_app
89-
rclone copyto bin/jetkvm_app.sha256 r2://jetkvm-update/app/$(VERSION)/jetkvm_app.sha256
111+
rclone copyto bin/jetkvm_app.sha256 r2://jetkvm-update/app/$(VERSION)/jetkvm_app.sha256

‎go.mod‎

Lines changed: 21 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -11,13 +11,16 @@ require (
1111
github.com/coreos/go-oidc/v3 v3.11.0
1212
github.com/creack/pty v1.1.23
1313
github.com/fsnotify/fsnotify v1.9.0
14-
github.com/gin-contrib/logger v1.2.6
15-
github.com/gin-gonic/gin v1.10.1
14+
github.com/gin-contrib/logger v1.2.5
15+
github.com/gin-gonic/gin v1.10.0
16+
github.com/google/gopacket v1.1.19
1617
github.com/google/uuid v1.6.0
1718
github.com/guregu/null/v6 v6.0.0
1819
github.com/gwatts/rootcerts v0.0.0-20240401182218-3ab9db955caf
19-
github.com/hanwen/go-fuse/v2 v2.8.0
20-
github.com/pion/logging v0.2.3
20+
github.com/hanwen/go-fuse/v2 v2.5.1
21+
github.com/hashicorp/go-getter/v2 v2.2.3
22+
github.com/jellydator/ttlcache/v3 v3.3.0
23+
github.com/pion/logging v0.2.2
2124
github.com/pion/mdns/v2 v2.0.7
2225
github.com/pion/webrtc/v4 v4.0.16
2326
github.com/pojntfx/go-nbd v0.3.2
@@ -30,15 +33,16 @@ require (
3033
github.com/stretchr/testify v1.10.0
3134
github.com/vishvananda/netlink v1.3.0
3235
go.bug.st/serial v1.6.2
33-
golang.org/x/crypto v0.39.0
34-
golang.org/x/net v0.41.0
35-
golang.org/x/sys v0.33.0
36+
golang.org/x/crypto v0.36.0
37+
golang.org/x/net v0.38.0
38+
golang.org/x/sys v0.32.0
3639
)
3740

3841
replace github.com/pojntfx/go-nbd v0.3.2 => github.com/chemhack/go-nbd v0.0.0-20241006125820-59e45f5b1e7b
3942

4043
require (
4144
github.com/beorn7/perks v1.0.1 // indirect
45+
github.com/bgentry/go-netrc v0.0.0-20140422174119-9fd32a8b3d3d // indirect
4246
github.com/bytedance/sonic v1.13.2 // indirect
4347
github.com/bytedance/sonic/loader v0.2.4 // indirect
4448
github.com/cespare/xxhash/v2 v2.3.0 // indirect
@@ -52,11 +56,18 @@ require (
5256
github.com/go-playground/universal-translator v0.18.1 // indirect
5357
github.com/go-playground/validator/v10 v10.26.0 // indirect
5458
github.com/goccy/go-json v0.10.5 // indirect
59+
github.com/hashicorp/errwrap v1.0.0 // indirect
60+
github.com/hashicorp/go-cleanhttp v0.5.0 // indirect
61+
github.com/hashicorp/go-multierror v1.1.0 // indirect
62+
github.com/hashicorp/go-safetemp v1.0.0 // indirect
63+
github.com/hashicorp/go-version v1.1.0 // indirect
5564
github.com/json-iterator/go v1.1.12 // indirect
5665
github.com/klauspost/cpuid/v2 v2.2.10 // indirect
5766
github.com/leodido/go-urn v1.4.0 // indirect
5867
github.com/mattn/go-colorable v0.1.14 // indirect
5968
github.com/mattn/go-isatty v0.0.20 // indirect
69+
github.com/mitchellh/go-homedir v1.0.0 // indirect
70+
github.com/mitchellh/go-testing-interface v1.0.0 // indirect
6071
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
6172
github.com/modern-go/reflect2 v1.0.2 // indirect
6273
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
@@ -80,11 +91,13 @@ require (
8091
github.com/rogpeppe/go-internal v1.11.0 // indirect
8192
github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
8293
github.com/ugorji/go/codec v1.2.12 // indirect
94+
github.com/ulikunitz/xz v0.5.8 // indirect
8395
github.com/vishvananda/netns v0.0.4 // indirect
8496
github.com/wlynxg/anet v0.0.5 // indirect
8597
golang.org/x/arch v0.17.0 // indirect
8698
golang.org/x/oauth2 v0.24.0 // indirect
87-
golang.org/x/text v0.26.0 // indirect
99+
golang.org/x/sync v0.12.0 // indirect
100+
golang.org/x/text v0.23.0 // indirect
88101
google.golang.org/protobuf v1.36.6 // indirect
89102
gopkg.in/yaml.v3 v3.0.1 // indirect
90103
)

‎go.sum‎

Lines changed: 56 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,8 @@ github.com/beevik/ntp v1.4.3 h1:PlbTvE5NNy4QHmA4Mg57n7mcFTmr1W1j3gcK7L1lqho=
44
github.com/beevik/ntp v1.4.3/go.mod h1:Unr8Zg+2dRn7d8bHFuehIMSvvUYssHMxW3Q5Nx4RW5Q=
55
github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM=
66
github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=
7+
github.com/bgentry/go-netrc v0.0.0-20140422174119-9fd32a8b3d3d h1:xDfNPAt8lFiC1UJrqV3uuy861HCTo708pDMbjHHdCas=
8+
github.com/bgentry/go-netrc v0.0.0-20140422174119-9fd32a8b3d3d/go.mod h1:6QX/PXZ00z/TKoufEY6K/a0k6AhaJrQKdFe6OfVXsa4=
79
github.com/bytedance/sonic v1.13.2 h1:8/H1FempDZqC4VqjptGo14QQlJx8VdZJegxs6wwfqpQ=
810
github.com/bytedance/sonic v1.13.2/go.mod h1:o68xyaF9u2gvVBuGHPlUVCy+ZfmNNO5ETf1+KgkJhz4=
911
github.com/bytedance/sonic/loader v0.1.1/go.mod h1:ncP89zfokxS5LZrJxl5z0UJcsk4M4yY2JpfqGeCtNLU=
@@ -54,14 +56,30 @@ github.com/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5x
5456
github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
5557
github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
5658
github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
59+
github.com/google/gopacket v1.1.19 h1:ves8RnFZPGiFnTS0uPQStjwru6uO6h+nlr9j6fL7kF8=
60+
github.com/google/gopacket v1.1.19/go.mod h1:iJ8V8n6KS+z2U1A8pUwu8bW5SyEMkXJB8Yo/Vo+TKTo=
5761
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
5862
github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
5963
github.com/guregu/null/v6 v6.0.0 h1:N14VRS+4di81i1PXRiprbQJ9EM9gqBa0+KVMeS/QSjQ=
6064
github.com/guregu/null/v6 v6.0.0/go.mod h1:hrMIhIfrOZeLPZhROSn149tpw2gHkidAqxoXNyeX3iQ=
6165
github.com/gwatts/rootcerts v0.0.0-20240401182218-3ab9db955caf h1:JO6ISZIvEUitto5zjQ3/VEnDM5rPbqIFuOhS0U0ByeA=
6266
github.com/gwatts/rootcerts v0.0.0-20240401182218-3ab9db955caf/go.mod h1:5Kt9XkWvkGi2OHOq0QsGxebHmhCcqJ8KCbNg/a6+n+g=
63-
github.com/hanwen/go-fuse/v2 v2.8.0 h1:wV8rG7rmCz8XHSOwBZhG5YcVqcYjkzivjmbaMafPlAs=
64-
github.com/hanwen/go-fuse/v2 v2.8.0/go.mod h1:yE6D2PqWwm3CbYRxFXV9xUd8Md5d6NG0WBs5spCswmI=
67+
github.com/hanwen/go-fuse/v2 v2.5.1 h1:OQBE8zVemSocRxA4OaFJbjJ5hlpCmIWbGr7r0M4uoQQ=
68+
github.com/hanwen/go-fuse/v2 v2.5.1/go.mod h1:xKwi1cF7nXAOBCXujD5ie0ZKsxc8GGSA1rlMJc+8IJs=
69+
github.com/hashicorp/errwrap v1.0.0 h1:hLrqtEDnRye3+sgx6z4qVLNuviH3MR5aQ0ykNJa/UYA=
70+
github.com/hashicorp/errwrap v1.0.0/go.mod h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4=
71+
github.com/hashicorp/go-cleanhttp v0.5.0 h1:wvCrVc9TjDls6+YGAF2hAifE1E5U1+b4tH6KdvN3Gig=
72+
github.com/hashicorp/go-cleanhttp v0.5.0/go.mod h1:JpRdi6/HCYpAwUzNwuwqhbovhLtngrth3wmdIIUrZ80=
73+
github.com/hashicorp/go-getter/v2 v2.2.3 h1:6CVzhT0KJQHqd9b0pK3xSP0CM/Cv+bVhk+jcaRJ2pGk=
74+
github.com/hashicorp/go-getter/v2 v2.2.3/go.mod h1:hp5Yy0GMQvwWVUmwLs3ygivz1JSLI323hdIE9J9m7TY=
75+
github.com/hashicorp/go-multierror v1.1.0 h1:B9UzwGQJehnUY1yNrnwREHc3fGbC2xefo8g4TbElacI=
76+
github.com/hashicorp/go-multierror v1.1.0/go.mod h1:spPvp8C1qA32ftKqdAHm4hHTbPw+vmowP0z+KUhOZdA=
77+
github.com/hashicorp/go-safetemp v1.0.0 h1:2HR189eFNrjHQyENnQMMpCiBAsRxzbTMIgBhEyExpmo=
78+
github.com/hashicorp/go-safetemp v1.0.0/go.mod h1:oaerMy3BhqiTbVye6QuFhFtIceqFoDHxNAB65b+Rj1I=
79+
github.com/hashicorp/go-version v1.1.0 h1:bPIoEKD27tNdebFGGxxYwcL4nepeY4j1QP23PFRGzg0=
80+
github.com/hashicorp/go-version v1.1.0/go.mod h1:fltr4n8CU8Ke44wwGCBoEymUuxUHl09ZGVZPK5anwXA=
81+
github.com/jellydator/ttlcache/v3 v3.3.0 h1:BdoC9cE81qXfrxeb9eoJi9dWrdhSuwXMAnHTbnBm4Wc=
82+
github.com/jellydator/ttlcache/v3 v3.3.0/go.mod h1:bj2/e0l4jRnQdrnSTaGTsh4GSXvMjQcy41i7th0GVGw=
6583
github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=
6684
github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
6785
github.com/klauspost/compress v1.18.0 h1:c/Cqfb0r+Yi+JtIEq73FWXVkRonBlf0CRNYc8Zttxdo=
@@ -88,8 +106,12 @@ github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/
88106
github.com/mattn/go-isatty v0.0.19/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
89107
github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
90108
github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
91-
github.com/moby/sys/mountinfo v0.7.2 h1:1shs6aH5s4o5H2zQLn796ADW1wMrIwHsyJ2v9KouLrg=
92-
github.com/moby/sys/mountinfo v0.7.2/go.mod h1:1YOa8w8Ih7uW0wALDUgT1dTTSBrZ+HiBLGws92L2RU4=
109+
github.com/mitchellh/go-homedir v1.0.0 h1:vKb8ShqSby24Yrqr/yDYkuFz8d0WUjys40rvnGC8aR0=
110+
github.com/mitchellh/go-homedir v1.0.0/go.mod h1:SfyaCUpYCn1Vlf4IUYiD9fPX4A5wJrkLzIz1N1q0pr0=
111+
github.com/mitchellh/go-testing-interface v1.0.0 h1:fzU/JVNcaqHQEcVFAKeR41fkiLdIPrefOvVG1VZ96U0=
112+
github.com/mitchellh/go-testing-interface v1.0.0/go.mod h1:kRemZodwjscx+RGhAo8eIhFbs2+BFgRtFPeD/KE+zxI=
113+
github.com/moby/sys/mountinfo v0.6.2 h1:BzJjoreD5BMFNmD9Rus6gdd1pLuecOFPt8wC+Vygl78=
114+
github.com/moby/sys/mountinfo v0.6.2/go.mod h1:IJb6JQeOklcdMU9F5xQ8ZALD+CUr5VlGpwtX+VE0rpI=
93115
github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
94116
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg=
95117
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
@@ -167,6 +189,8 @@ github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS
167189
github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08=
168190
github.com/ugorji/go/codec v1.2.12 h1:9LC83zGrHhuUA9l16C9AHXAqEV/2wBQ4nkvumAE65EE=
169191
github.com/ugorji/go/codec v1.2.12/go.mod h1:UNopzCgEMSXjBc6AOMqYvWC1ktqTAfzJZUZgYf6w6lg=
192+
github.com/ulikunitz/xz v0.5.8 h1:ERv8V6GKqVi23rgu5cj9pVfVzJbOqAY2Ntl88O6c2nQ=
193+
github.com/ulikunitz/xz v0.5.8/go.mod h1:nbz6k7qbPmH4IRqmfOplQw/tblSgqTqBwxkY0oWt/14=
170194
github.com/vishvananda/netlink v1.3.0 h1:X7l42GfcV4S6E4vHTsw48qbrV+9PVojNfIhZcwQdrZk=
171195
github.com/vishvananda/netlink v1.3.0/go.mod h1:i6NetklAujEcC6fK0JPjT8qSwWyO0HLn4UKG+hGqeJs=
172196
github.com/vishvananda/netns v0.0.4 h1:Oeaw1EM2JMxD51g9uhtC0D7erkIjgmj8+JZc26m1YX8=
@@ -175,23 +199,41 @@ github.com/wlynxg/anet v0.0.5 h1:J3VJGi1gvo0JwZ/P1/Yc/8p63SoW98B5dHkYDmpgvvU=
175199
github.com/wlynxg/anet v0.0.5/go.mod h1:eay5PRQr7fIVAMbTbchTnO9gG65Hg/uYGdc7mguHxoA=
176200
go.bug.st/serial v1.6.2 h1:kn9LRX3sdm+WxWKufMlIRndwGfPWsH1/9lCWXQCasq8=
177201
go.bug.st/serial v1.6.2/go.mod h1:UABfsluHAiaNI+La2iESysd9Vetq7VRdpxvjx7CmmOE=
178-
golang.org/x/arch v0.17.0 h1:4O3dfLzd+lQewptAHqjewQZQDyEdejz3VwgeYwkZneU=
179-
golang.org/x/arch v0.17.0/go.mod h1:bdwinDaKcfZUGpH09BB7ZmOfhalA8lQdzl62l8gGWsk=
180-
golang.org/x/crypto v0.39.0 h1:SHs+kF4LP+f+p14esP5jAoDpHU8Gu/v9lFRK6IT5imM=
181-
golang.org/x/crypto v0.39.0/go.mod h1:L+Xg3Wf6HoL4Bn4238Z6ft6KfEpN0tJGo53AAPC632U=
182-
golang.org/x/net v0.41.0 h1:vBTly1HeNPEn3wtREYfy4GZ/NECgw2Cnl+nK6Nz3uvw=
183-
golang.org/x/net v0.41.0/go.mod h1:B/K4NNqkfmg07DQYrbwvSluqCJOOXwUjeb/5lOisjbA=
202+
go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
203+
go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
204+
golang.org/x/arch v0.15.0 h1:QtOrQd0bTUnhNVNndMpLHNWrDmYzZ2KDqSrEymqInZw=
205+
golang.org/x/arch v0.15.0/go.mod h1:JmwW7aLIoRUKgaTzhkiEFxvcEiQGyOg9BMonBJUS7EE=
206+
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
207+
golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
208+
golang.org/x/crypto v0.36.0 h1:AnAEvhDddvBdpY+uR+MyHmuZzzNqXSe/GvuDeob5L34=
209+
golang.org/x/crypto v0.36.0/go.mod h1:Y4J0ReaxCR1IMaabaSMugxJES1EpwhBHhv2bDHklZvc=
210+
golang.org/x/lint v0.0.0-20200302205851-738671d3881b/go.mod h1:3xt1FjdF8hUf6vQPIChWIBhFzV8gjjsPE/fR3IyQdNY=
211+
golang.org/x/mod v0.1.1-0.20191105210325-c90efee705ee/go.mod h1:QqPTAvyqsEbceGzBzNggFXnrqF1CaUcvgkdR5Ot7KZg=
212+
golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
213+
golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
214+
golang.org/x/net v0.38.0 h1:vRMAPTMaeGqVhG5QyLJHqNDwecKTomGeqbnfZyKlBI8=
215+
golang.org/x/net v0.38.0/go.mod h1:ivrbrMbzFq5J41QOQh0siUuly180yBYtLp+CKbEaFx8=
184216
golang.org/x/oauth2 v0.24.0 h1:KTBBxWqUa0ykRPLtV69rRto9TLXcqYkeswu48x/gvNE=
185217
golang.org/x/oauth2 v0.24.0/go.mod h1:XYTD2NtWslqkgxebSiOHnXEap4TF09sJSc7H1sXbhtI=
218+
golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
219+
golang.org/x/sync v0.0.0-20201207232520-09787c993a3a/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
220+
golang.org/x/sync v0.12.0 h1:MHc5BpPuC30uJk597Ri8TV3CNZcTLu6B6z4lJy+g6Jw=
221+
golang.org/x/sync v0.12.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
222+
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
223+
golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
224+
golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
186225
golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
187226
golang.org/x/sys v0.2.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
188227
golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
189228
golang.org/x/sys v0.10.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
190229
golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
191-
golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw=
192-
golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
193-
golang.org/x/text v0.26.0 h1:P42AVeLghgTYr4+xUnTRKDMqpar+PtX7KWuNQL21L8M=
194-
golang.org/x/text v0.26.0/go.mod h1:QK15LZJUUQVJxhz7wXgxSy/CJaTFjd0G+YLonydOVQA=
230+
golang.org/x/sys v0.32.0 h1:s77OFDvIQeibCmezSnk/q6iAfkdiQaJi4VzroCFrN20=
231+
golang.org/x/sys v0.32.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
232+
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
233+
golang.org/x/text v0.23.0 h1:D71I7dUrlY+VX0gQShAThNGHFxZ13dGLBHQLVl1mJlY=
234+
golang.org/x/text v0.23.0/go.mod h1:/BLNzu4aZCJ1+kcD0DNRotWKage4q2rGVAg4o22unh4=
235+
golang.org/x/tools v0.0.0-20200130002326-2f3ba24bd6e7/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
236+
golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
195237
google.golang.org/protobuf v1.36.6 h1:z1NpPI8ku2WgiWnf+t9wTPsn6eP1L7ksHUlkfLvd9xY=
196238
google.golang.org/protobuf v1.36.6/go.mod h1:jduwjTPXsFjZGTmRluh+L6NjiWu7pchiJ2/5YcXBHnY=
197239
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=

‎internal/lldp/afpacket.go‎

Lines changed: 85 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,85 @@
1+
package lldp
2+
3+
import (
4+
"fmt"
5+
"net"
6+
"os"
7+
"syscall"
8+
"unsafe"
9+
10+
"github.com/google/gopacket/afpacket"
11+
"golang.org/x/sys/unix"
12+
)
13+
14+
const (
15+
afPacketBufferSize = 2 // in MiB
16+
afPacketSnaplen = 9216
17+
)
18+
19+
func afPacketComputeSize(targetSizeMb int, snaplen int, pageSize int) (
20+
frameSize int, blockSize int, numBlocks int, err error) {
21+
22+
if snaplen < pageSize {
23+
frameSize = pageSize / (pageSize / snaplen)
24+
} else {
25+
frameSize = (snaplen/pageSize + 1) * pageSize
26+
}
27+
28+
// 128 is the default from the gopacket library so just use that
29+
blockSize = frameSize * 128
30+
numBlocks = (targetSizeMb * 1024 * 1024) / blockSize
31+
32+
if numBlocks == 0 {
33+
return 0, 0, 0, fmt.Errorf("interface buffersize is too small")
34+
}
35+
36+
return frameSize, blockSize, numBlocks, nil
37+
}
38+
39+
func afPacketNewTPacket(ifName string) (*afpacket.TPacket, error) {
40+
szFrame, szBlock, numBlocks, err := afPacketComputeSize(
41+
afPacketBufferSize,
42+
afPacketSnaplen,
43+
os.Getpagesize())
44+
if err != nil {
45+
return nil, err
46+
}
47+
48+
return afpacket.NewTPacket(
49+
afpacket.OptInterface(ifName),
50+
afpacket.OptFrameSize(szFrame),
51+
afpacket.OptBlockSize(szBlock),
52+
afpacket.OptNumBlocks(numBlocks),
53+
afpacket.OptAddVLANHeader(false),
54+
afpacket.SocketRaw,
55+
afpacket.TPacketVersion3)
56+
}
57+
58+
type ifreq struct {
59+
ifrName [IFNAMSIZ]byte
60+
ifrHwaddr syscall.RawSockaddr
61+
}
62+
63+
func addMulticastAddr(ifName string, addr net.HardwareAddr) error {
64+
fd, err := syscall.Socket(syscall.AF_INET, syscall.SOCK_DGRAM, 0)
65+
if err != nil {
66+
return err
67+
}
68+
defer syscall.Close(fd)
69+
70+
var name [IFNAMSIZ]byte
71+
copy(name[:], []byte(ifName))
72+
73+
ifr := &ifreq{
74+
ifrName: name,
75+
ifrHwaddr: toRawSockaddr(addr),
76+
}
77+
78+
_, _, ep := unix.Syscall(unix.SYS_IOCTL, uintptr(fd),
79+
unix.SIOCADDMULTI, uintptr(unsafe.Pointer(ifr)))
80+
81+
if ep != 0 {
82+
return syscall.Errno(ep)
83+
}
84+
return nil
85+
}

‎internal/lldp/afpacket_arm.go‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
//go:build arm && linux
2+
3+
package lldp
4+
5+
import (
6+
"net"
7+
"syscall"
8+
)
9+
10+
func toRawSockaddr(mac net.HardwareAddr) (sockaddr syscall.RawSockaddr) {
11+
for i, n := range mac {
12+
sockaddr.Data[i] = uint8(n)
13+
}
14+
return
15+
}

‎internal/lldp/afpacket_nonarm.go‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
//go:build !arm && linux
2+
3+
package lldp
4+
5+
import (
6+
"net"
7+
"syscall"
8+
)
9+
10+
func toRawSockaddr(mac net.HardwareAddr) (sockaddr syscall.RawSockaddr) {
11+
for i, n := range mac {
12+
sockaddr.Data[i] = int8(n)
13+
}
14+
return
15+
}

0 commit comments

Comments
 (0)