Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 30 for closeFunc (0.17 sec)

  1. src/net/sock_cloexec_solaris.go

    	if err == nil {
    		syscall.CloseOnExec(s)
    	}
    	syscall.ForkLock.RUnlock()
    	if err != nil {
    		return -1, os.NewSyscallError("socket", err)
    	}
    	if err = syscall.SetNonblock(s, true); err != nil {
    		poll.CloseFunc(s)
    		return -1, os.NewSyscallError("setnonblock", err)
    	}
    	return s, nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:17:25 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  2. src/internal/poll/sys_cloexec.go

    	ns, sa, err := AcceptFunc(s)
    	if err == nil {
    		syscall.CloseOnExec(ns)
    	}
    	if err != nil {
    		return -1, nil, "accept", err
    	}
    	if err = syscall.SetNonblock(ns, true); err != nil {
    		CloseFunc(ns)
    		return -1, nil, "setnonblock", err
    	}
    	return ns, sa, "", nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 07 23:34:17 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  3. src/internal/poll/sock_cloexec_solaris.go

    	ns, sa, err := AcceptFunc(s)
    	if err == nil {
    		syscall.CloseOnExec(ns)
    	}
    	if err != nil {
    		return -1, nil, "accept", err
    	}
    	if err = syscall.SetNonblock(ns, true); err != nil {
    		CloseFunc(ns)
    		return -1, nil, "setnonblock", err
    	}
    	return ns, sa, "", nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:17:25 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  4. src/internal/poll/sock_cloexec_accept.go

    	ns, sa, err = AcceptFunc(s)
    	if err == nil {
    		syscall.CloseOnExec(ns)
    	}
    	if err != nil {
    		return -1, nil, "accept", err
    	}
    	if err = syscall.SetNonblock(ns, true); err != nil {
    		CloseFunc(ns)
    		return -1, nil, "setnonblock", err
    	}
    	return ns, sa, "", nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Dec 16 03:40:42 UTC 2022
    - 1.8K bytes
    - Viewed (0)
  5. src/net/sock_posix.go

    	s, err := sysSocket(family, sotype, proto)
    	if err != nil {
    		return nil, err
    	}
    	if err = setDefaultSockopts(s, family, sotype, ipv6only); err != nil {
    		poll.CloseFunc(s)
    		return nil, err
    	}
    	if fd, err = newFD(s, family, sotype, net); err != nil {
    		poll.CloseFunc(s)
    		return nil, err
    	}
    
    	// This function makes a network file descriptor for the
    	// following applications:
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go

    		c.forget(graceful)
    	}
    
    	if timer == nil {
    		closeFunc()
    		return false
    	}
    
    	// OK, block sending, but only until timer fires.
    	select {
    	case c.input <- event:
    		return true
    	case <-timer.C:
    		closeFunc()
    		return false
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 12:22:41 UTC 2023
    - 18.7K bytes
    - Viewed (0)
  7. src/internal/poll/splice_linux.go

    	return &splicePipe{splicePipeFields: splicePipeFields{rfd: fds[0], wfd: fds[1]}}
    }
    
    // destroyPipe destroys a pipe.
    func destroyPipe(p *splicePipe) {
    	CloseFunc(p.rfd)
    	CloseFunc(p.wfd)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:49:26 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  8. src/net/ipsock_posix.go

    		p.ipv4MappedIPv6Enabled = true
    		return
    	}
    
    	s, err := sysSocket(syscall.AF_INET, syscall.SOCK_STREAM, syscall.IPPROTO_TCP)
    	switch err {
    	case syscall.EAFNOSUPPORT, syscall.EPROTONOSUPPORT:
    	case nil:
    		poll.CloseFunc(s)
    		p.ipv4Enabled = true
    	}
    	var probes = []struct {
    		laddr TCPAddr
    		value int
    	}{
    		// IPv6 communication capability
    		{laddr: TCPAddr{IP: ParseIP("::1")}, value: 1},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  9. src/net/interface_aix.go

    	tab, err := getIfList()
    	if err != nil {
    		return nil, err
    	}
    
    	sock, err := sysSocket(syscall.AF_INET, syscall.SOCK_DGRAM, 0)
    	if err != nil {
    		return nil, err
    	}
    	defer poll.CloseFunc(sock)
    
    	var ift []Interface
    	for len(tab) > 0 {
    		ifm := (*syscall.IfMsgHdr)(unsafe.Pointer(&tab[0]))
    		if ifm.Msglen == 0 {
    			break
    		}
    		if ifm.Type == syscall.RTM_IFINFO {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat Aug 27 05:42:03 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  10. 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)
Back to top