Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 104 for recvq (0.12 sec)

  1. src/go/doc/comment/parse.go

    	pkg, name, ok := splitDocName(text)
    	var recv string
    	if ok {
    		pkg, recv, _ = splitDocName(pkg)
    	}
    	if pkg != "" {
    		if pkg, ok = d.lookupPkg(pkg); !ok {
    			return nil, false
    		}
    	} else {
    		if ok = d.lookupSym(recv, name); !ok {
    			return nil, false
    		}
    	}
    	link = &DocLink{
    		ImportPath: pkg,
    		Recv:       recv,
    		Name:       name,
    	}
    	return link, true
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 12:02:03 UTC 2023
    - 33.5K bytes
    - Viewed (0)
  2. src/go/parser/resolver.go

    	}
    }
    
    func (r *resolver) walkRecv(recv *ast.FieldList) {
    	// If our receiver has receiver type parameters, we must declare them before
    	// trying to resolve the rest of the receiver, and avoid re-resolving the
    	// type parameter identifiers.
    	if recv == nil || len(recv.List) == 0 {
    		return // nothing to do
    	}
    	typ := recv.List[0].Type
    	if ptr, ok := typ.(*ast.StarExpr); ok {
    		typ = ptr.X
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Nov 02 12:56:53 UTC 2023
    - 15.8K bytes
    - Viewed (0)
  3. src/go/internal/gcimporter/iimport.go

    			mpos := r.pos()
    			mname := r.ident()
    
    			// TODO(mdempsky): Matches bimport.go, but I
    			// don't agree with this.
    			var recv *types.Var
    			if base != nil {
    				recv = types.NewVar(token.NoPos, r.currPkg, "", base)
    			}
    
    			msig := r.signature(recv, nil, nil)
    			methods[i] = types.NewFunc(mpos, r.currPkg, mname, msig)
    		}
    
    		typ := types.NewInterfaceType(methods, embeddeds)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  4. pkg/istio-agent/xds_proxy.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
    		// Requests channel is unbounded. The Envoy<->XDS Proxy<->Istiod system produces a natural
    		// looping of Recv and Send. Due to backpressure introduced by gRPC natively (that is, Send() can
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  5. src/go/types/resolver.go

    				hasTParamError := false                           // avoid duplicate type parameter errors
    				if d.decl.Recv.NumFields() == 0 {
    					// regular function
    					if d.decl.Recv != nil {
    						check.error(d.decl.Recv, BadRecv, "method has no receiver")
    						// treat as function
    					}
    					if name == "init" || (name == "main" && check.pkg.name == "main") {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 16:22:59 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  6. src/cmd/vendor/golang.org/x/tools/go/ast/astutil/enclosing.go

    		// in fact, FuncDecl.Recv precedes FuncDecl.Type.Func.
    		//
    		// As a workaround, we inline the case for FuncType
    		// here and order things correctly.
    		//
    		children = nil // discard ast.Walk(FuncDecl) info subtrees
    		children = append(children, tok(n.Type.Func, len("func")))
    		if n.Recv != nil {
    			children = append(children, n.Recv)
    		}
    		children = append(children, n.Name)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Dec 18 21:28:13 UTC 2023
    - 15.9K bytes
    - Viewed (0)
  7. src/cmd/vendor/golang.org/x/tools/go/analysis/passes/loopclosure/loopclosure.go

    	f := typeutil.StaticCallee(info, call)
    	if f == nil || f.Name() != method {
    		return false
    	}
    	recv := f.Type().(*types.Signature).Recv()
    	if recv == nil {
    		return false
    	}
    
    	// Check that the receiver is a <pkgPath>.<typeName> or
    	// *<pkgPath>.<typeName>.
    	_, named := typesinternal.ReceiverNamed(recv)
    	return analysisutil.IsNamedType(named, pkgPath, typeName)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  8. src/cmd/compile/internal/types2/object.go

    		sig := f.typ.(*Signature)
    		if recv := sig.Recv(); recv != nil {
    			buf.WriteByte('(')
    			if _, ok := recv.Type().(*Interface); ok {
    				// gcimporter creates abstract methods of
    				// named interfaces using the interface type
    				// (not the named type) as the receiver.
    				// Don't print it in full.
    				buf.WriteString("interface")
    			} else {
    				WriteType(buf, recv.Type(), qf)
    			}
    			buf.WriteByte(')')
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 07 20:08:23 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  9. src/cmd/cgo/ast.go

    		case *ast.FuncDecl:
    			// Also, reject attempts to declare methods on C.T or *C.T.
    			// (The generated code would otherwise accept this
    			// invalid input; see issue #57926.)
    			if decl.Recv != nil && len(decl.Recv.List) > 0 {
    				recvType := decl.Recv.List[0].Type
    				if recvType != nil {
    					t := recvType
    					if star, ok := unparen(t).(*ast.StarExpr); ok {
    						t = star.X
    					}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 07 16:54:27 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  10. tensorflow/compiler/mlir/tfrt/tests/mlrt/tpu_conversions.mlir

      // CHECK: [[recv_future:%.*]] = tf_mlrt.async_executeop.device([[device]]){{.*}}op: \22Recv\22
      // CHECK: [[recv:%.*]] = tf_mlrt.await [[recv_future]]
      // CHECK: [[rendezvous_key_base:%.*]], [[result_future:%.*]] = tf_mlrt_tpu.compile_and_execute([[recv]])
      // CHECK: tf_mlrt.await [[result_future]]
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Oct 04 21:25:31 UTC 2023
    - 11K bytes
    - Viewed (0)
Back to top