- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 27 for waitc (0.12 sec)
-
pkg/controller/podautoscaler/horizontal_test.go
m.metricComputationErrorLabels[metricType] = append(m.metricComputationErrorLabels[metricType], err) } // waitUntilRecorded waits for the HPA controller to reconcile at least once. func (m *mockMonitor) waitUntilRecorded(t *testing.T) { if err := wait.Poll(20*time.Millisecond, 100*time.Millisecond, func() (done bool, err error) { m.RWMutex.RLock() defer m.RWMutex.RUnlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 199.3K bytes - Viewed (0) -
cmd/admin-handlers.go
if ok { continue } client := client ng.Go(ctx, func() error { return client.CommitBinary(ctx) }, idx, *client.host) } for _, nerr := range ng.Wait() { if nerr.Err != nil { prs, ok := peerResults[nerr.Host.String()] if ok { prs.Err = nerr.Err.Error() peerResults[nerr.Host.String()] = prs } else {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
src/database/sql/sql.go
func (db *DB) Stats() DBStats { wait := db.waitDuration.Load() db.mu.Lock() defer db.mu.Unlock() stats := DBStats{ MaxOpenConnections: db.maxOpen, Idle: len(db.freeConn), OpenConnections: db.numOpen, InUse: db.numOpen - len(db.freeConn), WaitCount: db.waitCount, WaitDuration: time.Duration(wait), MaxIdleClosed: db.maxIdleClosed,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LocalCache.java
} } /** A reference to a value. */ interface ValueReference<K, V> { /** Returns the value. Does not block or throw exceptions. */ @CheckForNull V get(); /** * Waits for a value that may still be loading. Unlike get(), this method can block (in the case * of FutureValueReference). * * @throws ExecutionException if the loading thread throws an exception
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 143.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/util/intstr" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/uuid" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apiserver/pkg/storage/names" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" core "k8s.io/client-go/testing" "k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/record"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ArtifactTransformCachingIntegrationTest.groovy
def cleaningBarrier = blockingHttpServer.expectAndBlock("cleaning") def cleaningBuild = executer.withTasks("waitForCleaningBarrier").withArgument("--no-daemon").start() then: 'cleaning build starts and waits on its barrier' cleaningBarrier.waitForAllPendingCalls() when: 'transforming build is started' def transformBarrier = blockingHttpServer.expectAndBlock("transform")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 11:52:44 UTC 2024 - 97.8K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
} } /** A reference to a value. */ interface ValueReference<K, V> { /** Returns the value. Does not block or throw exceptions. */ @CheckForNull V get(); /** * Waits for a value that may still be loading. Unlike get(), this method can block (in the case * of FutureValueReference). * * @throws ExecutionException if the loading thread throws an exception
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 149.2K bytes - Viewed (0) -
src/internal/trace/testdata/tests/go122-gc-stress.test
String id=9 data="sync.(*Cond).Wait" String id=10 data="sync" String id=11 data="chan send" String id=12 data="chan receive" String id=13 data="GC mark assist wait for work" String id=14 data="GC background sweeper wait" String id=15 data="system goroutine wait" String id=16 data="preempted" String id=17 data="wait for debug call" String id=18
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 139.1K bytes - Viewed (0) -
src/net/http/serve_test.go
if err := cmd.Start(); err != nil { b.Fatalf("subprocess failed to start: %v", err) } done := make(chan error, 1) go func() { done <- cmd.Wait() close(done) }() defer func() { cancel() <-done }() // Wait for the server in the child process to respond and tell us // its listening address, once it's started listening: bs := bufio.NewScanner(stdout) if !bs.Scan() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
src/cmd/link/internal/ld/data.go
writeBlock(ctxt, out, ldr, syms, addr, length, pad) } // Prepare for the next loop. if idx != -1 { syms = syms[idx+1:] } written += length addr += length } wg.Wait() } func writeBlock(ctxt *Link, out *OutBuf, ldr *loader.Loader, syms []loader.Sym, addr, size int64, pad []byte) { st := ctxt.makeRelocSymState()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 12 15:10:50 UTC 2024 - 100.5K bytes - Viewed (0)