mirror of
https://github.com/libp2p/go-reuseport.git
synced 2025-09-27 03:05:57 +08:00
46 lines
987 B
Go
46 lines
987 B
Go
package reuseport
|
|
|
|
import (
|
|
"context"
|
|
"net"
|
|
"strings"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func testDialFromListeningPort(t *testing.T, network, host string) {
|
|
lc := net.ListenConfig{
|
|
Control: Control,
|
|
}
|
|
ctx := context.Background()
|
|
ll, err := lc.Listen(ctx, network, host+":0")
|
|
if err != nil && strings.Contains(err.Error(), "cannot assign requested address") {
|
|
t.Skip(err)
|
|
}
|
|
require.NoError(t, err)
|
|
rl, err := lc.Listen(ctx, network, host+":0")
|
|
require.NoError(t, err)
|
|
d := net.Dialer{
|
|
LocalAddr: ll.Addr(),
|
|
Control: Control,
|
|
}
|
|
c, err := d.Dial(network, rl.Addr().String())
|
|
require.NoError(t, err)
|
|
c.Close()
|
|
}
|
|
|
|
func TestDialFromListeningPort(t *testing.T) {
|
|
testDialFromListeningPort(t, "tcp", "localhost")
|
|
}
|
|
|
|
func TestDialFromListeningPortTcp6(t *testing.T) {
|
|
testDialFromListeningPort(t, "tcp6", "[::1]")
|
|
}
|
|
|
|
func TestListenPacketWildcardAddress(t *testing.T) {
|
|
pc, err := ListenPacket("udp", ":0")
|
|
require.NoError(t, err)
|
|
pc.Close()
|
|
}
|