Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 425 for doneSz (0.05 sec)

  1. docs/bucket/replication/setup_2site_existing_replication.sh

    catch() {
    	if [ $# -ne 0 ]; then
    		echo "error on line $1"
    		for site in sitea siteb; do
    			echo "$site server logs ========="
    			cat "/tmp/${site}_1.log"
    			echo "==========================="
    			cat "/tmp/${site}_2.log"
    		done
    	fi
    
    	echo "Cleaning up instances of MinIO"
    	pkill minio
    	pkill -9 minio
    	rm -rf /tmp/multisitea
    	rm -rf /tmp/multisiteb
    	rm -rf /tmp/data
    	if [ $# -ne 0 ]; then
    		exit $#
    	fi
    }
    
    catch
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  2. android/guava-tests/benchmark/com/google/common/collect/SortedCopyBenchmark.java

        List<Integer> list = new ArrayList<>(set);
        inputOrder.arrange(list);
        input = ImmutableList.copyOf(list);
      }
    
      @Benchmark
      int collections(int reps) {
        int dummy = 0;
        // Yes, this could be done more elegantly
        if (mutable) {
          for (int i = 0; i < reps; i++) {
            List<Integer> copy = new ArrayList<>(input);
            sort(copy);
            dummy += copy.get(0);
          }
        } else {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/hash/AbstractNonStreamingHashFunction.java

    import java.nio.ByteOrder;
    import java.nio.charset.Charset;
    import java.util.Arrays;
    
    /**
     * Skeleton implementation of {@link HashFunction}, appropriate for non-streaming algorithms. All
     * the hash computation done using {@linkplain #newHasher()} are delegated to the {@linkplain
     * #hashBytes(byte[], int, int)} method.
     *
     * @author Dimitris Andreou
     */
    @Immutable
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  4. ci/official/containers/ml_build/setup.python.sh

    pushd /usr/include/x86_64-linux-gnu
    for f in $(ls | grep python); do
      # set up symlink for devtoolset-9
      rm -f /dt9/usr/include/x86_64-linux-gnu/$f
      ln -s /usr/include/x86_64-linux-gnu/$f /dt9/usr/include/x86_64-linux-gnu/$f
    done
    popd
    
    # Python 3.10 include headers fix:
    # sysconfig.get_path('include') incorrectly points to /usr/local/include/python
    # map /usr/include/python3.10 to /usr/local/include/python3.10
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Fri Aug 01 02:44:57 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  5. docs/en/docs/async.md

    There's no waiting 🕙 anywhere, just a lot of work to be done, on multiple places of the house.
    
    You could have turns as in the burgers example, first the living room, then the kitchen, but as you are not waiting 🕙 for anything, just cleaning and cleaning, the turns wouldn't affect anything.
    
    It would take the same amount of time to finish with or without turns (concurrency) and you would have done the same amount of work.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24K bytes
    - Viewed (0)
  6. cmd/metacache-server-pool.go

    	listCtx, cancelList := context.WithCancel(ctx)
    	filteredResults := o.gatherResults(listCtx, filterCh)
    	var wg sync.WaitGroup
    	wg.Add(1)
    	var listErr error
    
    	go func(o listPathOptions) {
    		defer wg.Done()
    		if o.Lifecycle == nil {
    			// No filtering ahead, ask drives to stop
    			// listing exactly at a specific limit.
    			o.StopDiskAtLimit = true
    		}
    		listErr = z.listMerged(listCtx, o, filterCh)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  7. cmd/bootstrap-peer-server.go

    	var mu sync.Mutex
    	for onlineServers < len(clnts)/2 {
    		var wg sync.WaitGroup
    		wg.Add(len(clnts))
    		onlineServers = 0
    		for _, clnt := range clnts {
    			go func(clnt *bootstrapRESTClient) {
    				defer wg.Done()
    
    				if clnt.gridConn.State() != grid.StateConnected {
    					mu.Lock()
    					offlineEndpoints = append(offlineEndpoints, fmt.Errorf("%s is unreachable: %w", clnt, grid.ErrDisconnected))
    					mu.Unlock()
    					return
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

       * mutated by the call thread only. If is accessed by background connect threads.
       */
      private val tcpConnectsInFlight = CopyOnWriteArrayList<Plan>()
    
      /**
       * Results are posted here as they occur. The find job is done when either one plan completes
       * successfully or all plans fail.
       */
      private val connectResults = taskRunner.backend.decorate(LinkedBlockingDeque<ConnectResult>())
    
      override fun find(): RealConnection {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  9. ci/official/containers/ml_build_arm64/setup.python.sh

    for f in $(ls | grep python); do
      # set up symlink for devtoolset-10
      rm -f /dt10/usr/include/aarch64-linux-gnu/$f
      ln -s /usr/include/aarch64-linux-gnu/$f /dt10/usr/include/aarch64-linux-gnu/$f
    done
    popd
    
    # Python 3.10 include headers fix:
    # sysconfig.get_path('include') incorrectly points to /usr/local/include/python
    # map /usr/include/python3.10 to /usr/local/include/python3.10
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Fri Aug 01 19:14:43 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt

       * returns null.
       *
       * This will typically return null until [ResponseBody.source] has buffered the last byte of the
       * response body. Call `body.source().request(1024 * 1024)` to block until either that's done, or
       * 1 MiB of response data is loaded into memory. (You could use any size here, though large values
       * risk exhausting memory.)
       *
       * This returns an empty value if the trailers are available, but have no data.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 28 14:39:28 UTC 2025
    - 18.1K bytes
    - Viewed (0)
Back to top