- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for chanrecv2 (0.19 sec)
-
src/cmd/internal/goobj/builtinlist.go
{"runtime.mapdelete_fast64", 1}, {"runtime.mapdelete_faststr", 1}, {"runtime.mapiternext", 1}, {"runtime.mapclear", 1}, {"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},
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/cmd/compile/internal/typecheck/_builtin/runtime.go
// *byte is really *runtime.Type func makechan64(chanType *byte, size int64) (hchan chan any) func makechan(chanType *byte, size int) (hchan chan any) 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
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
{"mapdelete_fast64", funcTag, 93}, {"mapdelete_faststr", funcTag, 94}, {"mapiternext", funcTag, 95}, {"mapclear", funcTag, 96}, {"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},
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/runtime/chan.go
} // entry points for <- c from compiled code. // //go:nosplit func chanrecv1(c *hchan, elem unsafe.Pointer) { chanrecv(c, elem, true) } //go:nosplit func chanrecv2(c *hchan, elem unsafe.Pointer) (received bool) { _, received = chanrecv(c, elem, true) return } // chanrecv receives on channel c and writes the received data to ep.
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/walk/assign.go
walkExprListSafe(n.Lhs, init) r.X = walkExpr(r.X, init) var n1 ir.Node if ir.IsBlank(n.Lhs[0]) { n1 = typecheck.NodNil() } else { n1 = typecheck.NodAddr(n.Lhs[0]) } fn := chanfn("chanrecv2", 2, r.X.Type()) ok := n.Lhs[1] call := mkcall1(fn, types.Types[types.TBOOL], init, r.X, n1) return typecheck.Stmt(ir.NewAssignStmt(base.Pos, ok, call)) } // walkReturn walks an ORETURN node.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:09:06 UTC 2024 - 20.3K bytes - Viewed (0) -
src/runtime/select.go
type scase struct { c *hchan // chan elem unsafe.Pointer // data element } var ( chansendpc = abi.FuncPCABIInternal(chansend) chanrecvpc = abi.FuncPCABIInternal(chanrecv) ) func selectsetpc(pc *uintptr) { *pc = getcallerpc() } func sellock(scases []scase, lockorder []uint16) { var c *hchan for _, o := range lockorder { c0 := scases[o].c
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 13 21:36:04 UTC 2024 - 15K bytes - Viewed (0) -
src/runtime/pprof/pprof_test.go
prefix []string }{ {"heap", []string{"runtime/pprof.allocDeep"}}, {"block", []string{"runtime.chanrecv1", "runtime/pprof.blockChanDeep"}}, {"mutex", []string{"sync.(*Mutex).Unlock", "runtime/pprof.blockMutexDeep"}}, {"goroutine", []string{"runtime.gopark", "runtime.chanrecv", "runtime.chanrecv1", "runtime/pprof.goroutineDeep"}}, } for _, test := range tests { t.Run(test.profiler, func(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 68.8K bytes - Viewed (0) -
src/internal/trace/trace_test.go
{"main.main.func2", 0}, }}, {trace.EventStateTransition, "Goroutine Running->Waiting", []frame{ {"runtime.chanrecv1", 0}, {"main.main.func3", 0}, }}, {trace.EventStateTransition, "Goroutine Running->Waiting", []frame{ {"runtime.chanrecv1", 0}, {"main.main.func4", 0}, }}, {trace.EventStateTransition, "Goroutine Waiting->Runnable", []frame{ {"runtime.chansend1", 0},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 18.5K bytes - Viewed (0) -
src/internal/trace/oldtrace.go
lastStwReason uint64 inlineToStringID []uint64 builtinToStringID []uint64 } const ( // Block reasons sForever = iota sPreempted sGosched sSleep sChanSend sChanRecv sNetwork sSync sSyncCond sSelect sEmpty sMarkAssistWait // STW kinds sSTWUnknown sSTWGCMarkTermination sSTWGCSweepTermination sSTWWriteHeapDump sSTWGoroutineProfile
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 17.2K bytes - Viewed (0) -
src/cmd/compile/internal/walk/walk.go
func walkRecv(n *ir.UnaryExpr) ir.Node { if n.Typecheck() == 0 { base.Fatalf("missing typecheck: %+v", n) } init := ir.TakeInit(n) n.X = walkExpr(n.X, &init) call := walkExpr(mkcall1(chanfn("chanrecv1", 2, n.X.Type()), nil, &init, n.X, typecheck.NodNil()), &init) return ir.InitExpr(init, call) } func convas(n *ir.AssignStmt, init *ir.Nodes) *ir.AssignStmt { if n.Op() != ir.OAS {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 20:56:00 UTC 2024 - 10.4K bytes - Viewed (0)