- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,013 for _Gwaiting (0.17 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/wait/poll.go
// will be invoked immediately. When using very short intervals, condition may be invoked multiple // times before a context cancellation is detected. If immediate is true, condition will be // invoked before waiting and guarantees that condition is invoked at least once, regardless of // whether the context has been cancelled.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 26 06:13:35 UTC 2023 - 14K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection_test.go
raw := spdyConn.(*connection).conn if err := raw.Wait(15 * time.Second); err != nil { t.Fatalf("client: timed out waiting for connection closure: %v", err) } expired := time.NewTimer(15 * time.Second) defer expired.Stop() i := 0 for { select { case <-expired.C: t.Fatalf("timed out waiting for proxy and/or server closure") case <-serverDone: i++ case <-proxyDone: i++ }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 01 11:58:57 UTC 2023 - 7.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SendPartialResponseThenBlock.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
releasenotes/notes/48882.yaml
apiVersion: release-notes/v2 kind: bug-fix area: telemetry releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 216 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/ready_test.go
package cacher import ( "context" "sync" "testing" "time" ) func Test_newReady(t *testing.T) { errCh := make(chan error, 10) ready := newReady() ready.set(false) // create 10 goroutines waiting for ready for i := 0; i < 10; i++ { go func() { errCh <- ready.wait(context.Background()) }() } select { case <-time.After(1 * time.Second): case <-errCh: t.Errorf("ready should be blocking")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 16 13:32:11 UTC 2023 - 4.6K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/UserInputReceiver.java
* Does not block waiting for the input. */ void readAndForwardText(Normalizer normalizer); /** * Requests that bytes should be read from this process' stdin and forwarded to the daemon. * Does not block waiting for the input. */ void readAndForwardStdin(); interface Normalizer { /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 30 05:03:08 UTC 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/AutobahnTester.kt
response: Response?, ) { t.printStackTrace(System.out) latch.countDown() } }, ) check(latch.await(30, TimeUnit.SECONDS)) { "Timed out waiting for test $number to finish." } val endNanos = System.nanoTime() val tookMs = TimeUnit.NANOSECONDS.toMillis(endNanos - startNanos.get()) println("Took ${tookMs}ms") }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.6K bytes - Viewed (0) -
src/internal/trace/summary.go
s.gs[g.ID] = g case GoRunning: // Record execution time as we transition out of running g.ExecTime += ev.Time().Sub(g.lastStartTime) g.lastStartTime = 0 case GoWaiting: // Record block time as we transition out of waiting. if g.lastBlockTime != 0 { g.BlockTimeByReason[g.lastBlockReason] += ev.Time().Sub(g.lastBlockTime) g.lastBlockTime = 0 } case GoRunnable:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 20.7K bytes - Viewed (0) -
security/pkg/util/certutil.go
package util import ( "fmt" "time" "istio.io/istio/security/pkg/pki/util" ) // CertUtil is an interface for utility functions on certificate. type CertUtil interface { // GetWaitTime returns the waiting time before renewing the certificate. GetWaitTime([]byte, time.Time) (time.Duration, error) } // CertUtilImpl is the implementation of CertUtil, for production use. type CertUtilImpl struct { gracePeriodPercentage int
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 30 19:33:26 UTC 2023 - 2.3K bytes - Viewed (0) -
src/sync/runtime.go
// the reason for waiting in a backtrace, and is used to compute some metrics. // Otherwise they're functionally identical. func runtime_SemacquireMutex(s *uint32, lifo bool, skipframes int) func runtime_SemacquireRWMutexR(s *uint32, lifo bool, skipframes int) func runtime_SemacquireRWMutex(s *uint32, lifo bool, skipframes int) // Semrelease atomically increments *s and notifies a waiting goroutine // if one is blocked in Semacquire.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 16 16:32:27 UTC 2022 - 2.3K bytes - Viewed (0)