Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. src/go/types/check.go

    		m[node] = obj
    	}
    }
    
    func (check *Checker) recordSelection(x *ast.SelectorExpr, kind SelectionKind, recv Type, obj Object, index []int, indirect bool) {
    	assert(obj != nil && (recv == nil || len(index) > 0))
    	check.recordUse(x.Sel, obj)
    	if m := check.Selections; m != nil {
    		m[x] = &Selection{kind, recv, obj, index, indirect}
    	}
    }
    
    func (check *Checker) recordScope(node ast.Node, scope *Scope) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  9. src/cmd/vendor/golang.org/x/tools/go/ast/astutil/rewrite.go

    	case *ast.BadDecl:
    		// nothing to do
    
    	case *ast.GenDecl:
    		a.apply(n, "Doc", nil, n.Doc)
    		a.applyList(n, "Specs")
    
    	case *ast.FuncDecl:
    		a.apply(n, "Doc", nil, n.Doc)
    		a.apply(n, "Recv", nil, n.Recv)
    		a.apply(n, "Name", nil, n.Name)
    		a.apply(n, "Type", nil, n.Type)
    		a.apply(n, "Body", nil, n.Body)
    
    	// Files and packages
    	case *ast.File:
    		a.apply(n, "Doc", nil, n.Doc)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Dec 18 21:28:13 UTC 2023
    - 12.2K bytes
    - Viewed (0)
  10. tensorflow/compiler/mlir/tensorflow/ir/tf_executor_ops.td

        it always produces a valid output even when inputs are dead.
      }];
    
      let description = [{
        Its primary use so far is in the scheduling of recvs, where we add
        ControlTrigger nodes and use them to trigger recvs. We allow ControlTrigger
        nodes to be enabled by dead nodes.
      }];
    
      let arguments = (ins
        Variadic<TfeControlType>:$controlInputs
      );
      let results = (outs
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Feb 23 19:35:12 UTC 2023
    - 22K bytes
    - Viewed (0)
Back to top