Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for rp (0.02 sec)

  1. pkg/config/schema/kubetypes/common.go

    		}
    		return gr
    	}
    	if rp := typemap.Get[RegisterType[T]](registeredTypes); rp != nil {
    		return (*rp).GetGVR()
    	}
    	panic("unknown kind: " + ptr.TypeName[T]())
    }
    
    func MustGVKFromType[T runtime.Object]() (cfg config.GroupVersionKind) {
    	if gvk, ok := getGvk(ptr.Empty[T]()); ok {
    		return gvk
    	}
    	if rp := typemap.Get[RegisterType[T]](registeredTypes); rp != nil {
    		return (*rp).GetGVK()
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 16:38:40 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  2. pkg/config/analysis/analyzers/telemetry/selector.go

    		foundPod := false
    		c.ForEach(gvk.Pod, func(rp *resource.Instance) bool {
    			pNs := rp.Metadata.FullName.Namespace
    			podLabels := labels.Set(rp.Metadata.Labels)
    
    			// Only attempt to match in the same namespace
    			if pNs != sNs {
    				return true
    			}
    
    			if sel.Matches(podLabels) {
    				foundPod = true
    				podsToTelemetries[rp.Metadata.FullName] = append(podsToTelemetries[rp.Metadata.FullName], rs)
    			}
    
    			return true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun May 05 03:44:57 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  3. src/internal/trace/testdata/testprog/stress-start-stop.go

    		done := make(chan bool)
    
    		wg.Add(1)
    		go func() {
    			<-done
    			wg.Done()
    		}()
    
    		rp, wp, err := os.Pipe()
    		if err != nil {
    			log.Fatalf("failed to create pipe: %v", err)
    			return
    		}
    		defer func() {
    			rp.Close()
    			wp.Close()
    		}()
    		wg.Add(1)
    		go func() {
    			var tmp [1]byte
    			rp.Read(tmp[:])
    			<-done
    			wg.Done()
    		}()
    		time.Sleep(time.Millisecond)
    
    		go func() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  4. src/internal/trace/testdata/testprog/stress.go

    	go func() {
    		<-done
    		wg.Done()
    	}()
    
    	// Create a goroutine blocked in syscall before tracing.
    	rp, wp, err := os.Pipe()
    	if err != nil {
    		log.Fatalf("failed to create pipe: %v", err)
    	}
    	defer func() {
    		rp.Close()
    		wp.Close()
    	}()
    	wg.Add(1)
    	go func() {
    		var tmp [1]byte
    		rp.Read(tmp[:])
    		<-done
    		wg.Done()
    	}()
    	time.Sleep(time.Millisecond) // give the goroutine above time to block
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  5. pkg/config/analysis/analyzers/sidecar/selector.go

    		foundPod := false
    		c.ForEach(gvk.Pod, func(rp *resource.Instance) bool {
    			pNs := rp.Metadata.FullName.Namespace
    			podLabels := labels.Set(rp.Metadata.Labels)
    
    			// Only attempt to match in the same namespace
    			if pNs != sNs {
    				return true
    			}
    
    			if sel.Matches(podLabels) {
    				foundPod = true
    				podsToSidecars[rp.Metadata.FullName] = append(podsToSidecars[rp.Metadata.FullName], rs)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun May 05 03:44:57 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. src/internal/trace/testdata/testprog/stacks.go

    		if err != nil {
    			log.Printf("failed to accept: %v", err)
    			return
    		}
    		c.Close()
    	}()
    	rp, wp, err := os.Pipe()
    	if err != nil {
    		log.Fatalf("failed to create a pipe: %v", err)
    	}
    	defer rp.Close()
    	defer wp.Close()
    	pipeReadDone := make(chan bool)
    	go func() { // func11
    		var data [1]byte
    		rp.Read(data[:])
    		pipeReadDone <- true
    	}()
    
    	time.Sleep(100 * time.Millisecond)
    	runtime.GC()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  7. src/crypto/internal/boring/build-goboring.sh

    typedef unsigned int u128 __attribute__((mode(TI)));
    
    static u128 div(u128 x, u128 y, u128 *rp) {
    	int n = 0;
    	while((y>>(128-1)) != 1 && y < x) {
    		y<<=1;
    		n++;
    	}
    	u128 q = 0;
    	for(;; n--, y>>=1, q<<=1) {
    		if(x>=y) {
    			x -= y;
    			q |= 1;
    		}
    		if(n == 0)
    			break;
    	}
    	if(rp)
    		*rp = x;
    	return q;
    }
    
    u128 __umodti3(u128 x, u128 y) {
    	u128 r;
    	div(x, y, &r);
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jan 26 22:52:27 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  8. src/crypto/tls/testdata/Client-TLSv12-ExportKeyingMaterial

    00000020  ff 6e e3 60 11 40 2c b8  40 87 5c 20 86 3d de c2  |.n.`.@,.@.\ .=..|
    00000030  18 41 ff 1a dc 00 77 4e  17 0b 36 f3 69 92 d7 04  |.A....wN..6.i...|
    00000040  c4 c6 39 ad ed f7 06 23  8c 52 50 da cc a8 00 00  |..9....#.RP.....|
    00000050  11 ff 01 00 01 00 00 0b  00 04 03 00 01 02 00 17  |................|
    00000060  00 00 16 03 03 02 59 0b  00 02 55 00 02 52 00 02  |......Y...U..R..|
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:33:38 UTC 2024
    - 6.7K bytes
    - Viewed (0)
Back to top