Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for wl (0.05 sec)

  1. istioctl/pkg/writer/ztunnel/configdump/workload.go

    	fmt.Fprintln(w, "NAMESPACE\tPOD NAME\tADDRESS\tNODE\tWAYPOINT\tPROTOCOL")
    
    	for _, wl := range verifiedWorkloads {
    		address := strings.Join(wl.WorkloadIPs, ",")
    		if len(address) == 0 {
    			address = wl.Hostname
    		}
    		waypoint := waypointName(wl, zDump.Services)
    		fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\n",
    			wl.Namespace, wl.Name, address, wl.Node, waypoint, wl.Protocol)
    
    	}
    	return w.Flush()
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 24 09:07:30 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/ztunnelserver.go

    	snap := z.pods.ReadCurrentPodSnapshot()
    	for uid, wl := range snap {
    		var resp *zdsapi.WorkloadResponse
    		var err error
    		log := log.WithLabels("uid", uid)
    		if wl.Workload != nil {
    			log = log.WithLabels(
    				"name", wl.Workload.Name,
    				"namespace", wl.Workload.Namespace,
    				"serviceAccount", wl.Workload.ServiceAccount)
    		}
    		if wl.Netns != nil {
    			fd := int(wl.Netns.Fd())
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/pod_cache_test.go

    	p := newPodNetnsCache(openNsTestOverride)
    
    	pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{UID: "testUID"}}
    	ns := newFakeNsInode(inc(), 1)
    	wl := WorkloadInfo{
    		Workload: podToWorkload(pod),
    		Netns:    ns,
    	}
    	netns1 := p.UpsertPodCacheWithNetns(string(pod.UID), wl)
    	if !reflect.DeepEqual(netns1, ns) {
    		t.Fatalf("Expected the same Netns for the same uid, got %v and %v", netns1, ns)
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/ztunnel/configdump/connections.go

    			return r
    		}
    		return cmp.Compare(a.Info.Namespace, b.Info.Namespace)
    	})
    	for _, wl := range workloads {
    		if filter.Namespace != "" && filter.Namespace != wl.Info.Namespace {
    			continue
    		}
    		name := fmt.Sprintf("%s.%s", wl.Info.Name, wl.Info.Namespace)
    		if filter.Direction != "outbound" {
    			for _, c := range wl.Connections.Inbound {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri May 31 21:45:11 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  5. internal/lsync/lrwmutex_test.go

    }
    
    // Borrowed from rwmutex_test.go
    func TestDRLocker(t *testing.T) {
    	wl := NewLRWMutex()
    	var rl sync.Locker
    	wlocked := make(chan bool, 1)
    	rlocked := make(chan bool, 1)
    	rl = wl.DRLocker()
    	n := 10
    	go func() {
    		for i := 0; i < n; i++ {
    			rl.Lock()
    			rl.Lock()
    			rlocked <- true
    			wl.Lock()
    			wlocked <- true
    		}
    	}()
    	for i := 0; i < n; i++ {
    		<-rlocked
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  6. tensorflow/BUILD

        framework_so = [],
        linkopts = select({
            "//tensorflow:macos": [
                "-Wl,-rename_section,__TEXT,text_env,__TEXT,__text",
                "-Wl,-unexported_symbols_list,$(location //tensorflow:tf_private_symbols.lds)",
            ],
            "//tensorflow:windows": [],
            "//tensorflow:freebsd": [
                "-Wl,--version-script,$(location //tensorflow:tf_framework_version_script.lds)",
                "-lexecinfo",
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Oct 16 05:28:35 UTC 2024
    - 53.5K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/pod_cache.go

    	newnetns, err := p.openNetns(nspath)
    	if err != nil {
    		return nil, err
    	}
    	wl := WorkloadInfo{
    		Workload: podToWorkload(pod),
    		Netns:    newnetns,
    	}
    	return p.UpsertPodCacheWithNetns(string(pod.UID), wl), nil
    }
    
    // Update the cache with the given Netns. If there is already a Netns for the given uid, we return it, and close the one provided.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri May 31 17:18:11 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  8. docs/sts/custom-token-identity.md

        </Credentials>
        <AssumedUser>custom:Alice</AssumedUser>
      </AssumeRoleWithCustomTokenResult>
      <ResponseMetadata>
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 27 00:58:09 UTC 2022
    - 3K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/net.go

    	// TODO: maybe remove existing uids in s.currentPodSnapshot from the filter set.
    	res, err := s.podNs.FindNetnsForPods(pods)
    	if err != nil {
    		return err
    	}
    
    	for uid, wl := range res {
    		s.currentPodSnapshot.UpsertPodCacheWithNetns(uid, wl)
    	}
    	return nil
    }
    
    func realDependenciesHost() *dep.RealDependencies {
    	return &dep.RealDependencies{
    		// We are in the host FS *and* the Host network
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/podcgroupns.go

    	"k8s.io/apimachinery/pkg/types"
    
    	"istio.io/istio/pkg/maps"
    	"istio.io/istio/pkg/util/sets"
    )
    
    type PodToNetns map[string]WorkloadInfo
    
    func (p PodToNetns) Close() {
    	for _, wl := range p {
    		wl.Netns.Close()
    	}
    }
    
    type PodNetnsFinder interface {
    	FindNetnsForPods(filter map[types.UID]*corev1.Pod) (PodToNetns, error)
    }
    
    type PodNetnsProcFinder struct {
    	proc fs.FS
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 11K bytes
    - Viewed (0)
Back to top