- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 297 for chancap (0.12 sec)
-
test/chancap.go
Clément Chigot <******@****.***> 1538380720 +0200
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 26 14:06:28 UTC 2018 - 1.6K bytes - Viewed (0) -
src/runtime/chan_test.go
c <- i } if len(c) != chanCap || cap(c) != chanCap { t.Fatalf("chan[%d]: bad len/cap, expect %v/%v, got %v/%v", chanCap, chanCap, chanCap, len(c), cap(c)) } } } } func TestNonblockRecvRace(t *testing.T) { n := 10000 if testing.Short() { n = 100 } for i := 0; i < n; i++ { c := make(chan int, 1) c <- 1 go func() { select {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 31 20:47:35 UTC 2023 - 23.4K bytes - Viewed (0) -
src/cmd/internal/goobj/builtinlist.go
{"runtime.makechan64", 1}, {"runtime.makechan", 1}, {"runtime.chanrecv1", 1}, {"runtime.chanrecv2", 1}, {"runtime.chansend1", 1}, {"runtime.closechan", 1}, {"runtime.chanlen", 1}, {"runtime.chancap", 1}, {"runtime.writeBarrier", 0}, {"runtime.typedmemmove", 1}, {"runtime.typedmemclr", 1}, {"runtime.typedslicecopy", 1}, {"runtime.selectnbsend", 1}, {"runtime.selectnbrecv", 1},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 21:08:03 UTC 2024 - 7.4K bytes - Viewed (0) -
src/runtime/chan.go
} //go:linkname reflectlite_chanlen internal/reflectlite.chanlen func reflectlite_chanlen(c *hchan) int { return chanlen(c) } //go:linkname reflect_chancap reflect.chancap func reflect_chancap(c *hchan) int { return chancap(c) } //go:linkname reflect_chanclose reflect.chanclose func reflect_chanclose(c *hchan) { closechan(c) } func (q *waitq) enqueue(sgp *sudog) { sgp.next = nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
src/cmd/compile/internal/typecheck/_builtin/runtime.go
func chanrecv1(hchan <-chan any, elem *any) func chanrecv2(hchan <-chan any, elem *any) bool func chansend1(hchan chan<- any, elem *any) func closechan(hchan chan<- any) func chanlen(hchan any) int func chancap(hchan any) int var writeBarrier struct { enabled bool pad [3]byte cgo bool alignme uint64 } // *byte is really *runtime.Type func typedmemmove(typ *byte, dst *any, src *any)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 21:08:03 UTC 2024 - 10.6K bytes - Viewed (0) -
src/cmd/compile/internal/typecheck/builtin.go
{"makechan64", funcTag, 98}, {"makechan", funcTag, 99}, {"chanrecv1", funcTag, 101}, {"chanrecv2", funcTag, 102}, {"chansend1", funcTag, 104}, {"closechan", funcTag, 105}, {"chanlen", funcTag, 106}, {"chancap", funcTag, 106}, {"writeBarrier", varTag, 108}, {"typedmemmove", funcTag, 109}, {"typedmemclr", funcTag, 110}, {"typedslicecopy", funcTag, 111}, {"selectnbsend", funcTag, 112}, {"selectnbrecv", funcTag, 113},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 21:08:03 UTC 2024 - 16.2K bytes - Viewed (0) -
src/cmd/compile/internal/walk/builtin.go
init.Append(ir.TakeInit(conv)...) _, len := backingArrayPtrLen(cheapExpr(conv.X, init)) return len } if isChanLenCap(n) { name := "chanlen" if n.Op() == ir.OCAP { name = "chancap" } // cannot use chanfn - closechan takes any, not chan any, // because it accepts both send-only and recv-only channels. fn := typecheck.LookupRuntime(name, n.X.Type()) return mkcall1(fn, n.Type(), init, n.X)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 22:35:22 UTC 2024 - 31.2K bytes - Viewed (0) -
src/reflect/value.go
} return v.capNonSlice() } func (v Value) capNonSlice() int { k := v.kind() switch k { case Array: return v.typ().Len() case Chan: return chancap(v.pointer()) case Ptr: if v.typ().Elem().Kind() == abi.Array { return v.typ().Elem().Len() } panic("reflect: call of reflect.Value.Cap on ptr to non-array Value") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 119.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/goaway.go
h.handler.ServeHTTP(w, r) } // probabilisticGoawayDecider send GOAWAY probabilistically according to chance type probabilisticGoawayDecider struct { chance float64 next func() float64 } // Goaway implement GoawayDecider func (p *probabilisticGoawayDecider) Goaway(r *http.Request) bool { return p.next() < p.chance
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jun 28 20:27:28 UTC 2020 - 2.4K bytes - Viewed (0) -
test/chan/sendstmt.go
// license that can be found in the LICENSE file. // Test various parsing cases that are a little // different now that send is a statement, not an expression. package main func main() { chanchan() sendprec() } func chanchan() { cc := make(chan chan int, 1) c := make(chan int, 1) cc <- c select { case <-cc <- 2: default: panic("nonblock") } if <-c != 2 { panic("bad receive") } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 15 02:39:16 UTC 2017 - 672 bytes - Viewed (0)