Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 104 for recvq (0.09 sec)

  1. src/go/internal/gcimporter/ureader.go

    	r.p.ifaces = append(r.p.ifaces, iface)
    
    	return iface
    }
    
    func (r *reader) signature(recv *types.Var, rtparams, tparams []*types.TypeParam) *types.Signature {
    	r.Sync(pkgbits.SyncSignature)
    
    	params := r.params()
    	results := r.params()
    	variadic := r.Bool()
    
    	return types.NewSignatureType(recv, rtparams, tparams, params, results, variadic)
    }
    
    func (r *reader) params() *types.Tuple {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. src/cmd/doc/pkg.go

    		}
    		return ""
    
    	case *ast.FuncDecl:
    		// Formats func declarations.
    		name := n.Name.Name
    		recv := pkg.oneLineNodeDepth(n.Recv, depth)
    		if len(recv) > 0 {
    			recv = "(" + recv + ") "
    		}
    		fnc := pkg.oneLineNodeDepth(n.Type, depth)
    		fnc = strings.TrimPrefix(fnc, "func")
    		return fmt.Sprintf("func %s%s%s", recv, name, fnc)
    
    	case *ast.TypeSpec:
    		sep := " "
    		if n.Assign.IsValid() {
    			sep = " = "
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jan 08 20:15:52 UTC 2024
    - 32K bytes
    - Viewed (0)
  3. tensorflow/compiler/mlir/tensorflow/ir/tf_device_ops.td

        communication via send/recvs). In this case, users of ParallelExecute op
        must provide correct control dependencies between regions to guarantee
        correctness. Regions in ParallelExecute may include Resource ops.
    
        In the case where different regions include ops access the same resource,
        the users of the ParallelExecute op must provide mechanism (via send/recvs
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Jan 23 23:53:20 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  4. src/cmd/fix/fix.go

    		}
    		walkBeforeAfter(&n.Type, before, after)
    
    	case *ast.BadDecl:
    	case *ast.GenDecl:
    		walkBeforeAfter(&n.Specs, before, after)
    	case *ast.FuncDecl:
    		if n.Recv != nil {
    			walkBeforeAfter(&n.Recv, before, after)
    		}
    		walkBeforeAfter(&n.Type, before, after)
    		if n.Body != nil {
    			walkBeforeAfter(&n.Body, before, after)
    		}
    
    	case *ast.File:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Dec 13 18:45:54 UTC 2021
    - 14.6K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/walk/order.go

    				base.Fatalf("unknown op in select %v", r.Op())
    
    			case ir.OSELRECV2:
    				// case x, ok = <-c
    				r := r.(*ir.AssignListStmt)
    				recv := r.Rhs[0].(*ir.UnaryExpr)
    				recv.X = o.expr(recv.X, nil)
    				if !ir.IsAutoTmp(recv.X) {
    					recv.X = o.copyExpr(recv.X)
    				}
    				init := ir.TakeInit(r)
    
    				colas := r.Def
    				do := func(i int, t *types.Type) {
    					n := r.Lhs[i]
    					if ir.IsBlank(n) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 08 02:00:33 UTC 2024
    - 42.7K bytes
    - Viewed (0)
  6. src/cmd/compile/internal/types2/call.go

    		// are rare.)
    		name := ""
    		if len(params) > 0 && params[0].name != "" {
    			// name needed
    			name = sig.recv.name
    			if name == "" {
    				name = "_"
    			}
    		}
    		params = append([]*Var{NewVar(sig.recv.pos, sig.recv.pkg, name, x.typ)}, params...)
    		x.mode = value
    		x.typ = &Signature{
    			tparams:  sig.tparams,
    			params:   NewTuple(params...),
    			results:  sig.results,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 31.5K bytes
    - Viewed (0)
  7. src/cmd/compile/internal/typecheck/stmt.go

    			} else {
    				def = ncase
    			}
    		} else {
    			n := Stmt(ncase.Comm)
    			ncase.Comm = n
    			oselrecv2 := func(dst, recv ir.Node, def bool) {
    				selrecv := ir.NewAssignListStmt(n.Pos(), ir.OSELRECV2, []ir.Node{dst, ir.BlankNode}, []ir.Node{recv})
    				selrecv.Def = def
    				selrecv.SetTypecheck(1)
    				selrecv.SetInit(n.Init())
    				ncase.Comm = selrecv
    			}
    			switch n.Op() {
    			default:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Nov 20 15:10:54 UTC 2023
    - 17.8K bytes
    - Viewed (0)
  8. src/go/internal/gccgoimporter/testdata/v1reflect.gox

     func (v <type 1>) OverflowInt (x <type -4>) <type -15>;
     func (v <type 1>) OverflowUint (x <type -8>) <type -15>;
     func (v <type 1>) Pointer () <type -13>;
     func (v <type 1>) Recv () (x <type 1>, ok <type -15>);
     func (v <type 1>) .reflect.recv (nb <type -15>) (val <type 1>, ok <type -15>);
     func (v <type 1>) Send (x <type 1>);
     func (v <type 1>) .reflect.send (x <type 1>, nb <type -15>) (selected <type -15>);
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Sep 30 21:33:51 UTC 2021
    - 10.3K bytes
    - Viewed (0)
  9. src/go/types/call.go

    		// are rare.)
    		name := ""
    		if len(params) > 0 && params[0].name != "" {
    			// name needed
    			name = sig.recv.name
    			if name == "" {
    				name = "_"
    			}
    		}
    		params = append([]*Var{NewVar(sig.recv.pos, sig.recv.pkg, name, x.typ)}, params...)
    		x.mode = value
    		x.typ = &Signature{
    			tparams:  sig.tparams,
    			params:   NewTuple(params...),
    			results:  sig.results,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  10. docs/bigdata/README.md

    fs.s3a.max.total.tasks=2048 # Maximum number of parallel tasks
    fs.s3a.multipart.size=512M # Size of each multipart chunk
    fs.s3a.multipart.threshold=512M # Size before using multipart uploads
    fs.s3a.socket.recv.buffer=65536 # Read socket buffer hint
    fs.s3a.socket.send.buffer=65536 # Write socket buffer hint
    fs.s3a.threads.max=2048 # Maximum number of threads for S3A
    ```
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
Back to top