- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 168 for withers (0.22 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/eventclock/fake.go
// events to run at that or an earlier time. // Events should not advance the clock. But just in case they do... now := fec.Now() for len(fec.waiters) > 0 && !now.Before(fec.waiters[0].targetTime) { ew := heap.Pop(&fec.waiters).(eventWaiter) fec.clientWG.Add(1) go func(f eventclock.EventFunc, now time.Time) { f(now) fec.clientWG.Add(-1) }(ew.f, now) foundSome = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 7.9K bytes - Viewed (0) -
src/sync/waitgroup.go
} // This goroutine has set counter to 0 when waiters > 0. // Now there can't be concurrent mutations of state: // - Adds must not happen concurrently with Wait, // - Wait does not increment waiters if it sees counter == 0. // Still do a cheap sanity check to detect WaitGroup misuse. if wg.state.Load() != state { panic("sync: WaitGroup misuse: Add called concurrently with Wait") } // Reset waiters count to 0. wg.state.Store(0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/testing/testing.go
if _, exists := r.watchers[gvr]; !exists { r.watchers[gvr] = make(map[string][]*watch.RaceFreeFakeWatcher) } r.watchers[gvr][ns] = append(r.watchers[gvr][ns], fakewatcher) return fakewatcher, nil } func (r *VolumeReactor) getWatches(gvr schema.GroupVersionResource, ns string) []*watch.RaceFreeFakeWatcher { watches := []*watch.RaceFreeFakeWatcher{} if r.watchers[gvr] != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 20.1K bytes - Viewed (0) -
Jenkinsfile.its
} parameters { string( defaultValue: 'master', description: 'Core Its branch (default master)', name: 'ITS_BRANCH' ) } stages { stage("Build Maven Core") { steps { withEnv(["JAVA_HOME=${ tool "JDK 1.8 (latest)" }", "PATH+MAVEN=${tool 'Maven 3.6.3'}/bin:${env.JAVA_HOME}/bin"]) { sh "mvn -Drat.skip=true -T2 -B -V install -PversionlessMavenDist -Dmaven.repo.local=${env.WORKSPACE}/repo" }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sun Dec 26 16:42:35 UTC 2021 - 2.3K bytes - Viewed (0) -
internal/fips/api.go
} } // TLSCiphersBackwardCompatible returns a list of supported // TLS transport cipher suite IDs. // // In contrast to TLSCiphers, the list contains additional // ciphers for backward compatibility. In particular, AES-CBC // and non-ECDHE ciphers. func TLSCiphersBackwardCompatible() []uint16 { if Enabled { return []uint16{ tls.TLS_AES_128_GCM_SHA256, // TLS 1.3 tls.TLS_AES_256_GCM_SHA384,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Dec 30 19:37:07 UTC 2022 - 5.1K bytes - Viewed (0) -
test/chan/select6.go
// Test for select: Issue 2075 // A bug in select corrupts channel queues of failed cases // if there are multiple waiters on those channels and the // select is the last in the queue. If further waits are made // on the channel without draining it first then those waiters // will never wake up. In the code below c1 is such a channel. package main func main() { c1 := make(chan bool) c2 := make(chan bool)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 783 bytes - Viewed (0) -
platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/AbstractFileWatcherUpdaterTest.groovy
/** * Returns 1 for non-hierarchical watchers, and 0 for hierarchical watchers. * * For use in interaction tests, when an interaction only happens for non-hierarchical watchers. * E.g.: * ifNonHierarchical * watcher.startWatching(_) */ abstract int getIfNonHierarchical() /** * Returns 1 for hierarchical watchers, and 0 for non-hierarchical watchers. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 21.5K bytes - Viewed (0) -
src/sync/mutex.go
// // If a waiter receives ownership of the mutex and sees that either // (1) it is the last waiter in the queue, or (2) it waited for less than 1 ms, // it switches mutex back to normal operation mode. // // Normal mode has considerably better performance as a goroutine can acquire // a mutex several times in a row even if there are blocked waiters. // Starvation mode is important to prevent pathological cases of tail latency.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
} return old; } } /** Performs a GAS operation on the {@link #waiters} field. */ @Override Waiter gasWaiters(AbstractFuture<?> future, Waiter update) { synchronized (future) { Waiter old = future.waiters; if (old != update) { future.waiters = update; } return old; } } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
src/internal/poll/fd_mutex.go
// 1 bit - lock for read operations. // 1 bit - lock for write operations. // 20 bits - total number of references (read+write+misc). // 20 bits - number of outstanding read waiters. // 20 bits - number of outstanding write waiters. const ( mutexClosed = 1 << 0 mutexRLock = 1 << 1 mutexWLock = 1 << 2 mutexRef = 1 << 3 mutexRefMask = (1<<20 - 1) << 3 mutexRWait = 1 << 23
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 20 16:55:30 UTC 2018 - 6.4K bytes - Viewed (0)