Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for SetNonblock (0.21 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/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)
  3. src/net/file_unix.go

    	s, call, err := poll.DupCloseOnExec(int(f.Fd()))
    	if err != nil {
    		if call != "" {
    			err = os.NewSyscallError(call, err)
    		}
    		return -1, err
    	}
    	if err := syscall.SetNonblock(s, true); err != nil {
    		poll.CloseFunc(s)
    		return -1, os.NewSyscallError("setnonblock", err)
    	}
    	return s, nil
    }
    
    func newFileFD(f *os.File) (*netFD, error) {
    	s, err := dupSocket(f)
    	if err != nil {
    		return nil, err
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  4. src/net/sock_cloexec.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // This file implements sysSocket for platforms that provide a fast path for
    // setting SetNonblock and CloseOnExec.
    
    //go:build dragonfly || freebsd || linux || netbsd || openbsd
    
    package net
    
    import (
    	"os"
    	"syscall"
    )
    
    // Wrapper around the socket system call that marks the returned file
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:17:25 UTC 2024
    - 730 bytes
    - Viewed (0)
  5. src/runtime/netpoll_fake.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // Fake network poller for js/wasm.
    // Should never be used, because js/wasm network connections do not honor "SetNonblock".
    
    //go:build js && wasm
    
    package runtime
    
    func netpollinit() {
    }
    
    func netpollIsPollDescriptor(fd uintptr) bool {
    	return false
    }
    
    func netpollopen(fd uintptr, pd *pollDesc) int32 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jul 20 15:45:57 UTC 2023
    - 664 bytes
    - Viewed (0)
  6. src/internal/poll/sock_cloexec.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // This file implements accept for platforms that provide a fast path for
    // setting SetNonblock and CloseOnExec.
    
    //go:build dragonfly || freebsd || (linux && !arm) || netbsd || openbsd
    
    package poll
    
    import "syscall"
    
    // Wrapper around the accept system call that marks the returned file
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:17:25 UTC 2024
    - 712 bytes
    - Viewed (0)
  7. src/os/pipe_test.go

    func TestReadNonblockingFd(t *testing.T) {
    	switch runtime.GOOS {
    	case "windows":
    		t.Skip("Windows doesn't support SetNonblock")
    	}
    	if os.Getenv("GO_WANT_READ_NONBLOCKING_FD") == "1" {
    		fd := syscallDescriptor(os.Stdin.Fd())
    		syscall.SetNonblock(fd, true)
    		defer syscall.SetNonblock(fd, false)
    		_, err := os.Stdin.Read(make([]byte, 1))
    		if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 05 23:35:29 UTC 2023
    - 12.4K bytes
    - Viewed (0)
  8. src/syscall/fs_wasip1.go

    	// runtime supports non-blocking stdio, the Go runtime is able to
    	// use the WASI net poller to poll for read/write readiness and is
    	// able to schedule goroutines while waiting.
    	SetNonblock(0, true)
    	SetNonblock(1, true)
    	SetNonblock(2, true)
    }
    
    type uintptr32 = uint32
    type size = uint32
    type fdflags = uint32
    type filesize = uint64
    type filetype = uint8
    type lookupflags = uint32
    type oflags = uint32
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  9. src/os/os_unix_test.go

    		t.Fatalf("pipe: %v", err)
    	}
    	defer syscall.Close(p[1])
    
    	// Set the read-side to non-blocking.
    	if !blocking {
    		if err := syscall.SetNonblock(p[0], true); err != nil {
    			syscall.Close(p[0])
    			t.Fatalf("SetNonblock: %v", err)
    		}
    	}
    	// Convert it to a file.
    	file := NewFile(uintptr(p[0]), "notapipe")
    	if file == nil {
    		syscall.Close(p[0])
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:32:43 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  10. src/os/fifo_test.go

    	}
    }
    
    func TestNewFileNonBlocking(t *testing.T) {
    	var p [2]int
    	if err := syscall.Pipe(p[:]); err != nil {
    		t.Fatal(err)
    	}
    	if err := syscall.SetNonblock(p[0], true); err != nil {
    		t.Fatal(err)
    	}
    	f := os.NewFile(uintptr(p[0]), "pipe")
    	nonblock, err := unix.IsNonblock(p[0])
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer f.Close()
    	if !nonblock {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 19 11:47:23 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top