Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 104 for recvq (0.12 sec)

  1. src/go/types/subst.go

    		// In this case, the type of f is an interface that is itself the receiver
    		// type of all of its methods. Because we have no type name to break
    		// cycles, substituting in the recv results in an infinite loop of
    		// recv->interface->recv->interface->...
    		recv := t.recv
    
    		params := subst.tuple(t.params)
    		results := subst.tuple(t.results)
    		if params != t.params || results != t.results {
    			return &Signature{
    				rparams: t.rparams,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:04:07 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  2. test/escape_reflect.go

    	mv := reflect.ValueOf(m)
    	it.Reset(mv)
    }
    
    func recv1(ch chan string) string { // ERROR "ch does not escape"
    	v := reflect.ValueOf(ch)
    	r, _ := v.Recv()
    	return r.String()
    }
    
    func recv2(ch chan string) string { // ERROR "ch does not escape"
    	v := reflect.ValueOf(ch)
    	r, _ := v.TryRecv()
    	return r.String()
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Sep 08 18:50:24 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  3. test/chan/select5.go

    }
    `
    
    func parse(name, s string) *template.Template {
    	t, err := template.New(name).Parse(s)
    	if err != nil {
    		panic(fmt.Sprintf("%q: %s", name, err))
    	}
    	return t
    }
    
    var recv = parse("recv", `
    	{{/*  Send n, receive it one way or another into x, check that they match. */}}
    	c <- n
    	{{if .Maybe}}
    	x = <-c
    	{{else}}
    	select {
    	{{/*  Blocking or non-blocking, before the receive. */}}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 02 13:43:18 UTC 2016
    - 10K bytes
    - Viewed (0)
  4. src/cmd/compile/internal/types2/subst.go

    		// In this case, the type of f is an interface that is itself the receiver
    		// type of all of its methods. Because we have no type name to break
    		// cycles, substituting in the recv results in an infinite loop of
    		// recv->interface->recv->interface->...
    		recv := t.recv
    
    		params := subst.tuple(t.params)
    		results := subst.tuple(t.results)
    		if params != t.params || results != t.results {
    			return &Signature{
    				rparams: t.rparams,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:04:07 UTC 2024
    - 11K bytes
    - Viewed (0)
  5. src/go/doc/reader.go

    	}
    	// function doesn't exist or has no documentation; use f
    	recv := ""
    	if f.Recv != nil {
    		var typ ast.Expr
    		// be careful in case of incorrect ASTs
    		if list := f.Recv.List; len(list) == 1 {
    			typ = list[0].Type
    		}
    		recv = recvString(typ)
    	}
    	mset[name] = &Func{
    		Doc:  f.Doc.Text(),
    		Name: name,
    		Decl: f,
    		Recv: recv,
    		Orig: recv,
    	}
    	if !preserveAST {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 27.5K bytes
    - Viewed (0)
  6. src/go/doc/doc.go

    //
    // If recv == "", HasSym reports whether the package has a top-level
    // const, func, type, or var named name.
    //
    // If recv != "", HasSym reports whether the package has a type
    // named recv with a method named name.
    func (p *Package) lookupSym(recv, name string) bool {
    	if recv != "" {
    		return p.syms[recv+"."+name]
    	}
    	return p.syms[name]
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 12:02:03 UTC 2023
    - 11.2K bytes
    - Viewed (0)
  7. pkg/istio-agent/xds_proxy_delta.go

    	con := &ProxyConnection{
    		conID:             connectionNumber.Inc(),
    		upstreamError:     make(chan error), // can be produced by recv and send
    		downstreamError:   make(chan error), // can be produced by recv and send
    		deltaRequestsChan: channels.NewUnbounded[*discovery.DeltaDiscoveryRequest](),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 04 20:29:08 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  8. src/cmd/vendor/golang.org/x/tools/go/analysis/passes/copylock/copylock.go

    // inadvertently copy a lock, by checking whether
    // its receiver, parameters, or return values
    // are locks.
    func checkCopyLocksFunc(pass *analysis.Pass, name string, recv *ast.FieldList, typ *ast.FuncType) {
    	if recv != nil && len(recv.List) > 0 {
    		expr := recv.List[0].Type
    		if path := lockPath(pass.Pkg, pass.TypesInfo.Types[expr].Type, nil); path != nil {
    			pass.ReportRangef(expr, "%s passes lock by value: %v", name, path)
    		}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  9. src/net/net_windows_test.go

    	}()
    
    	// Receive first or second connection.
    	s, err := recv(ln, true)
    	if err != nil {
    		t.Fatalf("recv failed: %v", err)
    	}
    	switch s {
    	case "":
    		// First connection data is received, let's get second connection data.
    	case "abc":
    		// First connection is lost forever, but that is ok.
    		return
    	default:
    		t.Fatalf(`"%s" received from recv, but "" or "abc" expected`, s)
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  10. src/cmd/compile/internal/typecheck/typecheck.go

    // expression "recv.sym".
    func NewMethodExpr(pos src.XPos, recv *types.Type, sym *types.Sym) *ir.SelectorExpr {
    	// Compute the method set for recv.
    	var ms []*types.Field
    	if recv.IsInterface() {
    		ms = recv.AllMethods()
    	} else {
    		mt := types.ReceiverBaseType(recv)
    		if mt == nil {
    			base.FatalfAt(pos, "type %v has no receiver base type", recv)
    		}
    		CalcMethods(mt)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 20 19:08:34 UTC 2024
    - 30.5K bytes
    - Viewed (0)
Back to top