Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 131 for oldData (0.12 sec)

  1. src/cmd/vendor/golang.org/x/sys/unix/mremap.go

    	},
    	mremap: mremap,
    }
    
    func (m *mremapMmapper) Mremap(oldData []byte, newLength int, flags int) (data []byte, err error) {
    	if newLength <= 0 || len(oldData) == 0 || len(oldData) != cap(oldData) || flags&mremapFixed != 0 {
    		return nil, EINVAL
    	}
    
    	pOld := &oldData[cap(oldData)-1]
    	m.Lock()
    	defer m.Unlock()
    	bOld := m.active[pOld]
    	if bOld == nil || &bOld[0] != &oldData[0] {
    		return nil, EINVAL
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  2. security/pkg/nodeagent/util/util.go

    	}
    
    	writeIfNotEqual := func(fileName string, newData []byte) error {
    		if newData == nil {
    			return nil
    		}
    		oldData, _ := os.ReadFile(path.Join(dir, fileName))
    		if !bytes.Equal(oldData, newData) {
    			if err := file.AtomicWrite(path.Join(dir, fileName), newData, certFileMode); err != nil {
    				return fmt.Errorf("failed to write data to file %v: %v", fileName, err)
    			}
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 17 10:33:38 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/cli-runtime/pkg/genericclioptions/record_flags.go

    	objCopy := obj.DeepCopyObject()
    	if err := r.Record(objCopy); err != nil {
    		return nil, err
    	}
    
    	oldData, err := json.Marshal(obj)
    	if err != nil {
    		return nil, err
    	}
    	newData, err := json.Marshal(objCopy)
    	if err != nil {
    		return nil, err
    	}
    
    	return jsonpatch.CreateMergePatch(oldData, newData)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. pkg/scheduler/util/utils.go

    	if newStatus == nil {
    		return nil
    	}
    
    	oldData, err := json.Marshal(v1.Pod{Status: old.Status})
    	if err != nil {
    		return err
    	}
    
    	newData, err := json.Marshal(v1.Pod{Status: *newStatus})
    	if err != nil {
    		return err
    	}
    	patchBytes, err := strategicpatch.CreateTwoWayMergePatch(oldData, newData, &v1.Pod{})
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Sep 21 01:40:44 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  5. pkg/controller/ttl/ttl_controller.go

    	oldData, err := json.Marshal(node)
    	if err != nil {
    		return err
    	}
    	setIntAnnotation(node, annotationKey, value)
    	newData, err := json.Marshal(node)
    	if err != nil {
    		return err
    	}
    	patchBytes, err := strategicpatch.CreateTwoWayMergePatch(oldData, newData, &v1.Node{})
    	if err != nil {
    		return err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/util/apiclient/idempotency.go

    		}
    
    		// The node may appear to have no labels at first,
    		// so we wait for it to get hostname label.
    		if _, found := n.ObjectMeta.Labels[v1.LabelHostname]; !found {
    			return false, nil
    		}
    
    		oldData, err := json.Marshal(n)
    		if err != nil {
    			*lastError = errors.Wrapf(err, "failed to marshal unmodified node %q into JSON", n.Name)
    			return false, *lastError
    		}
    
    		// Execute the mutating function
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Feb 18 11:14:32 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  7. pkg/controller/controller_utils.go

    		}
    
    		oldData, err := json.Marshal(node)
    		if err != nil {
    			return fmt.Errorf("failed to marshal the existing node %#v: %v", node, err)
    		}
    		newData, err := json.Marshal(newNode)
    		if err != nil {
    			return fmt.Errorf("failed to marshal the new node %#v: %v", newNode, err)
    		}
    		patchBytes, err := strategicpatch.CreateTwoWayMergePatch(oldData, newData, &v1.Node{})
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 12 15:34:44 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  8. pkg/volume/csi/csi_plugin.go

    		return ret, nil
    	}
    
    	ret.Spec = p.constructPVSourceSpec(volData[volDataKey.specVolID], volData[volDataKey.driverName], volData[volDataKey.volHandle])
    	return ret, nil
    }
    
    // constructVolSourceSpec constructs volume.Spec with CSIVolumeSource
    func (p *csiPlugin) constructVolSourceSpec(volSpecName, driverName string) *volume.Spec {
    	vol := &api.Volume{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  9. pkg/util/filesystem/defaultfs.go

    	}
    	return &defaultFile{file}, nil
    }
    
    // Rename via os.Rename
    func (fs *DefaultFs) Rename(oldpath, newpath string) error {
    	if !strings.HasPrefix(oldpath, fs.root) {
    		oldpath = fs.prefix(oldpath)
    	}
    	if !strings.HasPrefix(newpath, fs.root) {
    		newpath = fs.prefix(newpath)
    	}
    	return os.Rename(oldpath, newpath)
    }
    
    // MkdirAll via os.MkdirAll
    func (fs *DefaultFs) MkdirAll(path string, perm os.FileMode) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 03 07:38:14 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  10. pkg/api/pod/warnings.go

    	if pod == nil {
    		return nil
    	}
    
    	var (
    		oldSpec *api.PodSpec
    		oldMeta *metav1.ObjectMeta
    	)
    	if oldPod != nil {
    		oldSpec = &oldPod.Spec
    		oldMeta = &oldPod.ObjectMeta
    	}
    	return warningsForPodSpecAndMeta(nil, &pod.Spec, &pod.ObjectMeta, oldSpec, oldMeta)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 17:51:48 UTC 2024
    - 16.6K bytes
    - Viewed (0)
Back to top