Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 168 for withers (0.22 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top