mirror of
https://github.com/netbirdio/gvisor.git
synced 2026-05-22 17:12:49 -07:00
Standardize import alias
PiperOrigin-RevId: 375507298
This commit is contained in:
committed by
gVisor bot
parent
0b7854cf1e
commit
b60e23a7d9
@@ -36,10 +36,10 @@ import (
|
||||
"gvisor.dev/gvisor/pkg/tcpip/link/loopback"
|
||||
"gvisor.dev/gvisor/pkg/tcpip/link/sniffer"
|
||||
"gvisor.dev/gvisor/pkg/tcpip/network/arp"
|
||||
"gvisor.dev/gvisor/pkg/tcpip/network/internal/testutil"
|
||||
iptestutil "gvisor.dev/gvisor/pkg/tcpip/network/internal/testutil"
|
||||
"gvisor.dev/gvisor/pkg/tcpip/network/ipv4"
|
||||
"gvisor.dev/gvisor/pkg/tcpip/stack"
|
||||
tcptestutil "gvisor.dev/gvisor/pkg/tcpip/testutil"
|
||||
"gvisor.dev/gvisor/pkg/tcpip/testutil"
|
||||
"gvisor.dev/gvisor/pkg/tcpip/transport/icmp"
|
||||
"gvisor.dev/gvisor/pkg/tcpip/transport/raw"
|
||||
"gvisor.dev/gvisor/pkg/tcpip/transport/tcp"
|
||||
@@ -130,11 +130,11 @@ func TestForwarding(t *testing.T) {
|
||||
PrefixLen: 8,
|
||||
}
|
||||
outgoingLinkAddr := tcpip.LinkAddress("\x02\x03\x03\x04\x05\x06")
|
||||
remoteIPv4Addr1 := tcptestutil.MustParse4("10.0.0.2")
|
||||
remoteIPv4Addr2 := tcptestutil.MustParse4("11.0.0.2")
|
||||
unreachableIPv4Addr := tcptestutil.MustParse4("12.0.0.2")
|
||||
multicastIPv4Addr := tcptestutil.MustParse4("225.0.0.0")
|
||||
linkLocalIPv4Addr := tcptestutil.MustParse4("169.254.0.0")
|
||||
remoteIPv4Addr1 := testutil.MustParse4("10.0.0.2")
|
||||
remoteIPv4Addr2 := testutil.MustParse4("11.0.0.2")
|
||||
unreachableIPv4Addr := testutil.MustParse4("12.0.0.2")
|
||||
multicastIPv4Addr := testutil.MustParse4("225.0.0.0")
|
||||
linkLocalIPv4Addr := testutil.MustParse4("169.254.0.0")
|
||||
|
||||
tests := []struct {
|
||||
name string
|
||||
@@ -1542,9 +1542,9 @@ func TestFragmentationWritePacket(t *testing.T) {
|
||||
|
||||
for _, ft := range fragmentationTests {
|
||||
t.Run(ft.description, func(t *testing.T) {
|
||||
ep := testutil.NewMockLinkEndpoint(ft.mtu, nil, math.MaxInt32)
|
||||
ep := iptestutil.NewMockLinkEndpoint(ft.mtu, nil, math.MaxInt32)
|
||||
r := buildRoute(t, ep)
|
||||
pkt := testutil.MakeRandPkt(ft.transportHeaderLength, extraHeaderReserve+header.IPv4MinimumSize, []int{ft.payloadSize}, header.IPv4ProtocolNumber)
|
||||
pkt := iptestutil.MakeRandPkt(ft.transportHeaderLength, extraHeaderReserve+header.IPv4MinimumSize, []int{ft.payloadSize}, header.IPv4ProtocolNumber)
|
||||
source := pkt.Clone()
|
||||
err := r.WritePacket(stack.NetworkHeaderParams{
|
||||
Protocol: tcp.ProtocolNumber,
|
||||
@@ -1598,7 +1598,7 @@ func TestFragmentationWritePackets(t *testing.T) {
|
||||
insertAfter: 1,
|
||||
},
|
||||
}
|
||||
tinyPacket := testutil.MakeRandPkt(header.TCPMinimumSize, extraHeaderReserve+header.IPv4MinimumSize, []int{1}, header.IPv4ProtocolNumber)
|
||||
tinyPacket := iptestutil.MakeRandPkt(header.TCPMinimumSize, extraHeaderReserve+header.IPv4MinimumSize, []int{1}, header.IPv4ProtocolNumber)
|
||||
|
||||
for _, test := range writePacketsTests {
|
||||
t.Run(test.description, func(t *testing.T) {
|
||||
@@ -1608,13 +1608,13 @@ func TestFragmentationWritePackets(t *testing.T) {
|
||||
for i := 0; i < test.insertBefore; i++ {
|
||||
pkts.PushBack(tinyPacket.Clone())
|
||||
}
|
||||
pkt := testutil.MakeRandPkt(ft.transportHeaderLength, extraHeaderReserve+header.IPv4MinimumSize, []int{ft.payloadSize}, header.IPv4ProtocolNumber)
|
||||
pkt := iptestutil.MakeRandPkt(ft.transportHeaderLength, extraHeaderReserve+header.IPv4MinimumSize, []int{ft.payloadSize}, header.IPv4ProtocolNumber)
|
||||
pkts.PushBack(pkt.Clone())
|
||||
for i := 0; i < test.insertAfter; i++ {
|
||||
pkts.PushBack(tinyPacket.Clone())
|
||||
}
|
||||
|
||||
ep := testutil.NewMockLinkEndpoint(ft.mtu, nil, math.MaxInt32)
|
||||
ep := iptestutil.NewMockLinkEndpoint(ft.mtu, nil, math.MaxInt32)
|
||||
r := buildRoute(t, ep)
|
||||
|
||||
wantTotalPackets := len(ft.wantFragments) + test.insertBefore + test.insertAfter
|
||||
@@ -1722,8 +1722,8 @@ func TestFragmentationErrors(t *testing.T) {
|
||||
|
||||
for _, ft := range tests {
|
||||
t.Run(ft.description, func(t *testing.T) {
|
||||
pkt := testutil.MakeRandPkt(ft.transportHeaderLength, extraHeaderReserve+header.IPv4MinimumSize, []int{ft.payloadSize}, header.IPv4ProtocolNumber)
|
||||
ep := testutil.NewMockLinkEndpoint(ft.mtu, ft.mockError, ft.allowPackets)
|
||||
pkt := iptestutil.MakeRandPkt(ft.transportHeaderLength, extraHeaderReserve+header.IPv4MinimumSize, []int{ft.payloadSize}, header.IPv4ProtocolNumber)
|
||||
ep := iptestutil.NewMockLinkEndpoint(ft.mtu, ft.mockError, ft.allowPackets)
|
||||
r := buildRoute(t, ep)
|
||||
err := r.WritePacket(stack.NetworkHeaderParams{
|
||||
Protocol: tcp.ProtocolNumber,
|
||||
@@ -2944,7 +2944,7 @@ func TestWriteStats(t *testing.T) {
|
||||
t.Run(writer.name, func(t *testing.T) {
|
||||
for _, test := range tests {
|
||||
t.Run(test.name, func(t *testing.T) {
|
||||
ep := testutil.NewMockLinkEndpoint(header.IPv4MinimumMTU, &tcpip.ErrInvalidEndpointState{}, test.allowPackets)
|
||||
ep := iptestutil.NewMockLinkEndpoint(header.IPv4MinimumMTU, &tcpip.ErrInvalidEndpointState{}, test.allowPackets)
|
||||
rt := buildRoute(t, ep)
|
||||
|
||||
var pkts stack.PacketBufferList
|
||||
@@ -3240,8 +3240,8 @@ func TestCloseLocking(t *testing.T) {
|
||||
)
|
||||
|
||||
var (
|
||||
src = tcptestutil.MustParse4("16.0.0.1")
|
||||
dst = tcptestutil.MustParse4("16.0.0.2")
|
||||
src = testutil.MustParse4("16.0.0.1")
|
||||
dst = testutil.MustParse4("16.0.0.2")
|
||||
)
|
||||
|
||||
s := stack.New(stack.Options{
|
||||
|
||||
Reference in New Issue
Block a user