- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 49 for rp (0.04 sec)
-
src/compress/flate/example_test.go
var wg sync.WaitGroup defer wg.Wait() // Use io.Pipe to simulate a network connection. // A real network application should take care to properly close the // underlying connection. rp, wp := io.Pipe() // Start a goroutine to act as the transmitter. wg.Add(1) go func() { defer wg.Done() zw, err := flate.NewWriter(wp, flate.BestSpeed) if err != nil { log.Fatal(err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Nov 12 18:42:35 UTC 2016 - 6.5K bytes - Viewed (0) -
pkg/testcerts/testcerts.go
yQYipvEhYOJ7Dook+8rSfRY7lmLcdURWdOfY/s5U6kBDRqtTvl25zrivwNoLtBIo sYJFWchYEbv3k3457yfxawyuNfpwANv60bH7Hm9/ViBgqI5yrgB9Ly2pMDIGUjs2 1nJBSABGlZKcxRHhVKauv35DYG9hRa/C1AoIUsCziZHLggr9+eZ1CdmHTuKekWVt 9nriO02MXemKWfCZaRhPADnHf8oPw/rP+R/FrG6JF3JS9EVINQC8c9q0SyWbuwxg 4u9k9DKk/joZ0cbqlOS74Wvk2GFigIF9uuOhZdHzF/+IYH4ZNM0AFGVoKn+QwFG8 5kJyW6NsHIn5fOLyrT2rXXT/FJXr/lIJ//hzybIjHBfH4hB8uWvMLN2vrqT71yR6 dfQxqrTJcxJbidjA5LF0ABOQaJ0ja+OrL3LHofY1f9fXzUWV+Bx6NIvNlZwIxL4G
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Dec 08 16:24:03 UTC 2022 - 10.9K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_extender.go
// and get cached node info by given node name. nodeInfoCopy := f.CachedNodeNameToInfo[node.Node().Name].Snapshot() var potentialVictims []*v1.Pod removePod := func(rp *v1.Pod) error { return nodeInfoCopy.RemovePod(logger, rp) } addPod := func(ap *v1.Pod) { nodeInfoCopy.AddPod(ap) } // As the first step, remove all the lower priority pods from the node and // check if the given pod can be scheduled.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.9K bytes - Viewed (0) -
src/internal/trace/summary.go
g = s.gs[r.Scope.Goroutine()] case ResourceProc: rp := rangeP{id: r.Scope.Proc(), name: r.Name} if goid, ok := s.rangesP[rp]; ok { if goid == ev.Goroutine() { // As the comment in the RangeBegin case states, this is only OK // if we finish on the same goroutine we started on. g = s.gs[goid] } delete(s.rangesP, rp) } } if g == nil { break }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 20.7K bytes - Viewed (0) -
guava/src/com/google/thirdparty/publicsuffix/PublicSuffixPatterns.java
?t&en?ni??ude?zib??airpic?i&hgrobmal?m??re??om?rarref?s!.&5f,egaptig,ppatig,topsgolb,?ed??t&i&c?nifni??rahb??ut?v!.&21k?gro?moc?oc?ten???wik?xa&rp?t??yf??j&6pqgza9iabgm--nx?8da1tabbgl--nx?b!.&acirfa?eto?gro?m&oc?siruot??o&c!e??fni?noce?rga?tser??russa?s&etcetihcra?risiol?tacova??t&en?naruatser?opsgolb,?ude?vinu?yenom???d?f!.&ca?eman?gro?lim?moc?o&fni?rp??ten?vog?zib???nj?s?t!.&bew?c&a?in??eman?gro?lim?moc?o&c?g??t&en?ni?set??ude?vog?zib???yqx94qit--nx??k&8uxp3--nx?924tcf--nx?arfel?c&a&bdeef?lb??...
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Mar 21 21:04:43 UTC 2024 - 72.4K bytes - Viewed (0) -
android/guava/src/com/google/thirdparty/publicsuffix/PublicSuffixPatterns.java
?t&en?ni??ude?zib??airpic?i&hgrobmal?m??re??om?rarref?s!.&5f,egaptig,ppatig,topsgolb,?ed??t&i&c?nifni??rahb??ut?v!.&21k?gro?moc?oc?ten???wik?xa&rp?t??yf??j&6pqgza9iabgm--nx?8da1tabbgl--nx?b!.&acirfa?eto?gro?m&oc?siruot??o&c!e??fni?noce?rga?tser??russa?s&etcetihcra?risiol?tacova??t&en?naruatser?opsgolb,?ude?vinu?yenom???d?f!.&ca?eman?gro?lim?moc?o&fni?rp??ten?vog?zib???nj?s?t!.&bew?c&a?in??eman?gro?lim?moc?o&c?g??t&en?ni?set??ude?vog?zib???yqx94qit--nx??k&8uxp3--nx?924tcf--nx?arfel?c&a&bdeef?lb??...
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Mar 21 21:04:43 UTC 2024 - 72.4K bytes - Viewed (1) -
pkg/apis/core/fuzzer/fuzzer.go
policies := []core.PullPolicy{core.PullAlways, core.PullNever, core.PullIfNotPresent} *p = policies[c.Rand.Intn(len(policies))] }, func(rp *core.RestartPolicy, c fuzz.Continue) { policies := []core.RestartPolicy{core.RestartPolicyAlways, core.RestartPolicyNever, core.RestartPolicyOnFailure} *rp = policies[c.Rand.Intn(len(policies))] }, // core.DownwardAPIVolumeFile needs to have a specific func since FieldRef has to be
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 04:32:01 UTC 2024 - 18.5K bytes - Viewed (0) -
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) -
src/net/http/h2_bundle.go
} rp.header = make(Header) for _, hf := range f.RegularFields() { rp.header.Add(sc.canonicalHeader(hf.Name), hf.Value) } if rp.authority == "" { rp.authority = rp.header.Get("Host") } rw, req, err := sc.newWriterAndRequestNoBody(st, rp) if err != nil { return nil, nil, err } bodyOpen := !f.StreamEnded()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion.go
} specs := make([]namespacedGrant, 0, len(r.ReferenceGrant)) for _, obj := range r.ReferenceGrant { rp := obj.Spec.(*k8sbeta.ReferenceGrantSpec) specs = append(specs, namespacedGrant{Namespace: obj.Namespace, Grant: rp}) } for _, ng := range specs { rp := ng.Grant for _, from := range rp.From { fromKey := Reference{ Namespace: from.Namespace, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 84.7K bytes - Viewed (0)