Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for waitRead (0.12 sec)

  1. src/internal/poll/fd_poll_runtime.go

    	if pd.runtimeCtx == 0 {
    		return errors.New("waiting for unsupported file type")
    	}
    	res := runtime_pollWait(pd.runtimeCtx, mode)
    	return convertErr(res, isFile)
    }
    
    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 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:18:59 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  2. src/internal/poll/fd_wasip1.go

    		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
    	}
    }
    
    func (fd *FD) ReadDirent(buf []byte) (int, error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 20:14:02 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  3. 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.
    //
    // Invariant: when entering splicePump, there are exactly inPipe
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:49:26 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java

              return false;
            } else {
              long now = System.nanoTime();
              TimeUnit.NANOSECONDS.timedWait(lock, nanos);
              nanos -= System.nanoTime() - now; // subtract the actual time we waited
            }
          }
        }
      }
    
      /**
       * Checks if the executor has been shut down and increments the running task count.
       *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/DirectExecutorService.java

              return false;
            } else {
              long now = System.nanoTime();
              TimeUnit.NANOSECONDS.timedWait(lock, nanos);
              nanos -= System.nanoTime() - now; // subtract the actual time we waited
            }
          }
        }
      }
    
      /**
       * Checks if the executor has been shut down and increments the running task count.
       *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  6. subprojects/core/src/main/java/org/gradle/internal/work/AsyncWorkTracker.java

         * the asynchronous work, a {@link org.gradle.internal.exceptions.MultiCauseException} will be thrown with any exceptions
         * thrown.
         *
         * @param workCompletions - The items of work that should be waited on
         * @param lockRetention - How project locks should be treated while waiting on work
         */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 26 11:22:05 UTC 2024
    - 3K bytes
    - Viewed (0)
  7. tensorflow/compiler/jit/xla_tensor.cc

      if (std::find(streams_defined_on_.begin(), streams_defined_on_.end(),
                    stream) != streams_defined_on_.end()) {
        // stream is in streams_defined_on_; it doesn't need to be waited on.
        return;
      }
    
      stream->WaitFor(definition_event_.get()).IgnoreError();
      streams_defined_on_.push_back(stream);
    }
    
    void XlaTensor::ResetDefinitionEvent(std::shared_ptr<se::Event> event,
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Feb 22 08:47:20 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  8. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonStopClient.java

            }
    
            if (connection != null) {
                throw new GradleException(String.format("Timeout waiting for all daemons to stop. Waited %s.", timer.getElapsed()));
            }
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  9. src/os/exec_unix.go

    	// may wait on the wrong process if the PID is reused after the
    	// completes its wait.
    	//
    	// Checking for statusDone here would not be a complete fix, as the PID
    	// could still be waited on and reused prior to blockUntilWaitable.
    	switch p.pidStatus() {
    	case statusReleased:
    		return nil, syscall.EINVAL
    	}
    
    	// If we can block until Wait4 will succeed immediately, do so.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. src/sync/waitgroup.go

    // positive delta that start when the counter is greater than zero, may happen
    // at any time.
    // Typically this means the calls to Add should execute before the statement
    // creating the goroutine or other event to be waited for.
    // If a WaitGroup is reused to wait for several independent sets of events,
    // new Add calls must happen after all previous Wait calls have returned.
    // See the WaitGroup example.
    func (wg *WaitGroup) Add(delta int) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top