- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 1,013 for _Gwaiting (0.26 sec)
-
pilot/cmd/pilot-agent/app/wait.go
Timeout: time.Duration(requestTimeoutMillis) * time.Millisecond, } log.Infof("Waiting for Envoy proxy to be ready (timeout: %d seconds)...", timeoutSeconds) var err error timeout := time.After(time.Duration(timeoutSeconds) * time.Second) for { select { case <-timeout: return fmt.Errorf("timeout waiting for Envoy proxy to become ready. Last error: %v", err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/counter/interface.go
// Call Add(1) before forking a goroutine, Add(-1) at the end of that goroutine. // Call Add(-1) just before waiting on something from another goroutine (e.g., // just before a `select`). // Call Add(1) just before doing something that unblocks a goroutine that is // waiting on that something. Add(delta int)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 12 16:12:48 UTC 2019 - 1.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt
return failFastResponse!! } val result = responseQueue.take() // If take() returned because we're shutting down, then enqueue another dead letter so that any // other threads waiting on take() will also return. if (result == DEAD_LETTER) responseQueue.add(DEAD_LETTER) return result } override fun peek(): MockResponse {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 3K bytes - Viewed (0) -
cmd/prepare-storage.go
return format, nil } // Return error when quorum unformatted disks - indicating we are // waiting for first server to be online. unformattedDisks := quorumUnformattedDisks(sErrs) if unformattedDisks && !firstDisk { return nil, errNotFirstDisk } // Return error when quorum unformatted disks but waiting for rest // of the servers to be online. if unformattedDisks && firstDisk { return nil, errFirstDiskWait
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun May 19 08:06:49 UTC 2024 - 11.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
* * @throws InterruptedException if interrupted while waiting */ public void enterInterruptibly() throws InterruptedException { lock.lockInterruptibly(); } /** * Enters this monitor. Blocks at most the given time, and may be interrupted. * * @return whether the monitor was entered * @throws InterruptedException if interrupted while waiting */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 38.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/integTest/groovy/org/gradle/integtests/tooling/ToolingApiIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 13.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
assertThat(activeThreads).isEqualTo(0) } } /** Unblock a waiting task thread. Used by the test thread only. */ fun interruptCoordinatorThread() { taskRunner.assertThreadDoesntHoldLock() require(currentTask == TestThreadSerialTask) // Queue a task to interrupt the waiting coordinator. serialTaskQueue += object : SerialTask { override fun start() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/work/DefaultAsyncWorkTrackerTest.groovy
} then: def e = thrown(IllegalStateException) and: e.message == "Another thread is currently waiting on the completion of work for the provided operation" } def "can temporarily release a project lock while waiting on async work"() { def workerLease = Mock(WorkerLeaseRegistry.WorkerLease) def workerLeaseService = Mock(WorkerLeaseService)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 06 04:53:10 UTC 2023 - 14.9K bytes - Viewed (0) -
src/runtime/chan.go
// stack object, but sudogs aren't considered as roots of the // stack tracer. KeepAlive(ep) // someone woke us up. if mysg != gp.waiting { throw("G waiting list is corrupted") } gp.waiting = nil gp.activeStackChans = false closed := !mysg.success gp.param = nil if mysg.releasetime > 0 { blockevent(mysg.releasetime-t0, 2) } mysg.c = nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
cmd/kubeadm/app/util/initsystem/initsystem_windows.go
return nil } timeout := time.Now().Add(10 * time.Second) for status.State != svc.Stopped { if timeout.Before(time.Now()) { return errors.Errorf("timeout waiting for %s service to stop", service) } time.Sleep(300 * time.Millisecond) status, err = s.Query() if err != nil { return errors.Wrapf(err, "could not retrieve %s service status", service) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 08:56:16 UTC 2022 - 6.4K bytes - Viewed (0)