- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 4,820 for Done (0.16 sec)
-
src/cmd/cgo/internal/test/issue1435.go
// #include <unistd.h> // #include <sys/types.h> // // pthread_t *t = NULL; // pthread_mutex_t mu; // int nts = 0; // int all_done = 0; // // static void *aFn(void *vargp) { // int done = 0; // while (!done) { // usleep(100); // pthread_mutex_lock(&mu); // done = all_done; // pthread_mutex_unlock(&mu); // } // return NULL; // } // // void trial(int argc) { // int i;
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Jul 28 21:31:41 GMT 2023 - 7.5K bytes - Viewed (0) -
guava/src/com/google/common/collect/AbstractIterator.java
*/ @CanIgnoreReturnValue @CheckForNull protected final T endOfData() { state = State.DONE; return null; } @Override public final boolean hasNext() { checkState(state != State.FAILED); switch (state) { case DONE: return false; case READY: return true; default: } return tryToComputeNext(); }
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Fri Mar 18 02:04:10 GMT 2022 - 6.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 12K bytes - Viewed (0) -
cni/pkg/repair/repair.go
} rc, err := NewRepairController(client, cfg) if err != nil { repairLog.Fatalf("Fatal error constructing repair controller: %+v", err) } go rc.Run(ctx.Done()) client.RunAndWait(ctx.Done()) } // Set up Kubernetes client using kubeconfig (or in-cluster config if no file provided) func clientSetup() (kube.Client, error) { config, err := kube.DefaultRestConfig("", "") if err != nil {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.5K bytes - Viewed (0) -
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.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 3.1K bytes - Viewed (0) -
buildscripts/verify-healing.sh
d=$((d + 1)) args="$args http://127.0.0.1:$((start_port + 1))${WORK_DIR}/1/${d}/ http://127.0.0.1:$((start_port + 2))${WORK_DIR}/2/${d}/ http://127.0.0.1:$((start_port + 3))${WORK_DIR}/3/${d}/ " done "${MINIO[@]}" --address ":$((start_port + 1))" $args >"${WORK_DIR}/dist-minio-server1.log" 2>&1 & pid1=$! disown ${pid1}
Shell Script - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 4.2K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java
crawler.awaitTermination(crawlingExecutionInterval); if (crawler.getCrawlerContext().getStatus() == CrawlerStatus.DONE && !Constants.DONE.equals(crawlerStatusList.get(i))) { crawlerStatusList.set(i, Constants.DONE); final String sid = crawler.getCrawlerContext().getSessionId(); indexUpdater.addFinishedSessionId(sid);
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 22.6K bytes - Viewed (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.3K bytes - Viewed (1) -
cmd/peer-rest-client.go
// Listen - listen on peers. func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) { go func() { for { client.doListen(ctx, listenCh, v) select { case <-ctx.Done(): return default: // There was error in the REST request, retry after sometime as probably the peer is down. time.Sleep(5 * time.Second) } } }() }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
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(
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 11.6K bytes - Viewed (0)