- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for makeChan (0.4 sec)
-
src/runtime/chan.go
first *sudog last *sudog } //go:linkname reflect_makechan reflect.makechan func reflect_makechan(t *chantype, size int) *hchan { return makechan(t, size) } func makechan64(t *chantype, size int64) *hchan { if int64(int(size)) != size { panic(plainError("makechan: size out of range")) } return makechan(t, int(size)) } func makechan(t *chantype, size int) *hchan { elem := t.Elem
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
src/cmd/compile/internal/walk/builtin.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 22:35:22 UTC 2024 - 31.2K bytes - Viewed (0) -
src/cmd/compile/internal/typecheck/_builtin/runtime.go
func mapiternext(hiter *any) func mapclear(mapType *byte, hmap map[any]any) // *byte is really *runtime.Type func makechan64(chanType *byte, size int64) (hchan chan any) func makechan(chanType *byte, size int) (hchan chan any) func chanrecv1(hchan <-chan any, elem *any) func chanrecv2(hchan <-chan any, elem *any) bool func chansend1(hchan chan<- any, elem *any) func closechan(hchan chan<- any)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 21:08:03 UTC 2024 - 10.6K bytes - Viewed (0) -
src/cmd/compile/internal/typecheck/builtin.go
{"mapdelete_fast32", funcTag, 92}, {"mapdelete_fast64", funcTag, 93}, {"mapdelete_faststr", funcTag, 94}, {"mapiternext", funcTag, 95}, {"mapclear", funcTag, 96}, {"makechan64", funcTag, 98}, {"makechan", funcTag, 99}, {"chanrecv1", funcTag, 101}, {"chanrecv2", funcTag, 102}, {"chansend1", funcTag, 104}, {"closechan", funcTag, 105}, {"chanlen", funcTag, 106}, {"chancap", funcTag, 106},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 21:08:03 UTC 2024 - 16.2K bytes - Viewed (0) -
src/cmd/compile/internal/staticinit/sched.go
if n.Y.Op() != ir.OLITERAL || constant.Sign(n.Y.Val()) == 0 { return true } // Only possible side effect is panic on invalid size, // but many makechan and makemap use size zero, which is definitely OK. case ir.OMAKECHAN, ir.OMAKEMAP: n := n.(*ir.MakeExpr) if !ir.IsConst(n.Len, constant.Int) || constant.Sign(n.Len.Val()) != 0 { return true }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 17:16:14 UTC 2024 - 30.7K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_compile_on_demand_op.cc
GatherVariableInfo(ctx, *result, 0); TF_RETURN_IF_ERROR(variable_infos.status()); TF_RETURN_IF_ERROR(LockVariables(absl::MakeSpan(*variable_infos))); TF_RETURN_IF_ERROR(launch_context.PopulateOutputs( ctx, result, execution_output.ConsumeResult(), /*missing_ctx_input_prefix=*/0, absl::MakeSpan(*variable_infos), input_output_alias, snapshot_ptrs)); return absl::OkStatus(); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 29 08:39:39 UTC 2024 - 13.4K bytes - Viewed (0) -
tensorflow/compiler/jit/kernels/xla_ops.cc
OP_REQUIRES_OK(ctx, variable_infos.status()); OP_REQUIRES_OK(ctx, LockVariables(absl::MakeSpan(*variable_infos))); OP_REQUIRES_OK( ctx, launch_context.PopulateOutputs( ctx, closure.compilation_result(), execution_output->ConsumeResult(), /*missing_ctx_input_prefix=*/closure.num_constant_args(), absl::MakeSpan(*variable_infos), input_output_alias, snapshot_ptrs)); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 22:46:36 UTC 2024 - 41.4K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
} if len(pods) == 0 { return nil, ControlPlaneNotFoundError{istioNamespace} } responses := []*discovery.DiscoveryResponse{} xdsOpts := clioptions.CentralControlPlaneOptions{ XDSSAN: makeSan(istioNamespace, kubeClient.Revision()), CertDir: centralOpts.CertDir, Timeout: centralOpts.Timeout, } dialOpts, err := xds.DialOptions(xdsOpts, istioNamespace, tokenServiceAccount, kubeClient) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 13.6K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_launch_util_test.cc
TF_ASSERT_OK_AND_ASSIGN(std::vector<int> constant_input_indices, GetConstantInputIndicesFromContext(context_.get())); TF_ASSERT_OK(LockVariables(absl::MakeSpan(variables))); TF_ASSERT_OK_AND_ASSIGN( std::vector<XlaCompiler::Argument> args, XlaComputationLaunchContext::BuildXlaCompilerArguments( constant_input_indices, inputs, variables,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 09:53:30 UTC 2024 - 28.8K bytes - Viewed (0) -
tensorflow/c/experimental/next_pluggable_device/c_api.cc
variable_ptrs.reserve(num_vars); for (int i = 0; i < num_vars; ++i) { variable_ptrs.push_back(&(vars[i]->var_info)); } absl::Status cc_status = LockVariables(absl::MakeSpan(variable_ptrs)); status->status = cc_status; } void TF_AllocateTempForVariableInfo(TF_OpKernelContext* ctx, TF_VariableInfo* var_info,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Apr 22 05:48:24 UTC 2024 - 13.9K bytes - Viewed (0)