- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 106 for waitc (0.05 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
} postEnqueue.Done() postEnqueue.Wait() } postDequeueFunc := func() { preDequeue.Done() preDequeue.Wait() if atomicReadOnlyWaiting != 0 { t.Errorf("Wanted %d requests in queue, got %d", 0, atomicReadOnlyWaiting) } postDequeue.Done() postDequeue.Wait() } postExecuteFunc := func() { finishExecute.Done() finishExecute.Wait() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
default: cacher.Lock() cacher.bookmarkWatchers.popExpiredWatchersThreadUnsafe() cacher.Unlock() } } }() // wait for adding/removing watchers to end wg.Wait() if watchErr != nil { t.Fatal(watchErr) } // wait out the expiration period and pop expired watchers time.Sleep(2 * time.Second) cacher.Lock() defer cacher.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
} /** * Marks the given step final, waits for it to be finished, and returns the value. * * @throws ExecutionException if the step failed * @throws CancellationException if the step was cancelled */ abstract <T> T getFinalValue(ClosingFuture<T> closingFuture) throws ExecutionException; /** Marks the given step final, cancels it, and waits for the cancellation to happen. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
src/net/dnsclient_unix_test.go
A: TestAddr, }, }, } } return r, nil }} // Issue 13705: don't try to resolve onion addresses, etc func TestLookupTorOnion(t *testing.T) { defer dnsWaitGroup.Wait() r := Resolver{PreferGo: true, Dial: fakeDNSServerSuccessful.DialContext} addrs, err := r.LookupIPAddr(context.Background(), "foo.onion.") if err != nil { t.Fatalf("lookup = %v; want nil", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 72.4K bytes - Viewed (0) -
src/net/http/transport.go
// ResponseHeaderTimeout, if non-zero, specifies the amount of // time to wait for a server's response headers after fully // writing the request (including its body, if any). This // time does not include the time to read the response body. ResponseHeaderTimeout time.Duration // ExpectContinueTimeout, if non-zero, specifies the amount of // time to wait for a server's first response headers after fully
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
// No error; requeue at the regular resync interval. p.workQueue.Enqueue(podUID, wait.Jitter(p.resyncInterval, workerResyncIntervalJitterFactor)) case strings.Contains(syncErr.Error(), NetworkNotReadyErrorMsg): // Network is not ready; back off for short period of time and retry as network might be ready soon. p.workQueue.Enqueue(podUID, wait.Jitter(backOffOnTransientErrorPeriod, workerBackOffPeriodJitterFactor)) default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
src/cmd/link/internal/ld/dwarf.go
}) // waitq<T> dwws := d.mkinternaltype(ctxt, dwarf.DW_ABRV_STRUCTTYPE, "waitq", elemname, "", func(dww *dwarf.DWDie) { d.copychildren(ctxt, dww, waitq) d.substitutetype(dww, "first", d.defptrto(dwss)) d.substitutetype(dww, "last", d.defptrto(dwss)) newattr(dww, dwarf.DW_AT_byte_size, dwarf.DW_CLS_CONSTANT, getattr(waitq, dwarf.DW_AT_byte_size).Value, nil) })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 16:25:18 UTC 2024 - 72.4K bytes - Viewed (0) -
src/runtime/mgc.go
// // 1. In sweep termination, mark, or mark termination of cycle // N, wait until mark termination N completes and transitions // to sweep N. // // 2. In sweep N, help with sweep N. // // At this point we can begin a full cycle N+1. // // 3. Trigger cycle N+1 by starting sweep termination N+1. // // 4. Wait for mark termination N+1 to complete. // // 5. Help with sweep N+1 until it's done.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher_test.go
ticker := time.NewTicker(10 * time.Millisecond) var attach *storage.VolumeAttachment var err error defer ticker.Stop() // wait for attachment to be saved for i := 0; i < 100; i++ { attach, err = client.StorageV1().VolumeAttachments().Get(context.TODO(), attachID, metav1.GetOptions{}) if err != nil { attach = nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
cmd/batch-handlers.go
// persist in-memory state to disk after every 10secs. batchLogIf(ctx, ri.updateAfter(ctx, api, 10*time.Second, job)) if wait := globalBatchConfig.ReplicationWait(); wait > 0 { time.Sleep(wait) } }() } wk.Wait() ri.RetryAttempts = attempts ri.Complete = ri.ObjectsFailed == 0 ri.Failed = ri.ObjectsFailed > 0 globalBatchJobsMetrics.save(job.ID, ri)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0)