- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 2,460 for syncs (0.05 sec)
-
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/controller/garbagecollector/garbagecollector.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.4.md
* Provide kubernetes-controller-manager flags to control volume attach/detach reconciler sync. The duration of the syncs can be controlled, and the syncs can be shut off as well. ([#39551](https://github.com/kubernetes/kubernetes/pull/39551), [@chrislovecnm](https://github.com/chrislovecnm))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 133.5K 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/controller/replicaset/replica_set.go
// replica set when Spec changes, but it is safer to sync any // time this function is triggered. That way a full informer // resync can requeue any replica set that don't yet have pods // but whose last attempts at creating a pod have failed (since // we don't block on creation of pods) instead of those // replica sets stalling indefinitely. Enqueueing every time // does result in some spurious syncs (like when Status.Replica
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/kubelet/container/runtime.go
// will be GC'd. // TODO: Revisit this method and make it cleaner. GarbageCollect(ctx context.Context, gcPolicy GCPolicy, allSourcesReady bool, evictNonDeletedPods bool) error // SyncPod syncs the running pod into the desired pod. SyncPod(ctx context.Context, pod *v1.Pod, podStatus *PodStatus, pullSecrets []v1.Secret, backOff *flowcontrol.Backoff) PodSyncResult
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 27.8K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.5.md
* Provide kubernetes-controller-manager flags to control volume attach/detach reconciler sync. The duration of the syncs can be controlled, and the syncs can be shut off as well. ([#39551](https://github.com/kubernetes/kubernetes/pull/39551), [@chrislovecnm](https://github.com/chrislovecnm))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 136.4K bytes - Viewed (1) -
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) -
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) -
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)