Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 113 for recvq (0.04 sec)

  1. test/chan/select7.go

    	select {
    	case c <- 1:
    	}
    }
    
    func send3(recv func(<-chan int)) {
    	c := make(chan int)
    	go recv(c)
    	runtime.Gosched()
    	c2 := make(chan int)
    	select {
    	case c <- 1:
    	case c2 <- 1:
    	}
    }
    
    func main() {
    	send1(recv1)
    	send2(recv1)
    	send3(recv1)
    	send1(recv2)
    	send2(recv2)
    	send3(recv2)
    	send1(recv3)
    	send2(recv3)
    	send3(recv3)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 02 13:43:18 UTC 2016
    - 932 bytes
    - Viewed (0)
  2. src/cmd/vendor/golang.org/x/tools/internal/typesinternal/recv.go

    	"golang.org/x/tools/internal/aliases"
    )
    
    // ReceiverNamed returns the named type (if any) associated with the
    // type of recv, which may be of the form N or *N, or aliases thereof.
    // It also reports whether a Pointer was present.
    func ReceiverNamed(recv *types.Var) (isPtr bool, named *types.Named) {
    	t := recv.Type()
    	if ptr, ok := aliases.Unalias(t).(*types.Pointer); ok {
    		isPtr = true
    		t = ptr.Elem()
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  3. test/typeparam/append.go

    package main
    
    type Recv <-chan int
    
    type sliceOf[E any] interface {
    	~[]E
    }
    
    func _Append[S sliceOf[T], T any](s S, t ...T) S {
    	return append(s, t...)
    }
    
    func main() {
    	recv := make(Recv)
    	a := _Append([]Recv{recv}, recv)
    	if len(a) != 2 || a[0] != recv || a[1] != recv {
    		panic(a)
    	}
    
    	recv2 := make(chan<- int)
    	a2 := _Append([]chan<- int{recv2}, recv2)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 01 19:45:34 UTC 2022
    - 597 bytes
    - Viewed (0)
  4. test/closedchan.go

    	if x := c.Recv(); x != 1 {
    		println("testasync1: Recv did not get 1:", x, c.Impl())
    		failed = true
    	}
    
    	test1(c)
    }
    
    func testasync2(c Chan) {
    	// should be able to get the last value via Recv2
    	if x, ok := c.Recv2(); x != 1 || !ok {
    		println("testasync1: Recv did not get 1, true:", x, ok, c.Impl())
    		failed = true
    	}
    
    	test1(c)
    }
    
    func testasync3(c Chan) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 17 04:48:57 UTC 2012
    - 5.8K bytes
    - Viewed (0)
  5. test/struct0.go

    // Issue 2232.
    
    package main
    
    func recv(c chan interface{}) struct{} {
    	return (<-c).(struct{})
    }
    
    var m = make(map[interface{}]int)
    
    func recv1(c chan interface{}) {
    	defer rec()
    	m[(<-c).(struct{})] = 0
    }
    
    func rec() {
    	recover()
    }
    
    func main() {
    	c := make(chan interface{})
    	go recv(c)
    	c <- struct{}{}
    	go recv1(c)
    	c <- struct{}{}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 02 13:43:18 UTC 2016
    - 565 bytes
    - Viewed (0)
  6. test/ken/chan.go

    	go sel(ca[0], ca[1], ca[2], ca[3], nc, nc, nc, nc)
    }
    
    // select send to direct recv
    func test3(c int) {
    	ca := mkchan(c, 4)
    
    	changeNproc(4)
    	go recv(ca[0])
    	go recv(ca[1])
    	go recv(ca[2])
    	go recv(ca[3])
    
    	changeNproc(1)
    	go sel(nc, nc, nc, nc, ca[0], ca[1], ca[2], ca[3])
    }
    
    // select send to select recv
    func test4(c int) {
    	ca := mkchan(c, 4)
    
    	changeNproc(2)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 24 05:24:24 UTC 2012
    - 4.7K bytes
    - Viewed (0)
  7. pilot/test/xdstest/grpc.go

    	"istio.io/istio/pkg/log"
    	"istio.io/istio/pkg/sleep"
    )
    
    type slowClientStream struct {
    	grpc.ClientStream
    	recv, send time.Duration
    }
    
    func (w *slowClientStream) RecvMsg(m any) error {
    	if w.recv > 0 {
    		sleep.UntilContext(w.Context(), w.recv)
    		log.Infof("delayed recv for %v", w.recv)
    	}
    	return w.ClientStream.RecvMsg(m)
    }
    
    func (w *slowClientStream) SendMsg(m any) error {
    	if w.send > 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  8. src/cmd/vendor/golang.org/x/tools/internal/stdlib/stdlib.go

    //
    // Example: "(*Buffer).Grow" -> (true, "Buffer", "Grow")
    func (sym *Symbol) SplitMethod() (ptr bool, recv, name string) {
    	if sym.Kind != Method {
    		panic("not a method")
    	}
    	recv, name, _ = strings.Cut(sym.Name, ".")
    	recv = recv[len("(") : len(recv)-len(")")]
    	ptr = recv[0] == '*'
    	if ptr {
    		recv = recv[len("*"):]
    	}
    	return
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  9. src/cmd/compile/internal/types2/selection.go

    func (s *Selection) Type() Type {
    	switch s.kind {
    	case MethodVal:
    		// The type of x.f is a method with its receiver type set
    		// to the type of x.
    		sig := *s.obj.(*Func).typ.(*Signature)
    		recv := *sig.recv
    		recv.typ = s.recv
    		sig.recv = &recv
    		return &sig
    
    	case MethodExpr:
    		// The type of x.f is a function (without receiver)
    		// and an additional first argument with the same type as x.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Feb 22 19:32:17 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  10. src/go/types/selection.go

    func (s *Selection) Type() Type {
    	switch s.kind {
    	case MethodVal:
    		// The type of x.f is a method with its receiver type set
    		// to the type of x.
    		sig := *s.obj.(*Func).typ.(*Signature)
    		recv := *sig.recv
    		recv.typ = s.recv
    		sig.recv = &recv
    		return &sig
    
    	case MethodExpr:
    		// The type of x.f is a function (without receiver)
    		// and an additional first argument with the same type as x.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Apr 03 18:48:38 UTC 2024
    - 5.9K bytes
    - Viewed (0)
Back to top