fix netns info expire on sidecar mode

Signed-off-by: bingshen.wbs <[email protected]>

pkg/exporter/nettop/cache.go

@@ -119,7 +119,7 @@ func initDefaultEntity(sidecarMode bool) error {
 		}
 		ent := []*Entity{defaultEntity}
 		entities.Store(&ent)
-		addEntityToCache(defaultEntity, false)
+		addEntityToCache(defaultEntity, false, true)
 	}
 
 	return nil
@@ -283,15 +283,19 @@ func cachePodsWithTimeout(timeout time.Duration) error {
 	}
 }
 
-func addEntityToCache(e *Entity, ignoreHostPod bool) {
+func addEntityToCache(e *Entity, ignoreHostPod, noExpiration bool) {
+	expirationTime := 3 * cacheUpdateInterval
+	if noExpiration {
+		expirationTime = cache.NoExpiration
+	}
 	if !(ignoreHostPod && e.IsHostNetwork()) {
-		nsCache.Set(fmt.Sprintf("%d", e.inum), e, 3*cacheUpdateInterval)
+		nsCache.Set(fmt.Sprintf("%d", e.inum), e, expirationTime)
 	}
 	for _, ip := range e.ipList {
-		ipCache.Set(ip, e, 3*cacheUpdateInterval)
+		ipCache.Set(ip, e, expirationTime)
 	}
 	for _, pid := range e.pids {
-		pidCache.Set(fmt.Sprintf("%d", pid), e, 3*cacheUpdateInterval)
+		pidCache.Set(fmt.Sprintf("%d", pid), e, expirationTime)
 	}
 }
 
@@ -333,7 +337,7 @@ func cacheNetTopology(ctx context.Context) error {
 
 	var newEntities []*Entity
 	newEntities = append(newEntities, defaultEntity)
-	addEntityToCache(defaultEntity, false)
+	addEntityToCache(defaultEntity, false, true)
 
 	sandboxList, err := criClient.ListPodSandbox(&v1.PodSandboxFilter{
 		State: &v1.PodSandboxStateValue{
@@ -393,7 +397,7 @@ func cacheNetTopology(ctx context.Context) error {
 		var ns *netnsMeta
 
 		if netnsNum == defaultEntity.inum {
-			ns = defaultEntity.netnsMeta
+			continue
 		} else {
 			status := sandboxStatus.Status
 			if status.Network == nil || status.Network.Ip == "" {
@@ -420,7 +424,7 @@ func cacheNetTopology(ctx context.Context) error {
 		}
 
 		newEntities = append(newEntities, e)
-		addEntityToCache(e, true)
+		addEntityToCache(e, true, false)
 	}
 
 	entities.Store(&newEntities)

pkg/exporter/nettop/interface.go

@@ -24,7 +24,7 @@ func GetEntityByNetns(nsinum int) (*Entity, error) {
 	if found {
 		return v.(*Entity), nil
 	}
-	return nil, fmt.Errorf("entify for netns %d not found", nsinum)
+	return nil, fmt.Errorf("entity for netns %d not found", nsinum)
 }
 
 func GetHostNetworkEntity() (*Entity, error) {