Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 1,199 for syncAt (0.11 sec)

  1. api/openapi-spec/v3/apis__coordination.k8s.io__v1_openapi.json

    NotOlderThan\n  is interpreted as \"data at least as new as the provided `resourceVersion`\"\n  and the bookmark event is send when the state is synced\n  to a `resourceVersion` at least as fresh as the one provided by the ListOptions.\n  If `resourceVersion` is unset, this is interpreted as \"consistent read\" and the\n  bookmark event is send when the state is synced at least to the moment\n  when request started being processed.\n- `resourceVersionMatch` set to any other value or unset\n  Invalid error...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 136.6K bytes
    - Viewed (0)
  2. 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)
  3. cmd/site-replication.go

    				})
    				if err != nil {
    					return errSRBucketMetaError(err)
    				}
    			}
    		}
    	}
    
    	// Order matters from now on how the information is
    	// synced to remote sites.
    
    	// Policies should be synced first.
    	{
    		// Replicate IAM policies on local to all peers.
    		allPolicyDocs, err := globalIAMSys.ListPolicyDocs(ctx, "")
    		if err != nil {
    			return errSRBackendIssue(err)
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 184.3K bytes
    - Viewed (0)
  4. 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)
  5. pkg/controller/daemon/daemon_controller.go

    	// dsStoreSynced returns true if the daemonset store has been synced at least once.
    	// Added as a member to the struct to allow injection for testing.
    	dsStoreSynced cache.InformerSynced
    	// historyLister get list/get history from the shared informers's store
    	historyLister appslisters.ControllerRevisionLister
    	// historyStoreSynced returns true if the history store has been synced at least once.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  6. 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)
  7. pkg/kube/util.go

    		// * Cluster.CertificateAuthority. While this reads from files, the result is not attached to the request and is instead
    		//   entirely local
    	}
    	return nil
    }
    
    type Syncer interface {
    	HasSynced() bool
    }
    
    func AllSynced[T Syncer](syncers []T) bool {
    	for _, h := range syncers {
    		if !h.HasSynced() {
    			return false
    		}
    	}
    	return true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  8. 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)
  9. api/openapi-spec/v3/apis__networking.k8s.io__v1alpha1_openapi.json

    NotOlderThan\n  is interpreted as \"data at least as new as the provided `resourceVersion`\"\n  and the bookmark event is send when the state is synced\n  to a `resourceVersion` at least as fresh as the one provided by the ListOptions.\n  If `resourceVersion` is unset, this is interpreted as \"consistent read\" and the\n  bookmark event is send when the state is synced at least to the moment\n  when request started being processed.\n- `resourceVersionMatch` set to any other value or unset\n  Invalid error...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 196.5K bytes
    - Viewed (0)
  10. 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)
Back to top