- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 49 for rp (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
pkg/kubelet/cm/node_container_manager_linux.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 10.5K bytes - Viewed (0) -
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) -
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) -
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)