Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 29 of 29 for closerFunc (0.37 sec)

  1. src/net/mptcpsock_linux.go

    	switch {
    	case errors.Is(err, syscall.EPROTONOSUPPORT): // Not supported: >= v5.6
    	case errors.Is(err, syscall.EINVAL): // Not supported: < v5.6
    	case err == nil: // Supported and no error
    		poll.CloseFunc(s)
    		fallthrough
    	default:
    		// another error: MPTCP was not available but it might be later
    		mptcpAvailable = true
    	}
    
    	major, minor := unix.KernelVersion()
    	// SOL_MPTCP only supported from kernel 5.16
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 24 18:48:34 UTC 2023
    - 4K bytes
    - Viewed (0)
  2. src/net/fd_unix.go

    	if err != nil {
    		if errcall != "" {
    			err = wrapSyscallError(errcall, err)
    		}
    		return nil, err
    	}
    
    	if netfd, err = newFD(d, fd.family, fd.sotype, fd.net); err != nil {
    		poll.CloseFunc(d)
    		return nil, err
    	}
    	if err = netfd.init(); err != nil {
    		netfd.Close()
    		return nil, err
    	}
    	lsa, _ := syscall.Getsockname(netfd.pfd.Sysfd)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 24 20:19:46 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  3. src/internal/poll/fd_windows.go

    		return syscall.EINVAL
    	}
    	// Poller may want to unregister fd in readiness notification mechanism,
    	// so this must be executed before fd.CloseFunc.
    	fd.pd.close()
    	var err error
    	switch fd.kind {
    	case kindNet:
    		// The net package uses the CloseFunc variable for testing.
    		err = CloseFunc(fd.Sysfd)
    	default:
    		err = syscall.CloseHandle(fd.Sysfd)
    	}
    	fd.Sysfd = syscall.InvalidHandle
    	runtime_Semrelease(&fd.csema)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 31 16:50:42 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  4. src/net/fd_windows.go

    			err = wrapSyscallError(errcall, err)
    		}
    		return nil, err
    	}
    
    	// Associate our new socket with IOCP.
    	netfd, err := newFD(s, fd.family, fd.sotype, fd.net)
    	if err != nil {
    		poll.CloseFunc(s)
    		return nil, err
    	}
    	if err := netfd.init(); err != nil {
    		fd.Close()
    		return nil, err
    	}
    
    	// Get local and peer addr out of AcceptEx buffer.
    	var lrsa, rrsa *syscall.RawSockaddrAny
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 16:46:10 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  5. src/internal/poll/fd_wasip1.go

    	// If the descriptor is indeed closed, using a loop would race
    	// with some other goroutine opening a new descriptor.
    	// (The Linux kernel guarantees that it is closed on an EINTR error.)
    	return CloseFunc(fd)
    }
    
    // Copy creates a copy of the FD.
    //
    // The FD instance points to the same underlying file descriptor. The file
    // descriptor isn't closed until all FD instances that refer to it have been
    // closed/destroyed.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 20:14:02 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  6. src/crypto/tls/tls_test.go

    type changeImplConn struct {
    	net.Conn
    	writeFunc func([]byte) (int, error)
    	closeFunc func() error
    }
    
    func (w *changeImplConn) Write(p []byte) (n int, err error) {
    	if w.writeFunc != nil {
    		return w.writeFunc(p)
    	}
    	return w.Conn.Write(p)
    }
    
    func (w *changeImplConn) Close() error {
    	if w.closeFunc != nil {
    		return w.closeFunc()
    	}
    	return w.Conn.Close()
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 60.5K bytes
    - Viewed (0)
  7. src/internal/poll/fd_unix.go

    // no remaining references.
    func (fd *FD) destroy() error {
    	// Poller may want to unregister fd in readiness notification mechanism,
    	// so this must be executed before CloseFunc.
    	fd.pd.close()
    
    	err := fd.SysFile.destroy(fd.Sysfd)
    
    	fd.Sysfd = -1
    	runtime_Semrelease(&fd.csema)
    	return err
    }
    
    // Close closes the FD. The underlying file descriptor is closed by the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 04:09:44 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  8. src/net/http/clientserver_test.go

    	cst.tr.CloseIdleConnections()
    	a2 := get()
    	if a1 == a2 {
    		t.Errorf("didn't close connection")
    	}
    }
    
    type noteCloseConn struct {
    	net.Conn
    	closeFunc func()
    }
    
    func (x noteCloseConn) Close() error {
    	x.closeFunc()
    	return x.Conn.Close()
    }
    
    type testErrorReader struct{ t *testing.T }
    
    func (r testErrorReader) Read(p []byte) (n int, err error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 46.6K bytes
    - Viewed (0)
  9. src/net/http/serve_test.go

    type rwTestConn struct {
    	io.Reader
    	io.Writer
    	noopConn
    
    	closeFunc func() error // called if non-nil
    	closec    chan bool    // else, if non-nil, send value to it on close
    }
    
    func (c *rwTestConn) Close() error {
    	if c.closeFunc != nil {
    		return c.closeFunc()
    	}
    	select {
    	case c.closec <- true:
    	default:
    	}
    	return nil
    }
    
    type testConn struct {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 202K bytes
    - Viewed (0)
Back to top