Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 41 for udmMap (0.16 sec)

  1. pkg/kubelet/stats/helper.go

    	type specVal struct {
    		ref     statsapi.UserDefinedMetricDescriptor
    		valType cadvisorapiv1.DataType
    		time    time.Time
    		value   float64
    	}
    	udmMap := map[string]*specVal{}
    	for _, spec := range info.Spec.CustomMetrics {
    		udmMap[spec.Name] = &specVal{
    			ref: statsapi.UserDefinedMetricDescriptor{
    				Name:  spec.Name,
    				Type:  statsapi.UserDefinedMetricType(spec.Type),
    				Units: spec.Units,
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 17 23:40:02 UTC 2023
    - 14.8K bytes
    - Viewed (0)
  2. src/syscall/exec_linux.go

    	}
    }
    
    func formatIDMappings(idMap []SysProcIDMap) []byte {
    	var data []byte
    	for _, im := range idMap {
    		data = append(data, itoa.Itoa(im.ContainerID)+" "+itoa.Itoa(im.HostID)+" "+itoa.Itoa(im.Size)+"\n"...)
    	}
    	return data
    }
    
    // writeIDMappings writes the user namespace User ID or Group ID mappings to the specified path.
    func writeIDMappings(path string, idMap []SysProcIDMap) error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 07:45:37 UTC 2024
    - 23K bytes
    - Viewed (0)
  3. internal/logger/logonce.go

    // Holds a map of recently logged errors.
    type logOnceType struct {
    	IDMap map[string]onceErr
    	sync.Mutex
    }
    
    func (l *logOnceType) logOnceConsoleIf(ctx context.Context, subsystem string, err error, id string, errKind ...interface{}) {
    	if err == nil {
    		return
    	}
    
    	nerr := unwrapErrs(err)
    	l.Lock()
    	shouldLog := true
    	prev, ok := l.IDMap[id]
    	if !ok {
    		l.IDMap[id] = onceErr{
    			Err:   nerr,
    			Count: 1,
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  4. cni/pkg/ipset/ipset.go

    	ipToInsert := ip.Unmap()
    
    	// We have already Unmap'd, so we can do a simple IsV6 y/n check now
    	if ipToInsert.Is6() {
    		return m.Deps.addIP(m.V6Name, ipToInsert, ipProto, comment, replace)
    	}
    	return m.Deps.addIP(m.V4Name, ipToInsert, ipProto, comment, replace)
    }
    
    func (m *IPSet) DeleteIP(ip netip.Addr, ipProto uint8) error {
    	ipToDel := ip.Unmap()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  5. pkg/kubelet/pod/pod_manager.go

    }
    
    func podsMapToPods(UIDMap map[kubetypes.ResolvedPodUID]*v1.Pod) []*v1.Pod {
    	pods := make([]*v1.Pod, 0, len(UIDMap))
    	for _, pod := range UIDMap {
    		pods = append(pods, pod)
    	}
    	return pods
    }
    
    func mirrorPodsMapToMirrorPods(UIDMap map[kubetypes.MirrorPodUID]*v1.Pod) []*v1.Pod {
    	pods := make([]*v1.Pod, 0, len(UIDMap))
    	for _, pod := range UIDMap {
    		pods = append(pods, pod)
    	}
    	return pods
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:00 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  6. pkg/volume/util/fsquota/project.go

    			return project.id, false, nil
    		}
    		idMap[project.id] = true
    	}
    	var needToAddProjid = true
    	for _, projid := range list.projid {
    		idMap[projid.id] = true
    		if projid.id == id && id != common.BadQuotaID {
    			needToAddProjid = false
    		}
    	}
    	var err error
    	if id == common.BadQuotaID {
    		id, err = findAvailableQuota(path, idMap)
    		if err != nil {
    			return common.BadQuotaID, false, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 20 14:49:03 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  7. cmd/encryption-v1_test.go

    		minPartSz = int64(5) * humanize.MiByte
    		maxPartSz = int64(5) * humanize.GiByte
    
    		getEncSize = func(s int64) int64 {
    			v, _ := sio.EncryptedSize(uint64(s))
    			return int64(v)
    		}
    		udMap = func(isMulti bool) map[string]string {
    			m := map[string]string{
    				crypto.MetaAlgorithm: crypto.InsecureSealAlgorithm,
    				crypto.MetaMultipart: "1",
    			}
    			if !isMulti {
    				delete(m, crypto.MetaMultipart)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Sep 24 04:17:08 UTC 2022
    - 19.9K bytes
    - Viewed (0)
  8. src/net/netip/inlining_test.go

    		"(*uint128).halves",
    		"Addr.BitLen",
    		"Addr.hasZone",
    		"Addr.Is4",
    		"Addr.Is4In6",
    		"Addr.Is6",
    		"Addr.IsInterfaceLocalMulticast",
    		"Addr.IsValid",
    		"Addr.IsUnspecified",
    		"Addr.Less",
    		"Addr.Unmap",
    		"Addr.Zone",
    		"Addr.v4",
    		"Addr.v6",
    		"Addr.v6u16",
    		"Addr.withoutZone",
    		"AddrPortFrom",
    		"AddrPort.Addr",
    		"AddrPort.Port",
    		"AddrPort.IsValid",
    		"Prefix.IsSingleIP",
    		"Prefix.Masked",
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 17:10:01 UTC 2024
    - 2K bytes
    - Viewed (0)
  9. src/cmd/internal/bio/buf_mmap.go

    	if runtime.GOOS == "linux" {
    		mmapLimit = 30000
    	}
    }
    
    func (r *Reader) sliceOS(length uint64) ([]byte, bool) {
    	// For small slices, don't bother with the overhead of a
    	// mapping, especially since we have no way to unmap it.
    	const threshold = 16 << 10
    	if length < threshold {
    		return nil, false
    	}
    
    	// Have we reached the mmap limit?
    	if atomic.AddInt32(&mmapLimit, -1) < 0 {
    		atomic.AddInt32(&mmapLimit, 1)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 19 11:20:31 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  10. pkg/util/kernel/constants.go

    // (ref: https://github.com/torvalds/linux/commit/35dfb013149f74c2be1ff9c78f14e6a3cd1539d1)
    const IPVSConnReuseModeFixedKernelVersion = "5.9"
    
    // UserNamespacesSupportKernelVersion is the kernel version where idmap for tmpfs support was added
    // (ref: https://github.com/torvalds/linux/commit/05e6295f7b5e05f09e369a3eb2882ec5b40fff20)
    const UserNamespacesSupportKernelVersion = "6.3"
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 2.7K bytes
    - Viewed (0)
Back to top