Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 288 for devnode (0.12 sec)

  1. staging/src/k8s.io/apimachinery/pkg/runtime/serializer/cbor/internal/modes/decode.go

    		ByteStringToTime: cbor.ByteStringToTimeAllowed,
    	}.DecMode()
    	if err != nil {
    		panic(err)
    	}
    	return decode
    }()
    
    // DecodeLax is derived from Decode, but does not complain about unknown fields in the input.
    var DecodeLax cbor.DecMode = func() cbor.DecMode {
    	opts := Decode.DecOptions()
    	opts.ExtraReturnErrors &^= cbor.ExtraDecErrorUnknownField // clear bit
    	dm, err := opts.DecMode()
    	if err != nil {
    		panic(err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 14:03:36 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. src/encoding/json/decode.go

    	rv := reflect.ValueOf(v)
    	if rv.Kind() != reflect.Pointer || rv.IsNil() {
    		return &InvalidUnmarshalError{reflect.TypeOf(v)}
    	}
    
    	d.scan.reset()
    	d.scanWhile(scanSkipSpace)
    	// We decode rv not rv.Elem because the Unmarshaler interface
    	// test must be applied at the top level of the value.
    	err := d.value(rv)
    	if err != nil {
    		return d.addErrorContext(err)
    	}
    	return d.savedError
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:18:55 UTC 2024
    - 35.3K bytes
    - Viewed (0)
  3. cmd/erasure-decode.go

    	}
    
    	// If we cannot decode, just return read quorum error.
    	return nil, fmt.Errorf("%w (offline-disks=%d/%d)", errErasureReadQuorum, disksNotFound, len(p.readers))
    }
    
    // Decode reads from readers, reconstructs data if needed and writes the data to the writer.
    // A set of preferred drives can be supplied. In that case they will be used and the data reconstructed.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 21 14:36:21 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. pkg/controller/tainteviction/taint_eviction_test.go

    			},
    			oldNode:      testutil.NewNode("node1"),
    			newNode:      addTaintsToNode(testutil.NewNode("node1"), "testTaint1", "taint1", []int{1}),
    			expectDelete: true,
    		},
    		{
    			description: "Added tolerated taint",
    			pods: []corev1.Pod{
    				*addToleration(testutil.NewPod("pod1", "node1"), 1, 100),
    			},
    			oldNode:      testutil.NewNode("node1"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 31.3K bytes
    - Viewed (0)
  5. pkg/scheduler/eventhandlers.go

    }
    
    func nodeLabelsChanged(newNode *v1.Node, oldNode *v1.Node) bool {
    	return !equality.Semantic.DeepEqual(oldNode.GetLabels(), newNode.GetLabels())
    }
    
    func nodeTaintsChanged(newNode *v1.Node, oldNode *v1.Node) bool {
    	return !equality.Semantic.DeepEqual(newNode.Spec.Taints, oldNode.Spec.Taints)
    }
    
    func nodeConditionsChanged(newNode *v1.Node, oldNode *v1.Node) bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:04 UTC 2024
    - 24K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/interpodaffinity/plugin_test.go

    		name             string
    		pod              *v1.Pod
    		oldNode, newNode *v1.Node
    		expectedHint     framework.QueueingHint
    	}{
    		{
    			name:         "add a new node with matched pod affinity topologyKey",
    			pod:          st.MakePod().Name("p").PodAffinityIn("service", "zone", []string{"securityscan", "value2"}, st.PodAffinityWithRequiredReq).Obj(),
    			newNode:      st.MakeNode().Name("node-a").Label("zone", "zone1").Obj(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 03:08:44 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  7. src/runtime/tracemap.go

    			// much activity, or the map gets big and races to insert on
    			// the same node are much less likely.
    			if newNode == nil {
    				newNode = tab.newTraceMapNode(data, size, hash, tab.seq.Add(1))
    			}
    			if m.CompareAndSwapNoWB(nil, unsafe.Pointer(newNode)) {
    				return newNode.id, true
    			}
    			// Reload n. Because pointers are only stored once,
    			// we must have lost the race, and therefore n is not nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 17:03:35 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  8. src/cmd/go/internal/work/action.go

    func (b *Builder) VetAction(mode, depMode BuildMode, p *load.Package) *Action {
    	a := b.vetAction(mode, depMode, p)
    	a.VetxOnly = false
    	return a
    }
    
    func (b *Builder) vetAction(mode, depMode BuildMode, p *load.Package) *Action {
    	// Construct vet action.
    	a := b.cacheAction("vet", p, func() *Action {
    		a1 := b.CompileAction(mode|ModeVetOnly, depMode, p)
    
    		// vet expects to be able to import "fmt".
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 15:39:17 UTC 2024
    - 32.7K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apimachinery/pkg/runtime/serializer/cbor/internal/modes/decode_test.go

    			name:  "case-insensitive match treated as unknown field",
    			modes: []cbor.DecMode{modes.Decode},
    			in:    hex("a1614101"), // {"A": 1}
    			into: struct {
    				A int `json:"a"`
    			}{},
    			assertOnError: assertIdenticalError(&cbor.UnknownFieldError{Index: 0}),
    		},
    		{
    			name:  "case-insensitive match ignored in lax mode",
    			modes: []cbor.DecMode{modes.DecodeLax},
    			in:    hex("a1614101"), // {"A": 1}
    			into: struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 18:43:10 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  10. src/cmd/go/internal/fsys/fsys.go

    		overlay[from] = &node{actualFilePath: to}
    
    		// Add parent directory nodes to overlay structure.
    		childNode := overlay[from]
    		for {
    			dirNode := overlay[dir]
    			if dirNode == nil || dirNode.isDeleted() {
    				dirNode = &node{children: make(map[string]*node)}
    				overlay[dir] = dirNode
    			}
    			if childNode.isDeleted() {
    				// Only create one parent for a deleted file:
    				// the directory only conditionally exists if
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 18:35:34 UTC 2024
    - 22.7K bytes
    - Viewed (0)
Back to top