Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for chanrecv2 (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. test/live.go

    func f19() {
    	// dest temporary for channel receive.
    	var z *byte
    
    	if b {
    		z = <-ch // ERROR "stack object .autotmp_[0-9]+ \*byte$"
    	}
    	z = <-ch
    	z = <-ch // ERROR "live at call to chanrecv1: .autotmp_[0-9]+$"
    	printbytepointer(z)
    }
    
    func f20() {
    	// src temporary for channel send
    	if b {
    		ch <- byteptr() // ERROR "stack object .autotmp_[0-9]+ \*byte$"
    	}
    	ch <- byteptr()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Dec 05 20:34:30 UTC 2023
    - 18K bytes
    - Viewed (0)
  10. src/cmd/cgo/internal/testerrors/ptr_test.go

    		body:    `r, _, _ := os.Pipe(); r.SetDeadline(time.Now().Add(C.US31 * time.Microsecond))`,
    		fail:    false,
    	},
    	{
    		// Test for double evaluation of channel receive.
    		name:    "chanrecv",
    		c:       `void f32(char** p) {}`,
    		imports: []string{"time"},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Aug 03 16:07:49 UTC 2023
    - 21.2K bytes
    - Viewed (0)
Back to top