- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for syncAt (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)