Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 601 for syncAt (0.13 sec)

  1. src/os/user/lookup_unix_test.go

    root:x:0:0:root:/root:/bin/bash
    daemon:x:1:1:daemon:/usr/sbin:/usr/sbin/nologin
    bin:x:2:3:bin:/bin:/usr/sbin/nologin
         indented:x:3:3:indented:/dev:/usr/sbin/nologin
    sync:x:4:65534:sync:/bin:/bin/sync
    negative:x:-5:60:games:/usr/games:/usr/sbin/nologin
    man:x:6:12:man:/var/cache/man:/usr/sbin/nologin
    allfields:x:6:12:mansplit,man2,man3,man4:/home/allfields:/usr/sbin/nologin
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Nov 11 04:31:34 UTC 2022
    - 7.3K bytes
    - Viewed (0)
  2. pilot/pkg/config/kube/ingress/status.go

    	c.ingresses.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject))
    	// For any class change, sync all ingress; the handler will filter non-matching ones already
    	c.ingressClasses.AddEventHandler(controllers.ObjectHandler(func(o controllers.Object) {
    		// Just sync them all
    		c.enqueueAll()
    	}))
    	// For services, we queue all Ingress if its the ingress service
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  3. cmd/kube-controller-manager/app/options/endpointslicecontroller.go

    		errs = append(errs, fmt.Errorf("concurrent-service-endpoint-syncs must not be less than %d, but got %d", minConcurrentServiceEndpointSyncs, o.ConcurrentServiceEndpointSyncs))
    	} else if o.ConcurrentServiceEndpointSyncs > maxConcurrentServiceEndpointSyncs {
    		errs = append(errs, fmt.Errorf("concurrent-service-endpoint-syncs must not be more than %d, but got %d", maxConcurrentServiceEndpointSyncs, o.ConcurrentServiceEndpointSyncs))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 03 07:16:42 UTC 2020
    - 3.7K bytes
    - Viewed (0)
  4. src/runtime/race/testdata/waitgroup_test.go

    package race_test
    
    import (
    	"runtime"
    	"sync"
    	"testing"
    	"time"
    )
    
    func TestNoRaceWaitGroup(t *testing.T) {
    	var x int
    	_ = x
    	var wg sync.WaitGroup
    	n := 1
    	for i := 0; i < n; i++ {
    		wg.Add(1)
    		j := i
    		go func() {
    			x = j
    			wg.Done()
    		}()
    	}
    	wg.Wait()
    }
    
    func TestRaceWaitGroup(t *testing.T) {
    	var x int
    	_ = x
    	var wg sync.WaitGroup
    	n := 2
    	for i := 0; i < n; i++ {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Nov 03 22:09:38 UTC 2017
    - 5.3K bytes
    - Viewed (0)
  5. test/fixedbugs/issue27938.go

    // a qualified identifier with non-existing package.
    
    package p
    
    type _ struct {
    	F sync.Mutex // ERROR "undefined: sync|expected package|reference to undefined name"
    }
    
    type _ struct {
    	sync.Mutex // ERROR "undefined: sync|expected package|reference to undefined name"
    }
    
    type _ interface {
    	sync.Mutex // ERROR "undefined: sync|expected package|expected signature or type name|reference to undefined name"
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jul 06 00:02:11 UTC 2022
    - 696 bytes
    - Viewed (0)
  6. platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r22/CancellationCrossVersionSpec.groovy

            def sync = server.expectAndBlock("registered")
            def resultHandler = new TestResultHandler()
    
            when:
            withConnection { ProjectConnection connection ->
                def build = connection.newBuild()
                build.forTasks(':sub:broken')
                build.withCancellationToken(cancel.token())
                build.run(resultHandler)
                sync.waitForAllPendingCalls(resultHandler)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:20 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  7. api/go1.23.txt

    pkg sync/atomic, func OrInt64(*int64, int64) int64 #61395
    pkg sync/atomic, func OrUint32(*uint32, uint32) uint32 #61395
    pkg sync/atomic, func OrUint64(*uint64, uint64) uint64 #61395
    pkg sync/atomic, func OrUintptr(*uintptr, uintptr) uintptr #61395
    pkg sync/atomic, method (*Int32) And(int32) int32 #61395
    pkg sync/atomic, method (*Int32) Or(int32) int32 #61395
    pkg sync/atomic, method (*Int64) And(int64) int64 #61395
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 05 20:48:49 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. pkg/controller/deployment/progress.go

    		}
    	}
    	return conditions
    }
    
    // used for unit testing
    var nowFn = func() time.Time { return time.Now() }
    
    // requeueStuckDeployment checks whether the provided deployment needs to be synced for a progress
    // check. It returns the time after the deployment will be requeued for the progress check, 0 if it
    // will be requeued now, or -1 if it does not need to be requeued.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 13 11:00:44 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  9. pkg/proxy/ipvs/ipset_test.go

    		expectedEntries []string
    	}{
    		{
    			name: "normal ipset sync",
    			set: &utilipset.IPSet{
    				Name: "foo",
    			},
    			setType:         utilipset.HashIPPort,
    			ipv6:            false,
    			activeEntries:   []string{"172.17.0.4,tcp:80"},
    			currentEntries:  nil,
    			expectedEntries: []string{"172.17.0.4,tcp:80"},
    		},
    		{
    			name: "ipset IPv6 sync with no new entries",
    			set: &utilipset.IPSet{
    				Name: "abz",
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  10. test/assign.go

    // Does not compile.
    
    package main
    
    import "sync"
    
    type T struct {
    	int
    	sync.Mutex
    }
    
    func main() {
    	{
    		var x, y sync.Mutex
    		x = y // ok
    		_ = x
    	}
    	{
    		var x, y T
    		x = y // ok
    		_ = x
    	}
    	{
    		var x, y [2]sync.Mutex
    		x = y // ok
    		_ = x
    	}
    	{
    		var x, y [2]T
    		x = y // ok
    		_ = x
    	}
    	{
    		x := sync.Mutex{0, 0} // ERROR "assignment.*Mutex"
    		_ = x
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Dec 14 20:13:36 UTC 2020
    - 1K bytes
    - Viewed (0)
Back to top