Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for syncAt (0.12 sec)

  1. pkg/kubelet/pod_workers_test.go

    	}
    	if !podWorkers.CouldHaveRunningContainers(types.UID("abc")) {
    		t.Errorf("Expected pod to potentially have running containers (does not exist but not yet synced)")
    	}
    	if podWorkers.ShouldPodContentBeRemoved(types.UID("abc")) {
    		t.Errorf("Expected pod to not be suitable for removal (does not exist but not yet synced)")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  2. cmd/kube-controller-manager/app/options/options_test.go

    	"--concurrent-deployment-syncs=10",
    	"--concurrent-horizontal-pod-autoscaler-syncs=10",
    	"--concurrent-statefulset-syncs=15",
    	"--concurrent-endpoint-syncs=10",
    	"--concurrent-ephemeralvolume-syncs=10",
    	"--concurrent-service-endpoint-syncs=10",
    	"--concurrent-gc-syncs=30",
    	"--concurrent-namespace-syncs=20",
    	"--concurrent-job-syncs=10",
    	"--concurrent-cron-job-syncs=10",
    	"--concurrent-replicaset-syncs=10",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 02:59:09 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  3. pkg/proxy/nftables/proxier.go

    	// services that happened since nftables was synced. For a single object,
    	// changes are accumulated, i.e. previous is state from before all of them,
    	// current is state after applying all of those.
    	endpointsChanges *proxy.EndpointsChangeTracker
    	serviceChanges   *proxy.ServiceChangeTracker
    
    	mu           sync.Mutex // protects the following fields
    	svcPortMap   proxy.ServicePortMap
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  4. pkg/controller/job/job_controller.go

    	syncHandler         func(ctx context.Context, jobKey string) error
    	// podStoreSynced returns true if the pod store has been synced at least once.
    	// Added as a member to the struct to allow injection for testing.
    	podStoreSynced cache.InformerSynced
    	// jobStoreSynced returns true if the job store has been synced at least once.
    	// Added as a member to the struct to allow injection for testing.
    	jobStoreSynced cache.InformerSynced
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  5. src/runtime/pprof/pprof_test.go

    `},
    		{
    			name: "mutex",
    			f:    blockMutex,
    			stk: []string{
    				"sync.(*Mutex).Lock",
    				"runtime/pprof.blockMutex",
    				"runtime/pprof.TestBlockProfile",
    			},
    			re: `
    [0-9]+ [0-9]+ @( 0x[[:xdigit:]]+)+
    #	0x[0-9a-f]+	sync\.\(\*Mutex\)\.Lock\+0x[0-9a-f]+	.*sync/mutex\.go:[0-9]+
    #	0x[0-9a-f]+	runtime/pprof\.blockMutex\+0x[0-9a-f]+	.*runtime/pprof/pprof_test.go:[0-9]+
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 68.8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    	// Important: Since HighWaterMark is using sync/atomic, it has to be at the top of the struct due to a bug on 32-bit platforms
    	// See: https://golang.org/pkg/sync/atomic/ for more information
    	incomingHWM storage.HighWaterMark
    	// Incoming events that should be dispatched to watchers.
    	incoming chan watchCacheEvent
    
    	resourcePrefix string
    
    	sync.RWMutex
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  7. pkg/proxy/iptables/proxier.go

    		// been flushed. In both of those cases, the code will force a full sync.
    		// In all other cases, it ought to be safe to assume that the rules
    		// already exist, so we'll skip this step when doing a partial sync, to
    		// save us from having to invoke /sbin/iptables 20 times on each sync
    		// (which will be very slow on hosts with lots of iptables rules).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  8. pkg/controller/endpointslice/endpointslice_controller_test.go

    			informerGenerationNumber: 10,
    			trackerGenerationNumber:  12,
    			expectError:              true,
    		},
    		{
    			name:                     "cache and tracker synced",
    			informerGenerationNumber: 10,
    			trackerGenerationNumber:  10,
    			expectError:              false,
    		},
    		{
    			name:                     "tracker outdated",
    			informerGenerationNumber: 10,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  9. src/cmd/compile/internal/ppc64/ssa.go

    		ssa.OpPPC64LoweredAtomicStore64:
    		// SYNC or LWSYNC
    		// MOVB/MOVW/MOVD arg1,(arg0)
    		st := ppc64.AMOVD
    		switch v.Op {
    		case ssa.OpPPC64LoweredAtomicStore8:
    			st = ppc64.AMOVB
    		case ssa.OpPPC64LoweredAtomicStore32:
    			st = ppc64.AMOVW
    		}
    		arg0 := v.Args[0].Reg()
    		arg1 := v.Args[1].Reg()
    		// If AuxInt == 0, LWSYNC (Store-Release), else SYNC
    		// SYNC
    		syncOp := ppc64.ASYNC
    		if v.AuxInt == 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 19:59:38 UTC 2024
    - 55.4K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config_test.go

    				service:      service,
    				l:            &sync.Mutex{},
    				lastResponse: &kmsPluginHealthzResponse{},
    			},
    			wantTTL: kmsPluginHealthzPositiveTTL,
    		},
    		{
    			desc: "kms provider in bad state",
    			probe: &kmsPluginProbe{
    				name:         "test",
    				ttl:          kmsPluginHealthzPositiveTTL,
    				service:      errService,
    				l:            &sync.Mutex{},
    				lastResponse: &kmsPluginHealthzResponse{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 16:56:39 UTC 2024
    - 72.3K bytes
    - Viewed (0)
Back to top