Linux id-dci-web1412.main-hosting.eu 5.14.0-611.20.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jan 14 06:35:04 EST 2026 x86_64
LiteSpeed
: 2a02:4780:6:1512:0:19fc:adf1:2 | : 216.73.216.85
Cant Read [ /etc/named.conf ]
8.1.34
u435990001
www.github.com/MadExploits
Terminal
AUTO ROOT
Adminer
Backdoor Destroyer
Linux Exploit
Lock Shell
Lock File
Create User
CREATE RDP
PHP Mailer
BACKCONNECT
UNLOCK SHELL
HASH IDENTIFIER
CPANEL RESET
CREATE WP USER
README
+ Create Folder
+ Create File
/
opt /
go /
pkg /
mod /
golang.org /
x /
net@v0.20.0 /
ipv6 /
[ HOME SHELL ]
Name
Size
Permission
Action
batch.go
3.31
KB
-r--r--r--
bpf_test.go
2.02
KB
-r--r--r--
control.go
5.88
KB
-r--r--r--
control_rfc2292_unix.go
1.33
KB
-r--r--r--
control_rfc3542_unix.go
2.59
KB
-r--r--r--
control_stub.go
450
B
-r--r--r--
control_test.go
468
B
-r--r--r--
control_unix.go
1.34
KB
-r--r--r--
control_windows.go
363
B
-r--r--r--
defs_aix.go
1.1
KB
-r--r--r--
defs_darwin.go
1.08
KB
-r--r--r--
defs_dragonfly.go
823
B
-r--r--r--
defs_freebsd.go
1.1
KB
-r--r--r--
defs_linux.go
1.31
KB
-r--r--r--
defs_netbsd.go
823
B
-r--r--r--
defs_openbsd.go
823
B
-r--r--r--
defs_solaris.go
1.08
KB
-r--r--r--
dgramopt.go
7.54
KB
-r--r--r--
doc.go
7.71
KB
-r--r--r--
endpoint.go
3.13
KB
-r--r--r--
errors_other_test.go
413
B
-r--r--r--
errors_unix_test.go
481
B
-r--r--r--
example_test.go
5.2
KB
-r--r--r--
export_test.go
216
B
-r--r--r--
gen.go
4.32
KB
-r--r--r--
genericopt.go
1.27
KB
-r--r--r--
header.go
1.46
KB
-r--r--r--
header_test.go
1.2
KB
-r--r--r--
helper.go
1.06
KB
-r--r--r--
helper_posix_test.go
759
B
-r--r--r--
helper_stub_test.go
538
B
-r--r--r--
helper_unix_test.go
895
B
-r--r--r--
helper_windows_test.go
262
B
-r--r--r--
iana.go
4.9
KB
-r--r--r--
icmp.go
1.56
KB
-r--r--r--
icmp_bsd.go
680
B
-r--r--r--
icmp_linux.go
609
B
-r--r--r--
icmp_solaris.go
663
B
-r--r--r--
icmp_stub.go
537
B
-r--r--r--
icmp_test.go
2.02
KB
-r--r--r--
icmp_windows.go
516
B
-r--r--r--
icmp_zos.go
611
B
-r--r--r--
mocktransponder_test.go
610
B
-r--r--r--
multicast_test.go
7.44
KB
-r--r--r--
multicastlistener_test.go
6.07
KB
-r--r--r--
multicastsockopt_test.go
4.26
KB
-r--r--r--
payload.go
578
B
-r--r--r--
payload_cmsg.go
2.46
KB
-r--r--r--
payload_nocmsg.go
1.33
KB
-r--r--r--
readwrite_test.go
13.15
KB
-r--r--r--
sockopt.go
1.81
KB
-r--r--r--
sockopt_posix.go
2.18
KB
-r--r--r--
sockopt_stub.go
1.23
KB
-r--r--r--
sockopt_test.go
2.82
KB
-r--r--r--
sys_aix.go
3.37
KB
-r--r--r--
sys_asmreq.go
618
B
-r--r--r--
sys_asmreq_stub.go
454
B
-r--r--r--
sys_bpf.go
595
B
-r--r--r--
sys_bpf_stub.go
376
B
-r--r--r--
sys_bsd.go
2.78
KB
-r--r--r--
sys_darwin.go
3.97
KB
-r--r--r--
sys_freebsd.go
4.17
KB
-r--r--r--
sys_linux.go
3.83
KB
-r--r--r--
sys_solaris.go
3.86
KB
-r--r--r--
sys_ssmreq.go
1.29
KB
-r--r--r--
sys_ssmreq_stub.go
542
B
-r--r--r--
sys_stub.go
361
B
-r--r--r--
sys_windows.go
1.76
KB
-r--r--r--
sys_zos.go
3.51
KB
-r--r--r--
unicast_test.go
4.63
KB
-r--r--r--
unicastsockopt_test.go
2.58
KB
-r--r--r--
zsys_aix_ppc64.go
1.11
KB
-r--r--r--
zsys_darwin.go
1.02
KB
-r--r--r--
zsys_dragonfly.go
659
B
-r--r--r--
zsys_freebsd_386.go
1.04
KB
-r--r--r--
zsys_freebsd_amd64.go
1.08
KB
-r--r--r--
zsys_freebsd_arm.go
1.08
KB
-r--r--r--
zsys_freebsd_arm64.go
1.04
KB
-r--r--r--
zsys_freebsd_riscv64.go
1.04
KB
-r--r--r--
zsys_linux_386.go
1.24
KB
-r--r--r--
zsys_linux_amd64.go
1.27
KB
-r--r--r--
zsys_linux_arm.go
1.24
KB
-r--r--r--
zsys_linux_arm64.go
1.27
KB
-r--r--r--
zsys_linux_loong64.go
1.29
KB
-r--r--r--
zsys_linux_mips.go
1.24
KB
-r--r--r--
zsys_linux_mips64.go
1.27
KB
-r--r--r--
zsys_linux_mips64le.go
1.27
KB
-r--r--r--
zsys_linux_mipsle.go
1.24
KB
-r--r--r--
zsys_linux_ppc.go
1.24
KB
-r--r--r--
zsys_linux_ppc64.go
1.27
KB
-r--r--r--
zsys_linux_ppc64le.go
1.27
KB
-r--r--r--
zsys_linux_riscv64.go
1.29
KB
-r--r--r--
zsys_linux_s390x.go
1.27
KB
-r--r--r--
zsys_netbsd.go
656
B
-r--r--r--
zsys_openbsd.go
657
B
-r--r--r--
zsys_solaris.go
1.05
KB
-r--r--r--
zsys_zos_s390x.go
1.08
KB
-r--r--r--
Delete
Unzip
Zip
${this.title}
Close
Code Editor : readwrite_test.go
// Copyright 2013 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package ipv6_test import ( "bytes" "fmt" "net" "runtime" "strings" "sync" "testing" "time" "golang.org/x/net/internal/iana" "golang.org/x/net/ipv6" "golang.org/x/net/nettest" ) func BenchmarkReadWriteUnicast(b *testing.B) { switch runtime.GOOS { case "fuchsia", "hurd", "js", "nacl", "plan9", "wasip1", "windows": b.Skipf("not supported on %s", runtime.GOOS) } c, err := nettest.NewLocalPacketListener("udp6") if err != nil { b.Skipf("not supported on %s/%s: %v", runtime.GOOS, runtime.GOARCH, err) } defer c.Close() dst := c.LocalAddr() wb, rb := []byte("HELLO-R-U-THERE"), make([]byte, 128) b.Run("NetUDP", func(b *testing.B) { for i := 0; i < b.N; i++ { if _, err := c.WriteTo(wb, dst); err != nil { b.Fatal(err) } if _, _, err := c.ReadFrom(rb); err != nil { b.Fatal(err) } } }) b.Run("IPv6UDP", func(b *testing.B) { p := ipv6.NewPacketConn(c) cf := ipv6.FlagTrafficClass | ipv6.FlagHopLimit | ipv6.FlagSrc | ipv6.FlagDst | ipv6.FlagInterface | ipv6.FlagPathMTU if err := p.SetControlMessage(cf, true); err != nil { b.Fatal(err) } cm := ipv6.ControlMessage{ TrafficClass: iana.DiffServAF11 | iana.CongestionExperienced, HopLimit: 1, } ifi, _ := nettest.RoutedInterface("ip6", net.FlagUp|net.FlagLoopback) if ifi != nil { cm.IfIndex = ifi.Index } for i := 0; i < b.N; i++ { if _, err := p.WriteTo(wb, &cm, dst); err != nil { b.Fatal(err) } if _, _, _, err := p.ReadFrom(rb); err != nil { b.Fatal(err) } } }) } func BenchmarkPacketConnReadWriteUnicast(b *testing.B) { switch runtime.GOOS { case "fuchsia", "hurd", "js", "nacl", "plan9", "wasip1", "windows": b.Skipf("not supported on %s", runtime.GOOS) } payload := []byte("HELLO-R-U-THERE") iph := []byte{ 0x69, 0x8b, 0xee, 0xf1, 0xca, 0xfe, 0xff, 0x01, 0x20, 0x01, 0x0d, 0xb8, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x20, 0x01, 0x0d, 0xb8, 0x00, 0x02, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, } greh := []byte{0x00, 0x00, 0x86, 0xdd, 0x00, 0x00, 0x00, 0x00} datagram := append(greh, append(iph, payload...)...) bb := make([]byte, 128) cm := ipv6.ControlMessage{ TrafficClass: iana.DiffServAF11 | iana.CongestionExperienced, HopLimit: 1, Src: net.IPv6loopback, } ifi, _ := nettest.RoutedInterface("ip6", net.FlagUp|net.FlagLoopback) if ifi != nil { cm.IfIndex = ifi.Index } b.Run("UDP", func(b *testing.B) { c, err := nettest.NewLocalPacketListener("udp6") if err != nil { b.Skipf("not supported on %s/%s: %v", runtime.GOOS, runtime.GOARCH, err) } defer c.Close() p := ipv6.NewPacketConn(c) dst := c.LocalAddr() cf := ipv6.FlagHopLimit | ipv6.FlagInterface if err := p.SetControlMessage(cf, true); err != nil { b.Fatal(err) } wms := []ipv6.Message{ { Buffers: [][]byte{payload}, Addr: dst, OOB: cm.Marshal(), }, } rms := []ipv6.Message{ { Buffers: [][]byte{bb}, OOB: ipv6.NewControlMessage(cf), }, } b.Run("Net", func(b *testing.B) { for i := 0; i < b.N; i++ { if _, err := c.WriteTo(payload, dst); err != nil { b.Fatal(err) } if _, _, err := c.ReadFrom(bb); err != nil { b.Fatal(err) } } }) b.Run("ToFrom", func(b *testing.B) { for i := 0; i < b.N; i++ { if _, err := p.WriteTo(payload, &cm, dst); err != nil { b.Fatal(err) } if _, _, _, err := p.ReadFrom(bb); err != nil { b.Fatal(err) } } }) b.Run("Batch", func(b *testing.B) { for i := 0; i < b.N; i++ { if _, err := p.WriteBatch(wms, 0); err != nil { b.Fatal(err) } if _, err := p.ReadBatch(rms, 0); err != nil { b.Fatal(err) } } }) }) b.Run("IP", func(b *testing.B) { switch runtime.GOOS { case "netbsd": b.Skip("need to configure gre on netbsd") case "openbsd": b.Skip("net.inet.gre.allow=0 by default on openbsd") } c, err := net.ListenPacket(fmt.Sprintf("ip6:%d", iana.ProtocolGRE), "::1") if err != nil { b.Skipf("not supported on %s/%s: %v", runtime.GOOS, runtime.GOARCH, err) } defer c.Close() p := ipv6.NewPacketConn(c) dst := c.LocalAddr() cf := ipv6.FlagTrafficClass | ipv6.FlagHopLimit | ipv6.FlagSrc | ipv6.FlagDst | ipv6.FlagInterface | ipv6.FlagPathMTU if err := p.SetControlMessage(cf, true); err != nil { b.Fatal(err) } wms := []ipv6.Message{ { Buffers: [][]byte{datagram}, Addr: dst, OOB: cm.Marshal(), }, } rms := []ipv6.Message{ { Buffers: [][]byte{bb}, OOB: ipv6.NewControlMessage(cf), }, } b.Run("Net", func(b *testing.B) { for i := 0; i < b.N; i++ { if _, err := c.WriteTo(datagram, dst); err != nil { b.Fatal(err) } if _, _, err := c.ReadFrom(bb); err != nil { b.Fatal(err) } } }) b.Run("ToFrom", func(b *testing.B) { for i := 0; i < b.N; i++ { if _, err := p.WriteTo(datagram, &cm, dst); err != nil { b.Fatal(err) } if _, _, _, err := p.ReadFrom(bb); err != nil { b.Fatal(err) } } }) b.Run("Batch", func(b *testing.B) { for i := 0; i < b.N; i++ { if _, err := p.WriteBatch(wms, 0); err != nil { b.Fatal(err) } if _, err := p.ReadBatch(rms, 0); err != nil { b.Fatal(err) } } }) }) } func TestPacketConnConcurrentReadWriteUnicastUDP(t *testing.T) { switch runtime.GOOS { case "fuchsia", "hurd", "js", "nacl", "plan9", "wasip1", "windows": t.Skipf("not supported on %s", runtime.GOOS) } ifi, err := nettest.RoutedInterface("ip6", net.FlagUp|net.FlagLoopback) if err != nil { t.Skip("ipv6 is not enabled for loopback interface") } c, err := nettest.NewLocalPacketListener("udp6") if err != nil { t.Fatal(err) } defer c.Close() p := ipv6.NewPacketConn(c) defer p.Close() dst := c.LocalAddr() cf := ipv6.FlagTrafficClass | ipv6.FlagHopLimit | ipv6.FlagSrc | ipv6.FlagDst | ipv6.FlagInterface | ipv6.FlagPathMTU wb := []byte("HELLO-R-U-THERE") if err := p.SetControlMessage(cf, true); err != nil { // probe before test if protocolNotSupported(err) { t.Skipf("not supported on %s", runtime.GOOS) } t.Fatal(err) } var firstError sync.Once fatalf := func(format string, args ...interface{}) { // On the first error, close the PacketConn to unblock the remaining // goroutines. Suppress any further errors, which may occur simply due to // closing the PacketConn. first := false firstError.Do(func() { first = true p.Close() }) if first { t.Helper() t.Errorf(format, args...) } runtime.Goexit() } var wg sync.WaitGroup reader := func() { defer wg.Done() rb := make([]byte, 128) if n, cm, _, err := p.ReadFrom(rb); err != nil { fatalf("%v", err) } else if !bytes.Equal(rb[:n], wb) { fatalf("got %v; want %v", rb[:n], wb) } else { s := cm.String() if strings.Contains(s, ",") { t.Errorf("should be space-separated values: %s", s) } } } writer := func(toggle bool) { defer wg.Done() cm := ipv6.ControlMessage{ TrafficClass: iana.DiffServAF11 | iana.CongestionExperienced, Src: net.IPv6loopback, } if ifi != nil { cm.IfIndex = ifi.Index } if err := p.SetControlMessage(cf, toggle); err != nil { fatalf("%v", err) } backoff := time.Millisecond for { n, err := p.WriteTo(wb, &cm, dst) if err != nil { if n == 0 && isENOBUFS(err) { time.Sleep(backoff) backoff *= 2 continue } fatalf("%v", err) } if n != len(wb) { fatalf("got %d; want %d", n, len(wb)) } break } } const N = 10 wg.Add(N) for i := 0; i < N; i++ { go reader() } wg.Add(2 * N) for i := 0; i < 2*N; i++ { go writer(i%2 != 0) } wg.Add(N) for i := 0; i < N; i++ { go reader() } wg.Wait() } func TestPacketConnConcurrentReadWriteUnicast(t *testing.T) { switch runtime.GOOS { case "fuchsia", "hurd", "js", "nacl", "plan9", "wasip1", "windows": t.Skipf("not supported on %s", runtime.GOOS) } payload := []byte("HELLO-R-U-THERE") iph := []byte{ 0x69, 0x8b, 0xee, 0xf1, 0xca, 0xfe, 0xff, 0x01, 0x20, 0x01, 0x0d, 0xb8, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x20, 0x01, 0x0d, 0xb8, 0x00, 0x02, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, } greh := []byte{0x00, 0x00, 0x86, 0xdd, 0x00, 0x00, 0x00, 0x00} datagram := append(greh, append(iph, payload...)...) t.Run("UDP", func(t *testing.T) { c, err := nettest.NewLocalPacketListener("udp6") if err != nil { t.Skipf("not supported on %s/%s: %v", runtime.GOOS, runtime.GOARCH, err) } defer c.Close() p := ipv6.NewPacketConn(c) t.Run("ToFrom", func(t *testing.T) { testPacketConnConcurrentReadWriteUnicast(t, p, payload, c.LocalAddr(), false) }) t.Run("Batch", func(t *testing.T) { testPacketConnConcurrentReadWriteUnicast(t, p, payload, c.LocalAddr(), true) }) }) t.Run("IP", func(t *testing.T) { switch runtime.GOOS { case "netbsd": t.Skip("need to configure gre on netbsd") case "openbsd": t.Skip("net.inet.gre.allow=0 by default on openbsd") } c, err := net.ListenPacket(fmt.Sprintf("ip6:%d", iana.ProtocolGRE), "::1") if err != nil { t.Skipf("not supported on %s/%s: %v", runtime.GOOS, runtime.GOARCH, err) } defer c.Close() p := ipv6.NewPacketConn(c) t.Run("ToFrom", func(t *testing.T) { testPacketConnConcurrentReadWriteUnicast(t, p, datagram, c.LocalAddr(), false) }) t.Run("Batch", func(t *testing.T) { testPacketConnConcurrentReadWriteUnicast(t, p, datagram, c.LocalAddr(), true) }) }) } func testPacketConnConcurrentReadWriteUnicast(t *testing.T, p *ipv6.PacketConn, data []byte, dst net.Addr, batch bool) { ifi, _ := nettest.RoutedInterface("ip6", net.FlagUp|net.FlagLoopback) cf := ipv6.FlagTrafficClass | ipv6.FlagHopLimit | ipv6.FlagSrc | ipv6.FlagDst | ipv6.FlagInterface | ipv6.FlagPathMTU if err := p.SetControlMessage(cf, true); err != nil { // probe before test if protocolNotSupported(err) { t.Skipf("not supported on %s", runtime.GOOS) } t.Fatal(err) } var firstError sync.Once fatalf := func(format string, args ...interface{}) { // On the first error, close the PacketConn to unblock the remaining // goroutines. Suppress any further errors, which may occur simply due to // closing the PacketConn. first := false firstError.Do(func() { first = true p.Close() }) if first { t.Helper() t.Errorf(format, args...) } runtime.Goexit() } var wg sync.WaitGroup reader := func() { defer wg.Done() b := make([]byte, 128) n, cm, _, err := p.ReadFrom(b) if err != nil { fatalf("%v", err) } if !bytes.Equal(b[:n], data) { fatalf("got %#v; want %#v", b[:n], data) } s := cm.String() if strings.Contains(s, ",") { fatalf("should be space-separated values: %s", s) } } batchReader := func() { defer wg.Done() ms := []ipv6.Message{ { Buffers: [][]byte{make([]byte, 128)}, OOB: ipv6.NewControlMessage(cf), }, } n, err := p.ReadBatch(ms, 0) if err != nil { fatalf("%v", err) } if n != len(ms) { fatalf("got %d; want %d", n, len(ms)) } var cm ipv6.ControlMessage if err := cm.Parse(ms[0].OOB[:ms[0].NN]); err != nil { fatalf("%v", err) } b := ms[0].Buffers[0][:ms[0].N] if !bytes.Equal(b, data) { fatalf("got %#v; want %#v", b, data) } s := cm.String() if strings.Contains(s, ",") { fatalf("should be space-separated values: %s", s) } } writer := func(toggle bool) { defer wg.Done() cm := ipv6.ControlMessage{ TrafficClass: iana.DiffServAF11 | iana.CongestionExperienced, HopLimit: 1, Src: net.IPv6loopback, } if ifi != nil { cm.IfIndex = ifi.Index } if err := p.SetControlMessage(cf, toggle); err != nil { fatalf("%v", err) } backoff := time.Millisecond for { n, err := p.WriteTo(data, &cm, dst) if err != nil { if n == 0 && isENOBUFS(err) { time.Sleep(backoff) backoff *= 2 continue } fatalf("%v", err) } if n != len(data) { fatalf("got %d; want %d", n, len(data)) } break } } batchWriter := func(toggle bool) { defer wg.Done() cm := ipv6.ControlMessage{ TrafficClass: iana.DiffServAF11 | iana.CongestionExperienced, HopLimit: 1, Src: net.IPv6loopback, } if ifi != nil { cm.IfIndex = ifi.Index } if err := p.SetControlMessage(cf, toggle); err != nil { fatalf("%v", err) } ms := []ipv6.Message{ { Buffers: [][]byte{data}, OOB: cm.Marshal(), Addr: dst, }, } backoff := time.Millisecond for { n, err := p.WriteBatch(ms, 0) if err != nil { if n == 0 && isENOBUFS(err) { time.Sleep(backoff) backoff *= 2 continue } fatalf("%v", err) } if n != len(ms) { fatalf("got %d; want %d", n, len(ms)) } if ms[0].N != len(data) { fatalf("got %d; want %d", ms[0].N, len(data)) } break } } const N = 10 wg.Add(N) for i := 0; i < N; i++ { if batch { go batchReader() } else { go reader() } } wg.Add(2 * N) for i := 0; i < 2*N; i++ { if batch { go batchWriter(i%2 != 0) } else { go writer(i%2 != 0) } } wg.Add(N) for i := 0; i < N; i++ { if batch { go batchReader() } else { go reader() } } wg.Wait() }
Close