- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 143 for syncs (0.05 sec)
-
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) -
tensorflow/c/experimental/filesystem/filesystem_interface.h
/// Flushes `*file` and syncs contents to filesystem. /// /// This call might not block, and when it returns the contents might not have /// been fully persisted. /// /// DEFAULT IMPLEMENTATION: No op. void (*flush)(const TF_WritableFile* file, TF_Status* status); /// Syncs contents of `*file` with the filesystem. ///
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 27 17:36:54 UTC 2022 - 53.1K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
serviceChanges *proxy.ServiceChangeTracker mu sync.Mutex // protects the following fields svcPortMap proxy.ServicePortMap endpointsMap proxy.EndpointsMap nodeLabels map[string]string // initialSync is a bool indicating if the proxier is syncing for the first time. // It is set to true when a new proxier is initialized and then set to false on all // future syncs.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
proxier.mu.Lock() defer proxier.mu.Unlock() // don't sync rules till we've received services and endpoints if !proxier.isInitialized() { klog.V(2).InfoS("Not syncing hns until Services and Endpoints have been received from master") return } // Keep track of how long syncs take. start := time.Now() defer func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
func TestApfExecuteMultipleRequests(t *testing.T) { concurrentRequests := 5 preStartExecute, postStartExecute := &sync.WaitGroup{}, &sync.WaitGroup{} preEnqueue, postEnqueue := &sync.WaitGroup{}, &sync.WaitGroup{} preDequeue, postDequeue := &sync.WaitGroup{}, &sync.WaitGroup{} finishExecute := &sync.WaitGroup{} for _, wg := range []*sync.WaitGroup{preStartExecute, postStartExecute, preEnqueue, postEnqueue, preDequeue, postDequeue, finishExecute} {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
defer proxier.mu.Unlock() // don't sync rules till we've received services and endpoints if !proxier.isInitialized() { proxier.logger.V(2).Info("Not syncing nftables until Services and Endpoints have been received from master") return } // // Below this point we will not return until we try to write the nftables rules. // // Keep track of how long syncs take. start := time.Now() defer func() {
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/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/kubelet/pod_workers_test.go
) // fakePodWorkers runs sync pod function in serial, so we can have // deterministic behaviour in testing. type fakePodWorkers struct { lock sync.Mutex syncPodFn syncPodFnType cache kubecontainer.Cache t TestingInterface triggeredDeletion []types.UID triggeredTerminal []types.UID statusLock sync.Mutex running map[types.UID]bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
Static bool } // podWork is the internal changes type podWork struct { // WorkType is the type of sync to perform - sync (create), terminating (stop // containers), terminated (clean up and write status). WorkType PodWorkerState // Options contains the data to sync. Options UpdatePodOptions } // PodWorkers is an abstract interface for testability. type PodWorkers interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
// To prevent the restartable init containers to keep pod alive, we should // not restart them. changes.InitContainersToStart = nil } } return changes } // SyncPod syncs the running pod into the desired pod by executing following steps: // // 1. Compute sandbox and container changes. // 2. Kill pod sandbox if necessary. // 3. Kill any containers that should not be running.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0)