Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for waitCanceled (2.92 sec)

  1. src/internal/poll/fd_poll_js.go

    	return ErrDeadlineExceeded
    }
    
    func (pd *pollDesc) waitRead(isFile bool) error { return pd.wait('r', isFile) }
    
    func (pd *pollDesc) waitWrite(isFile bool) error { return pd.wait('w', isFile) }
    
    func (pd *pollDesc) waitCanceled(mode int) {}
    
    func (pd *pollDesc) pollable() bool { return true }
    
    // SetDeadline sets the read and write deadlines associated with fd.
    func (fd *FD) SetDeadline(t time.Time) error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 25 00:12:40 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  2. src/internal/poll/fd_poll_runtime.go

    }
    
    func (pd *pollDesc) waitRead(isFile bool) error {
    	return pd.wait('r', isFile)
    }
    
    func (pd *pollDesc) waitWrite(isFile bool) error {
    	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
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:18:59 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  3. src/internal/poll/fd_windows.go

    	if err != nil && err != syscall.ERROR_NOT_FOUND {
    		// TODO(brainman): maybe do something else, but panic.
    		panic(err)
    	}
    	// Wait for cancellation to complete.
    	fd.pd.waitCanceled(int(o.mode))
    	err = windows.WSAGetOverlappedResult(fd.Sysfd, &o.o, &o.qty, false, &o.flags)
    	if err != nil {
    		if err == syscall.ERROR_OPERATION_ABORTED { // IO Canceled
    			err = netpollErr
    		}
    		return 0, err
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 31 16:50:42 UTC 2024
    - 34.1K bytes
    - Viewed (0)
Back to top