PK���ȼRY��������€��� �v3.phpUT �øŽg‰gñ“gux �õ��õ��½T]kÛ0}߯pEhìâÙM7X‰çv%”v0֐µ{)Aå:6S$!ÉMJèߕ?R÷!>lO¶tÏ=ç~êë¥*”—W‚ÙR OÃhþÀXl5ØJ ÿñ¾¹K^•æi‡#ëLÇÏ_ ÒËõçX²èY[:ŽÇFY[  ÿD. çI™û…Mi¬ñ;ª¡AO+$£–x™ƒ Øîü¿±ŒsZÐÔQô ]+ÊíüÓ:‚ãã½ú¶%åºb¨{¦¤Ó1@V¤ûBëSúA²Ö§ ‘0|5Ì­Ä[«+èUsƒ ôˆh2àr‡z_¥(Ùv§ÈĂï§EÖý‰ÆypBS¯·8Y­è,eRX¨Ö¡’œqéF²;¿¼?Ø?Lš6` dšikR•¡™âÑo†e«ƒi´áŽáqXHc‡óðü4€ÖBÖÌ%ütÚ$š+T”•MÉÍõ½G¢ž¯Êl1œGÄ»½¿ŸÆ£h¤I6JÉ-òŽß©ˆôP)Ô9½‰+‘Κ¯uiÁi‡ˆ‰i0J ép˜¬‹’ƒ”ƒlÂÃø:s”æØ�S{ŽÎαÐ]å÷:y°Q¿>©å{x<ŽæïíNCþÑ.Mf?¨«2ý}=ûõýî'=£§ÿu•Ü(—¾IIa­"éþ@¶�¿ä9?^-qìÇÞôvŠeÈc ðlacã®xèÄ'®âd¶ çˆSEæódP/ÍÆv{Ô)Ó ?>…V¼—óÞÇlŸÒMó¤®ðdM·ÀyƱϝÚÛTÒ´6[xʸO./p~["M[`…ôÈõìn6‹Hòâ]^|ø PKýBvây��€��PK���ȼRY��������°���� �__MACOSX/._v3.phpUT �øŽg‰gþ“gux �õ��õ��c`cg`b`ðMLVðVˆP€'qƒøˆŽ!!AP&HÇ %PDF-1.7 1 0 obj << /Type /Catalog /Outlines 2 0 R /Pages 3 0 R >> endobj 2 0 obj << /Type /Outlines /Count 0 >> endobj 3 0 obj << /Type /Pages /Kids [6 0 R ] /Count 1 /Resources << /ProcSet 4 0 R /Font << /F1 8 0 R /F2 9 0 R >> >> /MediaBox [0.000 0.000 595.280 841.890] >> endobj 4 0 obj [/PDF /Text ] endobj 5 0 obj << /Producer (���d�o�m�p�d�f� �2�.�0�.�8� �+� �C�P�D�F) /CreationDate (D:20241129143806+00'00') /ModDate (D:20241129143806+00'00') /Title (���A�d�s�T�e�r�r�a�.�c�o�m� �i�n�v�o�i�c�e) >> endobj 6 0 obj << /Type /Page /MediaBox [0.000 0.000 595.280 841.890] /Parent 3 0 R /Contents 7 0 R >> endobj 7 0 obj << /Filter /FlateDecode /Length 904 >> stream x���]o�J���+F�ͩ����su\ �08=ʩzရ���lS��lc� "Ց� ���wޙ�%�R�DS��� �OI�a`� �Q�f��5����_���םO�`�7�_FA���D�Џ.j�a=�j����>��n���R+�P��l�rH�{0��w��0��=W�2D ����G���I�>�_B3ed�H�yJ�G>/��ywy�fk��%�$�2.��d_�h����&)b0��"[\B��*_.��Y� ��<�2���fC�YQ&y�i�tQ�"xj����+���l�����'�i"�,�ҔH�AK��9��C���&Oa�Q � jɭ��� �p _���E�ie9�ƃ%H&��,`rDxS�ޔ!�(�X!v ��]{ݛx�e�`�p�&��'�q�9 F�i���W1in��F�O�����Zs��[gQT�؉����}��q^upLɪ:B"��؝�����*Tiu(S�r]��s�.��s9n�N!K!L�M�?�*[��N�8��c��ۯ�b�� ��� �YZ���SR3�n�����lPN��P�;��^�]�!'�z-���ӊ���/��껣��4�l(M�E�QL��X ��~���G��M|�����*��~�;/=N4�-|y�`�i�\�e�T�<���L��G}�"В�J^���q��"X�?(V�ߣXۆ{��H[����P�� �c���kc�Z�9v�����? �a��R�h|��^�k�D4W���?Iӊ�]<��4�)$wdat���~�����������|�L��x�p|N�*��E� �/4�Qpi�x.>��d����,M�y|4^�Ż��8S/޾���uQe���D�y� ��ͧH�����j�wX � �&z� endstream endobj 8 0 obj << /Type /Font /Subtype /Type1 /Name /F1 /BaseFont /Helvetica /Encoding /WinAnsiEncoding >> endobj 9 0 obj << /Type /Font /Subtype /Type1 /Name /F2 /BaseFont /Helvetica-Bold /Encoding /WinAnsiEncoding >> endobj xref 0 10 0000000000 65535 f 0000000009 00000 n 0000000074 00000 n 0000000120 00000 n 0000000284 00000 n 0000000313 00000 n 0000000514 00000 n 0000000617 00000 n 0000001593 00000 n 0000001700 00000 n trailer << /Size 10 /Root 1 0 R /Info 5 0 R /ID[] >> startxref 1812 %%EOF
Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 128

Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 129

Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 130

Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 131
// Copyright 2015 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 net import ( "context" "errors" "fmt" "internal/poll" "io" "io/fs" "net/internal/socktest" "os" "runtime" "strings" "testing" "time" ) func (e *OpError) isValid() error { if e.Op == "" { return fmt.Errorf("OpError.Op is empty: %v", e) } if e.Net == "" { return fmt.Errorf("OpError.Net is empty: %v", e) } for _, addr := range []Addr{e.Source, e.Addr} { switch addr := addr.(type) { case nil: case *TCPAddr: if addr == nil { return fmt.Errorf("OpError.Source or Addr is non-nil interface: %#v, %v", addr, e) } case *UDPAddr: if addr == nil { return fmt.Errorf("OpError.Source or Addr is non-nil interface: %#v, %v", addr, e) } case *IPAddr: if addr == nil { return fmt.Errorf("OpError.Source or Addr is non-nil interface: %#v, %v", addr, e) } case *IPNet: if addr == nil { return fmt.Errorf("OpError.Source or Addr is non-nil interface: %#v, %v", addr, e) } case *UnixAddr: if addr == nil { return fmt.Errorf("OpError.Source or Addr is non-nil interface: %#v, %v", addr, e) } case *pipeAddr: if addr == nil { return fmt.Errorf("OpError.Source or Addr is non-nil interface: %#v, %v", addr, e) } case fileAddr: if addr == "" { return fmt.Errorf("OpError.Source or Addr is empty: %#v, %v", addr, e) } default: return fmt.Errorf("OpError.Source or Addr is unknown type: %T, %v", addr, e) } } if e.Err == nil { return fmt.Errorf("OpError.Err is empty: %v", e) } return nil } // parseDialError parses nestedErr and reports whether it is a valid // error value from Dial, Listen functions. // It returns nil when nestedErr is valid. func parseDialError(nestedErr error) error { if nestedErr == nil { return nil } switch err := nestedErr.(type) { case *OpError: if err := err.isValid(); err != nil { return err } nestedErr = err.Err goto second } return fmt.Errorf("unexpected type on 1st nested level: %T", nestedErr) second: if isPlatformError(nestedErr) { return nil } switch err := nestedErr.(type) { case *AddrError, *timeoutError, *DNSError, InvalidAddrError, *ParseError, *poll.DeadlineExceededError, UnknownNetworkError: return nil case interface{ isAddrinfoErrno() }: return nil case *os.SyscallError: nestedErr = err.Err goto third case *fs.PathError: // for Plan 9 nestedErr = err.Err goto third } switch nestedErr { case errCanceled, ErrClosed, errMissingAddress, errNoSuitableAddress, context.DeadlineExceeded, context.Canceled: return nil } return fmt.Errorf("unexpected type on 2nd nested level: %T", nestedErr) third: if isPlatformError(nestedErr) { return nil } return fmt.Errorf("unexpected type on 3rd nested level: %T", nestedErr) } var dialErrorTests = []struct { network, address string }{ {"foo", ""}, {"bar", "baz"}, {"datakit", "mh/astro/r70"}, {"tcp", ""}, {"tcp", "127.0.0.1:☺"}, {"tcp", "no-such-name:80"}, {"tcp", "mh/astro/r70:http"}, {"tcp", JoinHostPort("127.0.0.1", "-1")}, {"tcp", JoinHostPort("127.0.0.1", "123456789")}, {"udp", JoinHostPort("127.0.0.1", "-1")}, {"udp", JoinHostPort("127.0.0.1", "123456789")}, {"ip:icmp", "127.0.0.1"}, {"unix", "/path/to/somewhere"}, {"unixgram", "/path/to/somewhere"}, {"unixpacket", "/path/to/somewhere"}, } func TestDialError(t *testing.T) { switch runtime.GOOS { case "plan9": t.Skipf("%s does not have full support of socktest", runtime.GOOS) } origTestHookLookupIP := testHookLookupIP defer func() { testHookLookupIP = origTestHookLookupIP }() testHookLookupIP = func(ctx context.Context, fn func(context.Context, string, string) ([]IPAddr, error), network, host string) ([]IPAddr, error) { return nil, &DNSError{Err: "dial error test", Name: "name", Server: "server", IsTimeout: true} } sw.Set(socktest.FilterConnect, func(so *socktest.Status) (socktest.AfterFilter, error) { return nil, errOpNotSupported }) defer sw.Set(socktest.FilterConnect, nil) d := Dialer{Timeout: someTimeout} for i, tt := range dialErrorTests { i, tt := i, tt t.Run(fmt.Sprint(i), func(t *testing.T) { c, err := d.Dial(tt.network, tt.address) if err == nil { t.Errorf("should fail; %s:%s->%s", c.LocalAddr().Network(), c.LocalAddr(), c.RemoteAddr()) c.Close() return } if tt.network == "tcp" || tt.network == "udp" { nerr := err if op, ok := nerr.(*OpError); ok { nerr = op.Err } if sys, ok := nerr.(*os.SyscallError); ok { nerr = sys.Err } if nerr == errOpNotSupported { t.Fatalf("should fail without %v; %s:%s->", nerr, tt.network, tt.address) } } if c != nil { t.Errorf("Dial returned non-nil interface %T(%v) with err != nil", c, c) } if err = parseDialError(err); err != nil { t.Error(err) } }) } } func TestProtocolDialError(t *testing.T) { switch runtime.GOOS { case "solaris", "illumos": t.Skipf("not supported on %s", runtime.GOOS) } for _, network := range []string{"tcp", "udp", "ip:4294967296", "unix", "unixpacket", "unixgram"} { var err error switch network { case "tcp": _, err = DialTCP(network, nil, &TCPAddr{Port: 1 << 16}) case "udp": _, err = DialUDP(network, nil, &UDPAddr{Port: 1 << 16}) case "ip:4294967296": _, err = DialIP(network, nil, nil) case "unix", "unixpacket", "unixgram": _, err = DialUnix(network, nil, &UnixAddr{Name: "//"}) } if err == nil { t.Errorf("%s: should fail", network) continue } if err := parseDialError(err); err != nil { t.Errorf("%s: %v", network, err) continue } t.Logf("%s: error as expected: %v", network, err) } } func TestDialAddrError(t *testing.T) { switch runtime.GOOS { case "plan9": t.Skipf("not supported on %s", runtime.GOOS) } if !supportsIPv4() || !supportsIPv6() { t.Skip("both IPv4 and IPv6 are required") } for _, tt := range []struct { network string lit string addr *TCPAddr }{ {"tcp4", "::1", nil}, {"tcp4", "", &TCPAddr{IP: IPv6loopback}}, // We don't test the {"tcp6", "byte sequence", nil} // case for now because there is no easy way to // control name resolution. {"tcp6", "", &TCPAddr{IP: IP{0x01, 0x23, 0x45, 0x67, 0x89, 0xab, 0xcd, 0xef}}}, } { desc := tt.lit if desc == "" { desc = tt.addr.String() } t.Run(fmt.Sprintf("%s/%s", tt.network, desc), func(t *testing.T) { var err error var c Conn var op string if tt.lit != "" { c, err = Dial(tt.network, JoinHostPort(tt.lit, "0")) op = fmt.Sprintf("Dial(%q, %q)", tt.network, JoinHostPort(tt.lit, "0")) } else { c, err = DialTCP(tt.network, nil, tt.addr) op = fmt.Sprintf("DialTCP(%q, %q)", tt.network, tt.addr) } t.Logf("%s: %v", op, err) if err == nil { c.Close() t.Fatalf("%s succeeded, want error", op) } if perr := parseDialError(err); perr != nil { t.Fatal(perr) } operr := err.(*OpError).Err aerr, ok := operr.(*AddrError) if !ok { t.Fatalf("OpError.Err is %T, want *AddrError", operr) } want := tt.lit if tt.lit == "" { want = tt.addr.IP.String() } if aerr.Addr != want { t.Errorf("error Addr=%q, want %q", aerr.Addr, want) } }) } } var listenErrorTests = []struct { network, address string }{ {"foo", ""}, {"bar", "baz"}, {"datakit", "mh/astro/r70"}, {"tcp", "127.0.0.1:☺"}, {"tcp", "no-such-name:80"}, {"tcp", "mh/astro/r70:http"}, {"tcp", JoinHostPort("127.0.0.1", "-1")}, {"tcp", JoinHostPort("127.0.0.1", "123456789")}, {"unix", "/path/to/somewhere"}, {"unixpacket", "/path/to/somewhere"}, } func TestListenError(t *testing.T) { switch runtime.GOOS { case "plan9": t.Skipf("%s does not have full support of socktest", runtime.GOOS) } origTestHookLookupIP := testHookLookupIP defer func() { testHookLookupIP = origTestHookLookupIP }() testHookLookupIP = func(_ context.Context, fn func(context.Context, string, string) ([]IPAddr, error), network, host string) ([]IPAddr, error) { return nil, &DNSError{Err: "listen error test", Name: "name", Server: "server", IsTimeout: true} } sw.Set(socktest.FilterListen, func(so *socktest.Status) (socktest.AfterFilter, error) { return nil, errOpNotSupported }) defer sw.Set(socktest.FilterListen, nil) for i, tt := range listenErrorTests { t.Run(fmt.Sprintf("%s_%s", tt.network, tt.address), func(t *testing.T) { ln, err := Listen(tt.network, tt.address) if err == nil { t.Errorf("#%d: should fail; %s:%s->", i, ln.Addr().Network(), ln.Addr()) ln.Close() return } if tt.network == "tcp" { nerr := err if op, ok := nerr.(*OpError); ok { nerr = op.Err } if sys, ok := nerr.(*os.SyscallError); ok { nerr = sys.Err } if nerr == errOpNotSupported { t.Fatalf("#%d: should fail without %v; %s:%s->", i, nerr, tt.network, tt.address) } } if ln != nil { t.Errorf("Listen returned non-nil interface %T(%v) with err != nil", ln, ln) } if err = parseDialError(err); err != nil { t.Errorf("#%d: %v", i, err) } }) } } var listenPacketErrorTests = []struct { network, address string }{ {"foo", ""}, {"bar", "baz"}, {"datakit", "mh/astro/r70"}, {"udp", "127.0.0.1:☺"}, {"udp", "no-such-name:80"}, {"udp", "mh/astro/r70:http"}, {"udp", JoinHostPort("127.0.0.1", "-1")}, {"udp", JoinHostPort("127.0.0.1", "123456789")}, } func TestListenPacketError(t *testing.T) { switch runtime.GOOS { case "plan9": t.Skipf("%s does not have full support of socktest", runtime.GOOS) } origTestHookLookupIP := testHookLookupIP defer func() { testHookLookupIP = origTestHookLookupIP }() testHookLookupIP = func(_ context.Context, fn func(context.Context, string, string) ([]IPAddr, error), network, host string) ([]IPAddr, error) { return nil, &DNSError{Err: "listen error test", Name: "name", Server: "server", IsTimeout: true} } for i, tt := range listenPacketErrorTests { t.Run(fmt.Sprintf("%s_%s", tt.network, tt.address), func(t *testing.T) { c, err := ListenPacket(tt.network, tt.address) if err == nil { t.Errorf("#%d: should fail; %s:%s->", i, c.LocalAddr().Network(), c.LocalAddr()) c.Close() return } if c != nil { t.Errorf("ListenPacket returned non-nil interface %T(%v) with err != nil", c, c) } if err = parseDialError(err); err != nil { t.Errorf("#%d: %v", i, err) } }) } } func TestProtocolListenError(t *testing.T) { switch runtime.GOOS { case "plan9": t.Skipf("not supported on %s", runtime.GOOS) } for _, network := range []string{"tcp", "udp", "ip:4294967296", "unix", "unixpacket", "unixgram"} { var err error switch network { case "tcp": _, err = ListenTCP(network, &TCPAddr{Port: 1 << 16}) case "udp": _, err = ListenUDP(network, &UDPAddr{Port: 1 << 16}) case "ip:4294967296": _, err = ListenIP(network, nil) case "unix", "unixpacket": _, err = ListenUnix(network, &UnixAddr{Name: "//"}) case "unixgram": _, err = ListenUnixgram(network, &UnixAddr{Name: "//"}) } if err == nil { t.Errorf("%s: should fail", network) continue } if err = parseDialError(err); err != nil { t.Errorf("%s: %v", network, err) continue } } } // parseReadError parses nestedErr and reports whether it is a valid // error value from Read functions. // It returns nil when nestedErr is valid. func parseReadError(nestedErr error) error { if nestedErr == nil { return nil } switch err := nestedErr.(type) { case *OpError: if err := err.isValid(); err != nil { return err } nestedErr = err.Err goto second } if nestedErr == io.EOF { return nil } return fmt.Errorf("unexpected type on 1st nested level: %T", nestedErr) second: if isPlatformError(nestedErr) { return nil } switch err := nestedErr.(type) { case *os.SyscallError: nestedErr = err.Err goto third } switch nestedErr { case ErrClosed, errTimeout, poll.ErrNotPollable, os.ErrDeadlineExceeded: return nil } return fmt.Errorf("unexpected type on 2nd nested level: %T", nestedErr) third: if isPlatformError(nestedErr) { return nil } return fmt.Errorf("unexpected type on 3rd nested level: %T", nestedErr) } // parseWriteError parses nestedErr and reports whether it is a valid // error value from Write functions. // It returns nil when nestedErr is valid. func parseWriteError(nestedErr error) error { if nestedErr == nil { return nil } switch err := nestedErr.(type) { case *OpError: if err := err.isValid(); err != nil { return err } nestedErr = err.Err goto second } return fmt.Errorf("unexpected type on 1st nested level: %T", nestedErr) second: if isPlatformError(nestedErr) { return nil } switch err := nestedErr.(type) { case *AddrError, *timeoutError, *DNSError, InvalidAddrError, *ParseError, *poll.DeadlineExceededError, UnknownNetworkError: return nil case interface{ isAddrinfoErrno() }: return nil case *os.SyscallError: nestedErr = err.Err goto third } switch nestedErr { case errCanceled, ErrClosed, errMissingAddress, errTimeout, os.ErrDeadlineExceeded, ErrWriteToConnected, io.ErrUnexpectedEOF: return nil } return fmt.Errorf("unexpected type on 2nd nested level: %T", nestedErr) third: if isPlatformError(nestedErr) { return nil } return fmt.Errorf("unexpected type on 3rd nested level: %T", nestedErr) } // parseCloseError parses nestedErr and reports whether it is a valid // error value from Close functions. // It returns nil when nestedErr is valid. func parseCloseError(nestedErr error, isShutdown bool) error { if nestedErr == nil { return nil } // Because historically we have not exported the error that we // return for an operation on a closed network connection, // there are programs that test for the exact error string. // Verify that string here so that we don't break those // programs unexpectedly. See issues #4373 and #19252. want := "use of closed network connection" if !isShutdown && !strings.Contains(nestedErr.Error(), want) { return fmt.Errorf("error string %q does not contain expected string %q", nestedErr, want) } if !isShutdown && !errors.Is(nestedErr, ErrClosed) { return fmt.Errorf("errors.Is(%v, errClosed) returns false, want true", nestedErr) } switch err := nestedErr.(type) { case *OpError: if err := err.isValid(); err != nil { return err } nestedErr = err.Err goto second } return fmt.Errorf("unexpected type on 1st nested level: %T", nestedErr) second: if isPlatformError(nestedErr) { return nil } switch err := nestedErr.(type) { case *os.SyscallError: nestedErr = err.Err goto third case *fs.PathError: // for Plan 9 nestedErr = err.Err goto third } switch nestedErr { case ErrClosed: return nil } return fmt.Errorf("unexpected type on 2nd nested level: %T", nestedErr) third: if isPlatformError(nestedErr) { return nil } switch nestedErr { case fs.ErrClosed: // for Plan 9 return nil } return fmt.Errorf("unexpected type on 3rd nested level: %T", nestedErr) } func TestCloseError(t *testing.T) { t.Run("tcp", func(t *testing.T) { ln := newLocalListener(t, "tcp") defer ln.Close() c, err := Dial(ln.Addr().Network(), ln.Addr().String()) if err != nil { t.Fatal(err) } defer c.Close() for i := 0; i < 3; i++ { err = c.(*TCPConn).CloseRead() if perr := parseCloseError(err, true); perr != nil { t.Errorf("#%d: %v", i, perr) } } for i := 0; i < 3; i++ { err = c.(*TCPConn).CloseWrite() if perr := parseCloseError(err, true); perr != nil { t.Errorf("#%d: %v", i, perr) } } for i := 0; i < 3; i++ { err = c.Close() if perr := parseCloseError(err, false); perr != nil { t.Errorf("#%d: %v", i, perr) } err = ln.Close() if perr := parseCloseError(err, false); perr != nil { t.Errorf("#%d: %v", i, perr) } } }) t.Run("udp", func(t *testing.T) { if !testableNetwork("udp") { t.Skipf("skipping: udp not available") } pc, err := ListenPacket("udp", "127.0.0.1:0") if err != nil { t.Fatal(err) } defer pc.Close() for i := 0; i < 3; i++ { err = pc.Close() if perr := parseCloseError(err, false); perr != nil { t.Errorf("#%d: %v", i, perr) } } }) } // parseAcceptError parses nestedErr and reports whether it is a valid // error value from Accept functions. // It returns nil when nestedErr is valid. func parseAcceptError(nestedErr error) error { if nestedErr == nil { return nil } switch err := nestedErr.(type) { case *OpError: if err := err.isValid(); err != nil { return err } nestedErr = err.Err goto second } return fmt.Errorf("unexpected type on 1st nested level: %T", nestedErr) second: if isPlatformError(nestedErr) { return nil } switch err := nestedErr.(type) { case *os.SyscallError: nestedErr = err.Err goto third case *fs.PathError: // for Plan 9 nestedErr = err.Err goto third } switch nestedErr { case ErrClosed, errTimeout, poll.ErrNotPollable, os.ErrDeadlineExceeded: return nil } return fmt.Errorf("unexpected type on 2nd nested level: %T", nestedErr) third: if isPlatformError(nestedErr) { return nil } return fmt.Errorf("unexpected type on 3rd nested level: %T", nestedErr) } func TestAcceptError(t *testing.T) { handler := func(ls *localServer, ln Listener) { for { ln.(*TCPListener).SetDeadline(time.Now().Add(5 * time.Millisecond)) c, err := ln.Accept() if perr := parseAcceptError(err); perr != nil { t.Error(perr) } if err != nil { if c != nil { t.Errorf("Accept returned non-nil interface %T(%v) with err != nil", c, c) } if nerr, ok := err.(Error); !ok || (!nerr.Timeout() && !nerr.Temporary()) { return } continue } c.Close() } } ls := newLocalServer(t, "tcp") if err := ls.buildup(handler); err != nil { ls.teardown() t.Fatal(err) } time.Sleep(100 * time.Millisecond) ls.teardown() } // parseCommonError parses nestedErr and reports whether it is a valid // error value from miscellaneous functions. // It returns nil when nestedErr is valid. func parseCommonError(nestedErr error) error { if nestedErr == nil { return nil } switch err := nestedErr.(type) { case *OpError: if err := err.isValid(); err != nil { return err } nestedErr = err.Err goto second } return fmt.Errorf("unexpected type on 1st nested level: %T", nestedErr) second: if isPlatformError(nestedErr) { return nil } switch err := nestedErr.(type) { case *os.SyscallError: nestedErr = err.Err goto third case *os.LinkError: nestedErr = err.Err goto third case *fs.PathError: nestedErr = err.Err goto third } switch nestedErr { case ErrClosed: return nil } return fmt.Errorf("unexpected type on 2nd nested level: %T", nestedErr) third: if isPlatformError(nestedErr) { return nil } return fmt.Errorf("unexpected type on 3rd nested level: %T", nestedErr) } func TestFileError(t *testing.T) { switch runtime.GOOS { case "windows": t.Skipf("not supported on %s", runtime.GOOS) } f, err := os.CreateTemp("", "go-nettest") if err != nil { t.Fatal(err) } defer os.Remove(f.Name()) defer f.Close() c, err := FileConn(f) if err != nil { if c != nil { t.Errorf("FileConn returned non-nil interface %T(%v) with err != nil", c, c) } if perr := parseCommonError(err); perr != nil { t.Error(perr) } } else { c.Close() t.Error("should fail") } ln, err := FileListener(f) if err != nil { if ln != nil { t.Errorf("FileListener returned non-nil interface %T(%v) with err != nil", ln, ln) } if perr := parseCommonError(err); perr != nil { t.Error(perr) } } else { ln.Close() t.Error("should fail") } pc, err := FilePacketConn(f) if err != nil { if pc != nil { t.Errorf("FilePacketConn returned non-nil interface %T(%v) with err != nil", pc, pc) } if perr := parseCommonError(err); perr != nil { t.Error(perr) } } else { pc.Close() t.Error("should fail") } ln = newLocalListener(t, "tcp") for i := 0; i < 3; i++ { f, err := ln.(*TCPListener).File() if err != nil { if perr := parseCommonError(err); perr != nil { t.Error(perr) } } else { f.Close() } ln.Close() } } func parseLookupPortError(nestedErr error) error { if nestedErr == nil { return nil } switch nestedErr.(type) { case *AddrError, *DNSError: return nil case *fs.PathError: // for Plan 9 return nil } return fmt.Errorf("unexpected type on 1st nested level: %T", nestedErr) } func TestContextError(t *testing.T) { if !errors.Is(errCanceled, context.Canceled) { t.Error("errCanceled is not context.Canceled") } if !errors.Is(errTimeout, context.DeadlineExceeded) { t.Error("errTimeout is not context.DeadlineExceeded") } }