Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 49 for rp (0.02 sec)

  1. pilot/pkg/networking/core/envoyfilter/rc_patch.go

    	for _, rp := range efw.Patches[networking.EnvoyFilter_ROUTE_CONFIGURATION] {
    		if rp.Operation != networking.EnvoyFilter_Patch_MERGE {
    			continue
    		}
    		if commonConditionMatch(patchContext, rp) &&
    			routeConfigurationMatch(patchContext, routeConfiguration, rp, portMap) {
    			merge.Merge(routeConfiguration, rp.Value)
    			IncrementEnvoyFilterMetric(rp.Key(), Route, true)
    		} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 13K bytes
    - Viewed (0)
  2. 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)
  3. src/go/parser/testdata/resolution/typeparams.go2

    type RP /* =@RP1 */ struct{}
    
    // TODO(rFindley): make a decision on how/whether to resolve identifiers that
    // refer to receiver type parameters, as is the case for the 'P' result
    // parameter below.
    //
    // For now, we ensure that types are not incorrectly resolved when receiver
    // type parameters are in scope.
    func (r /* =@recv */ Receiver /* @Receiver */ [RP]) m(RP) RP {}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Nov 02 12:56:53 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. pkg/kubelet/cm/node_container_manager_linux.go

    	if utilfeature.DefaultFeatureGate.Enabled(kubefeatures.MemoryQoS) {
    		if rp.Memory != nil {
    			if rp.Unified == nil {
    				rp.Unified = make(map[string]string)
    			}
    			rp.Unified[Cgroup2MemoryMin] = strconv.FormatInt(*rp.Memory, 10)
    		}
    	}
    
    	cgroupConfig := &CgroupConfig{
    		Name:               cName,
    		ResourceParameters: rp,
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  8. src/crypto/internal/boring/div_test.c

    #define nelem(x) (sizeof(x)/sizeof((x)[0]))
    
    typedef uint32_t u32;
    
    static u32 div(u32 x, u32 y, u32 *rp) {
    	int n = 0;
    	while((y>>(32-1)) != 1 && y < x) {
    		y<<=1;
    		n++;
    	}
    	u32 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;
    }
    
    u32 tests[] = {
    	0,
    	1,
    	2,
    	3,
    	4,
    	5,
    	6,
    	7,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Aug 18 21:28:09 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top