Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 621 for wantSz (0.03 sec)

  1. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

         */
        if (throwable instanceof Error) {
          /*
           * TODO(cpovirk): Do we really want to log this if we called setException(throwable) and it
           * returned true? This was intentional (CL 46470009), but it seems odd compared to how we
           * normally handle Error.
           *
           * Similarly, do we really want to log the same Error more than once?
           */
          log(throwable);
        }
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 16K bytes
    - Viewed (0)
  2. .github/workflows/scorecard.yml

            with:
              results_file: results.sarif
              results_format: sarif
              # (Optional) "write" PAT token. Uncomment the `repo_token` line below if:
              # - you want to enable the Branch-Protection check on a *public* repository, or
              # - you are installing Scorecard on a *private* repository
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 01 19:32:55 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  3. internal/ringbuffer/README.md

    
    # Blocking vs Non-blocking
    
    The default behavior of the ring buffer is non-blocking, 
    meaning that reads and writes will return immediately with an error if the operation cannot be completed.
    If you want to block when reading or writing, you must enable it:
    
    ```go
    	rb := ringbuffer.New(1024).SetBlocking(true)
    ```
    
    Enabling blocking will cause the ring buffer to behave like a buffered [io.Pipe](https://pkg.go.dev/io#Pipe).
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

        if (lastElementAt == index) {
          // 'actualLastElement' is now at 'lastElementAt', and the element that was at 'lastElementAt'
          // is now at the end of queue. If that's the element we wanted to remove in the first place,
          // don't try to (incorrectly) trickle it. Instead, just delete it and we're done.
          queue[size] = null;
          return null;
        }
        E toTrickle = elementData(size);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 18:35:44 UTC 2025
    - 33.9K bytes
    - Viewed (0)
  5. internal/grid/muxserver.go

    func (m *muxServer) checkSeq(seq uint32) (ok bool) {
    	if seq != m.RecvSeq {
    		if debugPrint {
    			fmt.Printf("expected sequence %d, got %d\n", m.RecvSeq, seq)
    		}
    		m.disconnect(fmt.Sprintf("receive sequence number mismatch. want %d, got %d", m.RecvSeq, seq), false)
    		return false
    	}
    	m.RecvSeq++
    	return true
    }
    
    func (m *muxServer) message(msg message) {
    	if debugPrint {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  6. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/ArtifactRepositoryMetadata.java

        }
    
        @Override
        public String getArtifactId() {
            return artifact.getArtifactId();
        }
    
        @Override
        public String getBaseVersion() {
            // Don't want the artifact's version in here, as this is stored in the directory above that
            return null;
        }
    
        @Override
        public Object getKey() {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  7. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     * </ul>
     *
     * <p>The main purpose of {@link #addListener addListener} is to support this chaining. You will
     * rarely use it directly, in part because it does not provide direct access to the {@code Future}
     * result. (If you want such access, you may prefer {@link Futures#addCallback
     * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful:
     *
     * {@snippet :
     * final String name = ...;
     * inFlight.add(name);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ListenableFuture.java

     * </ul>
     *
     * <p>The main purpose of {@link #addListener addListener} is to support this chaining. You will
     * rarely use it directly, in part because it does not provide direct access to the {@code Future}
     * result. (If you want such access, you may prefer {@link Futures#addCallback
     * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful:
     *
     * {@snippet :
     * final String name = ...;
     * inFlight.add(name);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/ArtifactResolver.java

    import org.apache.maven.artifact.repository.ArtifactRepository;
    import org.apache.maven.artifact.resolver.filter.ArtifactFilter;
    import org.apache.maven.wagon.events.TransferListener;
    
    /**
     */
    // Just hide the one method we want behind the RepositorySystem interface.
    @Deprecated
    public interface ArtifactResolver {
    
        ArtifactResolutionResult resolve(ArtifactResolutionRequest request);
    
        // The rest is deprecated
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  10. internal/grid/connection.go

    	}
    	readDataInto := func(dst []byte, s ws.State, want ws.OpCode) ([]byte, error) {
    		dst = dst[:0]
    		for {
    			hdr, err := wsReader.NextFrame()
    			if err != nil {
    				return nil, err
    			}
    			if hdr.OpCode.IsControl() {
    				if err := controlHandler(hdr, &wsReader); err != nil {
    					return nil, err
    				}
    				continue
    			}
    			if hdr.OpCode&want == 0 {
    				if err := wsReader.Discard(); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 46.9K bytes
    - Viewed (0)
Back to top