Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for Mitake (0.16 sec)

  1. cni/pkg/nodeagent/pod_cache.go

    // No need to return NetnsCloser here it will be closed automatically on GC.
    // (it may be used in parallel by other parts of the code, so we want it to be used only when not used)
    func (p *podNetnsCache) Take(uid string) Netns {
    	// lock current pod map
    	p.mu.Lock()
    	defer p.mu.Unlock()
    	if ns, ok := p.currentPodCache[uid]; ok {
    		delete(p.currentPodCache, uid)
    		// already in cache
    		return ns.Netns
    	}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.5K bytes
    - Viewed (0)
  2. operator/cmd/mesh/operator-remove.go

    			if orArgs.revision == "" && !orArgs.purge {
    				return fmt.Errorf("at least one of the --revision or --purge flags must be set")
    			}
    			if len(args) > 0 {
    				return fmt.Errorf("istioctl operator remove does not take arguments")
    			}
    			return nil
    		},
    		RunE: func(cmd *cobra.Command, args []string) error {
    			client, err := ctx.CLIClient()
    			if err != nil {
    				return err
    			}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/pod_cache_test.go

    		Workload: podToWorkload(pod),
    		Netns:    ns,
    	}
    	netns1 := p.UpsertPodCacheWithNetns(string(pod.UID), wl)
    	netnsTaken := p.Take(string(pod.UID))
    	if netns1 != netnsTaken {
    		t.Fatalf("Expected the original Netns for the same uid, got %p and %p", netns1, ns)
    	}
    	if nil != p.Take(string(pod.UID)) {
    		// expect nil because we already took it
    		t.Fatalf("Expected nil Netns for the same uid twice")
    	}
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.2K bytes
    - Viewed (0)
Back to top