- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 519 for donec (0.15 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) -
cmd/bucket-lifecycle.go
func (es *expiryState) enqueueTierJournalEntry(je jentry) { wrkr := es.getWorkerCh(je.OpHash()) if wrkr == nil { es.stats.missedTierJournalTasks.Add(1) return } select { case <-GlobalContext.Done(): case wrkr <- je: default: es.stats.missedTierJournalTasks.Add(1) } } // enqueueFreeVersion enqueues a free version to be deleted func (es *expiryState) enqueueFreeVersion(oi ObjectInfo) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K 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 May 08 22:53:08 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* oldFuture is the previous task's newFuture. * outputFuture is the future we return to the caller, a nonCancellationPropagating taskFuture. * * newFuture is guaranteed to only complete once all tasks previously submitted to this instance * have completed - namely after oldFuture is done, and taskFuture has either completed or been
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 22.1K bytes - Viewed (0) -
.github/workflows/mint.yml
done docker-compose -f ${GITHUB_WORKSPACE}/.github/workflows/multipart/docker-compose-site1.yaml rm -s -f || true docker-compose -f ${GITHUB_WORKSPACE}/.github/workflows/multipart/docker-compose-site2.yaml rm -s -f || true for volume in $(docker volume ls -q | grep minio); do docker volume rm ${volume} || true done
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 23:44:49 GMT 2024 - 2.6K bytes - Viewed (0) -
src/main/assemblies/files/fess
ls=`ls -ld "$SCRIPT"` # Drop everything prior to -> link=`expr "$ls" : '.*-> \(.*\)$'` if expr "$link" : '/.*' > /dev/null; then SCRIPT="$link" else SCRIPT=`dirname "$SCRIPT"`/"$link" fi done # determine fess home FESS_HOME=`dirname "$SCRIPT"`/.. # make FESS_HOME absolute FESS_HOME=`cd "$FESS_HOME"; pwd` # If an include wasn't specified in the environment, then search for one...
Shell Script - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Sun Jan 15 06:32:15 GMT 2023 - 5.4K bytes - Viewed (0) -
cmd/metacache-server-pool.go
o.ID = c.id go func(meta metacache) { // Continuously update while we wait. t := time.NewTicker(metacacheMaxClientWait / 10) defer t.Stop() select { case <-ctx.Done(): // Request is done, stop updating. return case <-t.C: meta.lastHandout = time.Now() meta, _ = rpc.UpdateMetacacheListing(ctx, meta) } }(*c) } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
buildscripts/heal-inconsistent-versions.sh
"${PWD}/mc" cp /etc/hosts minio/bucket/testobj sudo chown -R ${USER}. "${WORK_DIR}/disk${i}" done for vid in $("${PWD}/mc" ls --json --versions minio/bucket/testobj | jq -r .versionId); do "${PWD}/mc" cat --vid "${vid}" minio/bucket/testobj | md5sum done pkill minio sleep 3 } function main() { start_port=$(shuf -i 10000-65000 -n 1) start_minio_4drive ${start_port}
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 26 05:07:25 GMT 2023 - 1.9K bytes - Viewed (0) -
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 May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 22.6K bytes - Viewed (0) -
docs/debugging/build.sh
#!/bin/bash export CGO_ENABLED=0 for dir in docs/debugging/*/; do go build -C ${dir} -v
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 20:47:03 GMT 2023 - 95 bytes - Viewed (0)