Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 561 for doneSz (0.21 sec)

  1. docs/features/caching.md

    Deleting the cache when it is no longer needed can be done.  However this may delete the purpose of the cache
    which is designed to persist between app restarts.
    
    ```kotlin
    cache.delete()
    ```
     
    ## Pruning the Cache
    
    Pruning the entire Cache to clear space temporarily can be done using evictAll.
    
    ```kotlin
    cache.evictAll()
    ```
    
    Removing individual items can be done using the urls iterator.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 3.1K bytes
    - Viewed (1)
  2. internal/logger/target/kafka/kafka_scram_client_contrib.go

    	response, err = x.ClientConversation.Step(challenge)
    	return response, err
    }
    
    // Done returns true if the conversation is completed or has errored.
    func (x *XDGSCRAMClient) Done() bool {
    	return x.ClientConversation.Done()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  3. cmd/metacache-walk.go

    		return err
    	}
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricWalkDir, opts.Bucket, opts.BaseDir)
    	if err != nil {
    		return err
    	}
    	defer done(0, &err)
    
    	return p.storage.WalkDir(ctx, opts, wr)
    }
    
    // WalkDir will traverse a directory and return all entries found.
    // On success a meta cache stream will be returned, that should be closed when done.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  4. docs/resiliency/resiliency-initial-script.sh

    		echo retry: timeout while running: mc alias set
    		exit 1
    	fi
    	eval ./mc alias set "${ALIAS_NAME}" "${MINIO_SERVER_URL}" minioadmin minioadmin && break
    	TIMEOUT=$((TIMEOUT - 1))
    	sleep 1
    done
    
    ./mc ready "${ALIAS_NAME}"
    
    ./mc mb "${ALIAS_NAME}"/"${BUCKET}"
    rm -rf "${SRC_DIR}" "${INLINED_DIR}" "${DEST_DIR}" && mkdir -p "${SRC_DIR}" "${INLINED_DIR}" "${DEST_DIR}"
    for idx in {1..10}; do
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sat Dec 21 04:24:45 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/graph/TraverserTest.java

        assertEqualCharNodes(Iterables.limit(result, 2), "ab");
        assertThat(graph.requestedNodes).containsExactly('a', 'a', 'b');
    
        // Iterate again to see if calculation is done again
        assertEqualCharNodes(Iterables.limit(result, 2), "ab");
        assertThat(graph.requestedNodes).containsExactly('a', 'a', 'a', 'b', 'b');
      }
    
      @Test
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 17:09:51 UTC 2025
    - 47.4K bytes
    - Viewed (2)
  6. internal/grid/grid_test.go

    				// Just wait for it to cancel.
    				for blockResp {
    					select {
    					case <-ctx.Done():
    						close(serverCanceled)
    						return NewRemoteErr(ctx.Err())
    					case resp <- []byte{1}:
    						time.Sleep(10 * time.Millisecond)
    					}
    				}
    				// Just wait for it to cancel.
    				<-ctx.Done()
    				close(serverCanceled)
    				return NewRemoteErr(ctx.Err())
    			},
    			OutCapacity: 1,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 36.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

    /**
     * A {@link FutureTask} that also implements the {@link ListenableFuture} interface. Unlike {@code
     * FutureTask}, {@code ListenableFutureTask} does not provide an overrideable {@link
     * FutureTask#done() done()} method. For similar functionality, call {@link #addListener}.
     *
     * <p>Few users should use this class. It is intended primarily for those who are implementing an
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  8. buildscripts/disable-root.sh

    nr_servers=4
    
    addr="localhost"
    args=""
    for ((i = 0; i < $((nr_servers)); i++)); do
    	args="$args $scheme://$addr:$((9100 + i))/${HOME}/tmp/dist/path1/$i"
    done
    
    echo $args
    
    for ((i = 0; i < $((nr_servers)); i++)); do
    	(minio server --address ":$((9100 + i))" $args 2>&1 >/tmp/log$i.txt) &
    done
    
    sleep 10s
    
    if [ ! -f ./mc ]; then
    	wget --quiet -O ./mc https://dl.minio.io/client/mc/release/linux-amd64/./mc &&
    		chmod +x mc
    fi
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

        do {
          System.runFinalization();
          if (predicate.isDone()) {
            return;
          }
          CountDownLatch done = new CountDownLatch(1);
          createUnreachableLatchFinalizer(done);
          await(done);
          if (predicate.isDone()) {
            return;
          }
        } while (System.nanoTime() - deadline < 0);
        throw formatRuntimeException(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  10. apache-maven/src/assembly/maven/bin/mvn

    while [ -h "$PRG" ] ; do
      ls=`ls -ld "$PRG"`
      link=`expr "$ls" : '.*-> \(.*\)$'`
      if expr "$link" : '/.*' > /dev/null; then
        PRG="$link"
      else
        PRG="`dirname "$PRG"`/$link"
      fi
    done
    
    saveddir=`pwd`
    
    MAVEN_HOME=`dirname "$PRG"`/..
    
    # make it fully qualified
    MAVEN_HOME=`cd "$MAVEN_HOME" && pwd`
    
    cd "$saveddir"
    
    CLASSWORLDS_CONF="$MAVEN_HOME/bin/m2.conf"
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Dec 10 16:40:06 UTC 2025
    - 9.2K bytes
    - Viewed (0)
Back to top