- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 84 for logic (0.05 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go
// resource, handling details like conflict detection with ResourceVersion and // semantics. The RESTCreateStrategy, RESTUpdateStrategy, and // RESTDeleteStrategy are generic across all backends, and encapsulate logic // specific to the API. // // TODO: make the default exposed methods exactly match a generic RESTStorage type Store struct { // NewFunc returns a new instance of the type this registry returns for a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 23:22:44 UTC 2024 - 60.8K bytes - Viewed (0) -
cmd/xl-storage_test.go
if err != testCase.err { t.Fatalf("TestXLStorage %d failed wanted: %s, got: %s", i+1, err, testCase.err) } } } // TestXLStorageMakeVol - TestXLStorage validate the logic for creation of new xlStorage volume. // Asserts the failures too against the expected failures. func TestXLStorageMakeVol(t *testing.T) { // create xlStorage test setup xlStorage, path, err := newXLStorageTestSetup(t)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 11 17:45:28 UTC 2024 - 66.7K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug.go
if pred.ID == baseID { continue } state.logf("Merging in state from %v:\n%v", pred, state.blockEndStateString(blockLocs[pred.ID])) } } state.currentState.reset(abt.T{}) // The normal logic of "reset" is included in the intersection loop below. slotLocs := state.currentState.slots // If this is the first call, do updates on the "baseState"; if this
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 58.4K bytes - Viewed (0) -
src/runtime/mgc.go
// should self-preempt. It assumes it is called from the fractional // worker. func pollFractionalWorkerExit() bool { // This should be kept in sync with the fractional worker // scheduler logic in findRunnableGCWorker. now := nanotime() delta := now - gcController.markStartTime if delta <= 0 { return true } p := getg().m.p.ptr()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
staging/src/k8s.io/api/extensions/v1beta1/types.go
// A default backend capable of servicing requests that don't match any // rule. At least one of 'backend' or 'rules' must be specified. This field // is optional to allow the loadbalancer controller or defaulting logic to // specify a global default. // +optional Backend *IngressBackend `json:"backend,omitempty" protobuf:"bytes,1,opt,name=backend"` // TLS configuration. Currently the Ingress only supports a single TLS
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 27 20:06:29 UTC 2023 - 61.3K bytes - Viewed (0) -
src/go/printer/nodes.go
// (because p.linebreak is called with the position of d, which // is past any documentation, the minimum requirement is satisfied // even w/o the extra getDoc(d) nil-check - leave it in case the // linebreak logic improves - there's already a TODO). if len(p.output) > 0 { // only print line break if we are not at the beginning of the output // (i.e., we are not printing only a partial program) min := 1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 17 18:53:17 UTC 2023 - 52.6K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
Delete(pod *v1.Pod) error // TODO(sanposhiho): move all PreEnqueueCkeck to Requeue and delete it from this parameter eventually. // Some PreEnqueueCheck include event filtering logic based on some in-tree plugins // and it affect badly to other plugins. // See https://github.com/kubernetes/kubernetes/issues/110175
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
tensorflow/compiler/jit/mark_for_compilation_pass.cc
// This function removes "obviously bad" cases like these. Status DeclusterNodes(); // Manifests the clustering decisions into the TF graph by tagging nodes with // an `_XlaCluster` attribute. Also some basic filter logic, like // tf_xla_min_cluster_size, are applied here. Status CreateClusters(); Status DumpDebugInfo(); bool IsCompilationCandidate(Node* n) const {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 12:19:41 UTC 2024 - 85.3K bytes - Viewed (0) -
src/encoding/json/decode_test.go
// this returns an error because unmarshal cannot set the field. // // (Issue 24152) If the embedded struct is given an explicit name, // ensure that the normal unmarshal logic does not panic in reflect. // // (Issue 28145) If the embedded struct is given an explicit name and has // exported methods, don't cause a panic trying to get its value. func TestUnmarshalEmbeddedUnexported(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 11 16:40:14 UTC 2024 - 67.6K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
routeName string expected map[string][]string expectedGateway map[string][]string oldestWins bool }{ // Port 80 has special cases as there is defaulting logic around this port { name: "simple port 80", cfg: []Configer{vsArgs{ Namespace: "default", Match: "known.default.svc.cluster.local", Dest: "alt-known.default.svc.cluster.local",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0)