Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for makeChan (0.25 sec)

  1. 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)
  2. src/cmd/internal/goobj/builtinlist.go

    	{"runtime.mapdelete_fast32", 1},
    	{"runtime.mapdelete_fast64", 1},
    	{"runtime.mapdelete_faststr", 1},
    	{"runtime.mapiternext", 1},
    	{"runtime.mapclear", 1},
    	{"runtime.makechan64", 1},
    	{"runtime.makechan", 1},
    	{"runtime.chanrecv1", 1},
    	{"runtime.chanrecv2", 1},
    	{"runtime.chansend1", 1},
    	{"runtime.closechan", 1},
    	{"runtime.chanlen", 1},
    	{"runtime.chancap", 1},
    	{"runtime.writeBarrier", 0},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 21 21:08:03 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  3. 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)
  4. src/reflect/value.go

    }
    
    // MakeChan creates a new channel with the specified type and buffer size.
    func MakeChan(typ Type, buffer int) Value {
    	if typ.Kind() != Chan {
    		panic("reflect.MakeChan of non-chan type")
    	}
    	if buffer < 0 {
    		panic("reflect.MakeChan: negative buffer size")
    	}
    	if typ.ChanDir() != BothDir {
    		panic("reflect.MakeChan: unidirectional channel type")
    	}
    	t := typ.common()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:17:41 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  5. 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)
  6. src/reflect/all_test.go

    	// check creation of unbuffered channel
    	var c chan int
    	cv := MakeChan(TypeOf(c), 0)
    	c = cv.Interface().(chan int)
    	if cv.TrySend(ValueOf(7)) {
    		t.Errorf("TrySend on sync chan succeeded")
    	}
    	if v, ok := cv.TryRecv(); v.IsValid() || ok {
    		t.Errorf("TryRecv on sync chan succeeded: isvalid=%v ok=%v", v.IsValid(), ok)
    	}
    
    	// len/cap
    	cv = MakeChan(TypeOf(c), 10)
    	c = cv.Interface().(chan int)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 218.8K bytes
    - Viewed (0)
  7. tensorflow/c/experimental/saved_model/core/ops/variable_ops.cc

                                      strlen(ResourceHandle::ANONYMOUS_NAME)));
    
      AbstractTensorHandle* var_handle = nullptr;
      int num_retvals = 1;
      TF_RETURN_IF_ERROR(varhandle_op->Execute(
          absl::MakeSpan(&var_handle, num_retvals), &num_retvals));
      AbstractTensorHandlePtr owned_var_handle(var_handle);
      if (!tensorflow::isa<ImmediateExecutionTensorHandle>(
              owned_var_handle.get())) {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Apr 23 11:28:19 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. tensorflow/compiler/mlir/quantization/stablehlo/cc/saved_model_import.cc

      // Copy to eliminate the `const` qualifier so that `absl::MakeSpan` can be
      // called on it.
      std::vector<std::string> exported_names = signature_keys;
      absl::StatusOr<OwningOpRef<ModuleOp>> module_op =
          SavedModelSignatureDefsToMlirImport(saved_model_path, tags,
                                              absl::MakeSpan(exported_names), &ctx,
                                              import_options, &bundle);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Apr 24 12:49:45 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  9. 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)
  10. src/internal/fmtsort/sort_test.go

    				return fmt.Sprintf("CHAN%d", i)
    			}
    		}
    		return "CHAN???"
    	default:
    		return fmt.Sprint(key)
    	}
    }
    
    var (
    	ints  [3]int
    	chans = makeChans()
    	pin   runtime.Pinner
    )
    
    func makeChans() []chan int {
    	cs := []chan int{make(chan int), make(chan int), make(chan int)}
    	// Order channels by address. See issue #49431.
    	for i := range cs {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 6.9K bytes
    - Viewed (0)
Back to top