- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 687 for marking (0.14 sec)
-
pilot/pkg/xds/discovery.go
var processStartTime = time.Now() // CachesSynced is called when caches have been synced so that server can accept connections. func (s *DiscoveryServer) CachesSynced() { log.Infof("All caches have been synced up in %v, marking server ready", time.Since(s.DiscoveryStartTime)) s.serverReady.Store(true) } func (s *DiscoveryServer) IsServerReady() bool { return s.serverReady.Load() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/CompactHashSet.java
* add(x)} operations <i>do not</i> create objects for the garbage collector to deal with, and for * every element added, the garbage collector will have to traverse {@code 1.5} references on * average, in the marking phase, not {@code 5.0} as in {@code java.util.HashSet}. * * <p>If there are no removals, then {@link #iterator iteration} order is the same as insertion * order. Any removal invalidates any ordering guarantees. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 18:11:09 UTC 2024 - 24K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
var globalPDPath string mounter := plugin.host.GetMounter(plugin.GetPluginName()) // Try really hard to get the global mount of the volume, an error returned from here would // leave the global mount still mounted, while marking the volume as unused. // The volume can then be mounted on several nodes, resulting in volume // corruption. paths, err := ioutil.GetReliableMountRefs(mounter, mountPath) if io.IsInconsistentReadError(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0) -
guava/src/com/google/common/collect/CompactHashSet.java
* add(x)} operations <i>do not</i> create objects for the garbage collector to deal with, and for * every element added, the garbage collector will have to traverse {@code 1.5} references on * average, in the marking phase, not {@code 5.0} as in {@code java.util.HashSet}. * * <p>If there are no removals, then {@link #iterator iteration} order is the same as insertion * order. Any removal invalidates any ordering guarantees. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 18:11:09 UTC 2024 - 24.9K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
nc.nodesToRetry.Store(node.Name, struct{}{}) return } } } nc.nodesToRetry.Delete(node.Name) } // Marking the pods not ready on a node requires looping over them and // updating each pod's status one at a time. This is performed serially, and // can take a while if we're processing each node serially as well. So we
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
common-protos/k8s.io/api/batch/v1/generated.proto
// Specifies the number of retries before marking this job failed. // Defaults to 6 // +optional optional int32 backoffLimit = 7; // A label query over pods that should match the pod count. // Normally, the system sets this field for you. // More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors // +optional
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 21.1K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/authoring-builds/tasks/custom_tasks.adoc
Passing property values on the command line is particularly helpful if they change more frequently. The task API supports a mechanism for marking a property to automatically generate a corresponding command line parameter with a specific name at runtime. [[sec:declaring_task_option]] === Step 1. Declare a command-line option
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun Feb 25 15:21:05 UTC 2024 - 23.6K bytes - Viewed (0) -
src/path/filepath/path_test.go
// 3) capture errors, expect two. // mark respective subtrees manually markTree(tree.entries[1]) markTree(tree.entries[3]) // correct double-marking of directory itself tree.entries[1].mark -= errVisit tree.entries[3].mark -= errVisit err := walk(tree.name, markFn) if err != nil { t.Fatalf("expected no error return from Walk, got %s", err) } if len(errors) != 2 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 22 16:38:19 UTC 2024 - 47.1K bytes - Viewed (0) -
src/runtime/runtime2.go
// but on the contention path they sleep in the kernel. // A zeroed Mutex is unlocked (no need to initialize each lock). // Initialization is helpful for static lock ranking, but not required. type mutex struct { // Empty struct if lock ranking is disabled, otherwise includes the lock rank lockRankStruct // Futex-based impl treats it as uint32 key, // while sema-based impl as M* waitm.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
Kind: "Pod", APIVersion: "v1", Namespace: "test", Name: "test", }, Reason: "TaintManagerEviction", Type: "Normal", Count: 1, Message: "Marking for deletion Pod test/test", Source: corev1.EventSource{Component: "nodeControllerTest"}, }, } if diff := cmp.Diff(want, recorder.Events, cmp.FilterPath(f, cmp.Ignore())); len(diff) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0)