Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,450 for pollable (0.28 sec)

  1. src/internal/poll/fd_unix.go

    // The net argument is a network name from the net package (e.g., "tcp"),
    // or "file".
    // Set pollable to true if fd should be managed by runtime netpoll.
    func (fd *FD) Init(net string, pollable bool) error {
    	fd.SysFile.init()
    
    	// We don't actually care about the various network types.
    	if net == "file" {
    		fd.isFile = true
    	}
    	if !pollable {
    		fd.isBlocking = 1
    		return nil
    	}
    	err := fd.pd.init(fd)
    	if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 04:09:44 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  2. src/os/file_unix.go

    				pollable = false
    			}
    
    			// In addition to the behavior described above for regular files,
    			// on Darwin, kqueue does not work properly with fifos:
    			// closing the last writer does not cause a kqueue event
    			// for any readers. See issue #24164.
    			if (runtime.GOOS == "darwin" || runtime.GOOS == "ios") && typ == syscall.S_IFIFO {
    				pollable = false
    			}
    		}
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 13:52:34 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  3. src/os/fifo_test.go

    // Issue #59545.
    func TestNonPollable(t *testing.T) {
    	if testing.Short() {
    		t.Skip("skipping test with tight loops in short mode")
    	}
    
    	// We need to open a non-pollable file.
    	// This is almost certainly Linux-specific,
    	// but if other systems have non-pollable files,
    	// we can add them here.
    	const nonPollable = "/dev/net/tun"
    
    	f, err := os.OpenFile(nonPollable, os.O_RDWR, 0)
    	if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 19 11:47:23 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  4. src/internal/poll/splice_linux.go

    		n, err := splice(pipefd, sock.Sysfd, max, spliceNonblock)
    		if err == syscall.EINTR {
    			continue
    		}
    		if err != syscall.EAGAIN {
    			return n, err
    		}
    		if sock.pd.pollable() {
    			if err := sock.pd.waitRead(sock.isFile); err != nil {
    				return n, err
    			}
    		}
    	}
    }
    
    // splicePump moves all the buffered data from a pipe to a socket.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:49:26 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  5. src/internal/poll/fd_poll_runtime.go

    	return pd.wait('w', isFile)
    }
    
    func (pd *pollDesc) waitCanceled(mode int) {
    	if pd.runtimeCtx == 0 {
    		return
    	}
    	runtime_pollWaitCanceled(pd.runtimeCtx, mode)
    }
    
    func (pd *pollDesc) pollable() bool {
    	return pd.runtimeCtx != 0
    }
    
    // Error values returned by runtime_pollReset and runtime_pollWait.
    // These must match the values in runtime/netpoll.go.
    const (
    	pollNoError        = 0
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:18:59 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  6. src/internal/poll/fd_windows.go

    // This can be called multiple times on a single FD.
    // The net argument is a network name from the net package (e.g., "tcp"),
    // or "file" or "console" or "dir".
    // Set pollable to true if fd should be managed by runtime netpoll.
    func (fd *FD) Init(net string, pollable bool) (string, error) {
    	if initErr != nil {
    		return "", initErr
    	}
    
    	switch net {
    	case "file", "dir":
    		fd.kind = kindFile
    	case "console":
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 31 16:50:42 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  7. src/internal/poll/fd_wasip1.go

    	if err := fd.incref(); err != nil {
    		return 0, err
    	}
    	defer fd.decref()
    	for {
    		n, err := syscall.ReadDir(fd.Sysfd, buf, cookie)
    		if err != nil {
    			n = 0
    			if err == syscall.EAGAIN && fd.pd.pollable() {
    				if err = fd.pd.waitRead(fd.isFile); err == nil {
    					continue
    				}
    			}
    		}
    		// Do not call eofError; caller does not expect to see io.EOF.
    		return n, err
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 20:14:02 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  8. src/cmd/vendor/golang.org/x/sys/unix/zerrors_zos_s390x.go

    	num  Signal
    	name string
    	desc string
    }{
    	{1, "SIGHUP", "hangup"},
    	{2, "SIGINT", "interrupt"},
    	{3, "SIGABT", "aborted"},
    	{4, "SIGILL", "illegal instruction"},
    	{5, "SIGPOLL", "pollable event"},
    	{6, "SIGURG", "urgent I/O condition"},
    	{7, "SIGSTOP", "stop process"},
    	{8, "SIGFPE", "floating point exception"},
    	{9, "SIGKILL", "killed"},
    	{10, "SIGBUS", "bus error"},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 16:12:58 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  9. src/syscall/zerrors_solaris_amd64.go

    	15: "terminated",
    	16: "user Signal 1",
    	17: "user Signal 2",
    	18: "child Status Changed",
    	19: "power-Fail/Restart",
    	20: "window Size Change",
    	21: "urgent Socket Condition",
    	22: "pollable Event",
    	23: "stopped (signal)",
    	24: "stopped (user)",
    	25: "continued",
    	26: "stopped (tty input)",
    	27: "stopped (tty output)",
    	28: "virtual Timer Expired",
    	29: "profiling Timer Expired",
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 13:52:34 UTC 2024
    - 50.8K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

        Callable<@Nullable Void> callable =
            new Callable<@Nullable Void>() {
              @Override
              public @Nullable Void call() throws Exception {
                assertEquals(Thread.currentThread().getName(), newName.get());
                return null;
              }
            };
        Callables.threadRenaming(callable, newName).call();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 5.4K bytes
    - Viewed (0)
Back to top