- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 212 for stopped_ (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
// The actual server loop (stoppable by closing stopCh) runs in a go routine, i.e. Serve does not block. // It returns a stoppedCh that is closed when all non-hijacked active requests have been processed. // It returns a listenerStoppedCh that is closed when the underlying http Server has stopped listening.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/test/groovy/org/gradle/internal/concurrent/DefaultExecutorFactoryTest.groovy
executor.execute(action1) executor.execute(action2) executor.stop() instant.stopped } then: instant.stopped > instant.completed1 instant.stopped > instant.completed2 } def factoryStopBlocksUntilAllJobsAreComplete() { given: def action1 = { thread.block()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 11.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
switch { case errors.Is(rebalErr, context.Canceled): status = rebalStopped traceMsg = fmt.Sprintf("stopped at %s", now) case rebalErr == nil: status = rebalCompleted traceMsg = fmt.Sprintf("completed at %s", now) default: status = rebalFailed traceMsg = fmt.Sprintf("stopped at %s with err: %v", now, rebalErr) } z.rebalMu.Lock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:45:54 UTC 2024 - 27.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DaemonStateCoordinatorTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:24:02 UTC 2024 - 16.3K bytes - Viewed (0) -
src/runtime/lockrank_on.go
// //go:nosplit func worldStarted() { if stopped := worldIsStopped.Add(-1); stopped != 0 { systemstack(func() { print("world stop count=", stopped, "\n") throw("released non-stopped world stop") }) } } // nosplit to ensure it can be called in as many contexts as possible. // //go:nosplit func checkWorldStopped() bool { stopped := worldIsStopped.Load() if stopped > 1 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 10.6K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager.go
// to be retried. if !i.stopped && i.store.hasSynced() && now.After(i.lastAccessTime.Add(maxIdleTime)) { return i.stopThreadUnsafe() } return false } func (i *objectCacheItem) restartReflectorIfNeeded() { i.lock.Lock() defer i.lock.Unlock() if i.immutable || !i.stopped { return } i.stopCh = make(chan struct{}) i.stopped = false go i.startReflector() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
return f.proxy } func (f *fakeConn) ConnectedAt() time.Time { return f.connTime } func (f *fakeConn) Stop() { f.Lock() defer f.Unlock() f.stopped = true } func (f *fakeConn) Stopped() bool { f.RLock() defer f.RUnlock() return f.stopped } var ( tmplA = &v1alpha3.WorkloadGroup{ Template: &v1alpha3.WorkloadEntry{ Ports: map[string]uint32{"http": 80},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0) -
src/runtime/preempt.go
// state was observed, so the caller must not assume that it // remains dead. dead bool // stopped indicates that this suspendG transitioned the G to // _Gwaiting via g.preemptStop and thus is responsible for // readying it when done. stopped bool } // suspendG suspends goroutine gp at a safe-point and returns the // state of the suspended goroutine. The caller gets read access to
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 15.1K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/TaskTimeoutIntegrationTest.groovy
outputLines[1] == "Timed out task ':block' has not yet stopped." outputLines[outputLines.size() - 1] == "Timed out task ':block' has stopped." and: def logging = taskLogging(":block") logging[0] == "Requesting stop of task ':block' as it has exceeded its configured timeout of 500ms." logging[1] == "Timed out task ':block' has not yet stopped."
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 03 15:21:23 UTC 2024 - 12.6K bytes - Viewed (0)