Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for iNode (0.02 sec)

  1. cni/pkg/nodeagent/fakes_test.go

    type fakeNs struct {
    	closed *atomic.Bool
    	fd     uintptr
    	inode  uint64
    }
    
    func newFakeNs(fd uintptr) *fakeNs {
    	// the fake inode is the fd! magic.
    	return &fakeNs{closed: &atomic.Bool{}, fd: fd, inode: uint64(fd)}
    }
    
    func newFakeNsInode(fd uintptr, inode uint64) *fakeNs {
    	return &fakeNs{closed: &atomic.Bool{}, fd: fd, inode: inode}
    }
    
    // Fd returns the file descriptor
    func (f *fakeNs) Fd() uintptr {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 23:33:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/pod_cache.go

    		if existing.Netns.Inode() == workload.Netns.Inode() {
    			workload.Netns.Close()
    			// Replace the workload, but keep the old Netns
    			p.currentPodCache[uid] = WorkloadInfo{
    				Workload: workload.Workload,
    				Netns:    existing.Netns,
    			}
    			// already in cache
    			return existing.Netns
    		}
    		log.Debug("netns inode mismatch, using the new one")
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri May 31 17:18:11 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/ztunnel/configdump/workload.go

    		jn := verifiedWorkloads[j].Namespace + "." + verifiedWorkloads[j].Name
    		if in != jn {
    			return in < jn
    		}
    		iNode := verifiedWorkloads[i].Node
    		jNode := verifiedWorkloads[j].Node
    		return iNode < jNode
    	})
    
    	fmt.Fprintln(w, "NAMESPACE\tPOD NAME\tADDRESS\tNODE\tWAYPOINT\tPROTOCOL")
    
    	for _, wl := range verifiedWorkloads {
    		address := strings.Join(wl.WorkloadIPs, ",")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 24 09:07:30 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/pod_cache_test.go

    	return newFakeNs(inc()), nil
    }
    
    func openNsTestOverrideWithInodes(inodes ...uint64) func(s string) (NetnsCloser, error) {
    	i := 0
    	return func(s string) (NetnsCloser, error) {
    		inode := inodes[i]
    		i++
    		return newFakeNsInode(inc(), inode), nil
    	}
    }
    
    func TestUpsertPodCache(t *testing.T) {
    	counter.Store(0)
    
    	p := newPodNetnsCache(openNsTestOverrideWithInodes(1, 1))
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  5. cmd/object-api-utils.go

    	for _, disk := range di {
    		if disk == nil || disk.Total == 0 {
    			continue
    		}
    		if !globalIsErasureSD && disk.FreeInodes < diskMinInodes && disk.UsedInodes > 0 {
    			// We have an inode count, but not enough inodes.
    			return false, nil
    		}
    		if int64(disk.Free) <= perDisk {
    			return false, nil
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
Back to top