Search Options

Results per page
Sort
Preferred Languages
Advance

Results 571 - 580 of 770 for NEXT (0.03 sec)

  1. impl/maven-core/src/main/java/org/apache/maven/graph/DefaultGraphBuilder.java

            StringBuilder projectNames = new StringBuilder();
            Iterator<MavenProject> iterator = projects.iterator();
            while (iterator.hasNext()) {
                MavenProject project = iterator.next();
                projectNames.append(project.getGroupId()).append(":").append(project.getArtifactId());
                if (iterator.hasNext()) {
                    projectNames.append(", ");
                }
            }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/CompactLinkedHashSet.java

      }
    
      private static final int ENDPOINT = -2;
    
      // TODO(user): predecessors and successors should be collocated (reducing cache misses).
      // Might also explore collocating all of [hash, next, predecessor, successor] fields of an
      // entry in a *single* long[], though that reduces the maximum size of the set by a factor of 2
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 09 00:15:47 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  3. docs/debugging/s3-verify/main.go

    	}
    
    	ageDelta, err := time.ParseDuration(minimumObjectAge)
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	maxObjectModTime := time.Now().Add(-ageDelta)
    
    	// Next object is used to ignore new objects in the source & target
    	nextObject := func(ch <-chan minio.ObjectInfo) (ctnt minio.ObjectInfo, ok bool) {
    		for {
    			ctnt, ok := <-ch
    			if !ok {
    				return minio.ObjectInfo{}, false
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 22 15:12:47 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/Lists.java

            }
    
            @Override
            public boolean hasPrevious() {
              return forwardIterator.hasNext();
            }
    
            @Override
            @ParametricNullness
            public T next() {
              if (!hasNext()) {
                throw new NoSuchElementException();
              }
              canRemoveOrSet = true;
              return forwardIterator.previous();
            }
    
            @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 43.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/graph/AbstractNetwork.java

        Set<E> edgesConnecting = edgesConnecting(nodeU, nodeV);
        switch (edgesConnecting.size()) {
          case 0:
            return null;
          case 1:
            return edgesConnecting.iterator().next();
          default:
            throw new IllegalArgumentException(String.format(MULTIPLE_EDGES_CONNECTING, nodeU, nodeV));
        }
      }
    
      @Override
      @CheckForNull
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Mar 13 18:17:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/graph/AbstractNetwork.java

        Set<E> edgesConnecting = edgesConnecting(nodeU, nodeV);
        switch (edgesConnecting.size()) {
          case 0:
            return null;
          case 1:
            return edgesConnecting.iterator().next();
          default:
            throw new IllegalArgumentException(String.format(MULTIPLE_EDGES_CONNECTING, nodeU, nodeV));
        }
      }
    
      @Override
      @CheckForNull
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Mar 13 18:17:09 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  7. internal/grid/handlers.go

    // If the context is canceled, the stream will be canceled.
    func (s *TypedStream[Req, Resp]) Results(next func(resp Resp) error) (err error) {
    	return s.responses.Results(func(b []byte) error {
    		resp := s.newResp()
    		_, err := resp.UnmarshalMsg(b)
    		if err != nil {
    			return err
    		}
    		return next(resp)
    	})
    }
    
    // Streamer creates a stream.
    type Streamer interface {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  8. cmd/format-erasure_test.go

    	fsDirs, err := getRandomDisks(nDisks)
    	if err != nil {
    		b.Fatal(err)
    	}
    
    	endpoints := mustGetNewEndpoints(0, 16, fsDirs...)
    	b.RunParallel(func(pb *testing.PB) {
    		endpoints := endpoints
    		for pb.Next() {
    			initStorageDisksWithErrors(endpoints, storageOpts{cleanUp: false, healthCheck: false})
    		}
    	})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Apr 15 08:25:46 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/Cookie.kt

            set(Calendar.SECOND, second)
            set(Calendar.MILLISECOND, 0)
            return timeInMillis
          }
        }
    
        /**
         * Returns the index of the next date character in `input`, or if `invert` the index
         * of the next non-date character in `input`.
         */
        private fun dateCharacterOffset(
          input: String,
          pos: Int,
          limit: Int,
          invert: Boolean,
        ): Int {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:12:05 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    					z.mpCache.Delete(id)
    					// No need to notify to peers, each node will delete its own cache.
    				}
    				return true
    			})
    
    			// Reset for the next interval
    			timer.Reset(globalAPIConfig.getStaleUploadsCleanupInterval())
    		}
    	}
    }
    
    func (z *erasureServerPools) NewNSLock(bucket string, objects ...string) RWLocker {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top