Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for makeChan (0.21 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/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)
  5. 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)
  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/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)
  8. 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)
  9. tensorflow/compiler/mlir/quantization/tensorflow/python/quantize_model.cc

      absl::StatusOr<mlir::OwningOpRef<mlir::ModuleOp>> module =
          SavedModelSignatureDefsToMlirImport(saved_model_path, tags,
                                              absl::MakeSpan(exported_names),
                                              context, import_options, &bundle);
      if (!module.status().ok()) {
        return absl::InternalError(absl::StrCat("Failed to import SavedModel: ",
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Fri May 17 03:36:50 UTC 2024
    - 23.8K bytes
    - Viewed (0)
Back to top