Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 254 for chanOf (0.29 sec)

  1. src/go/parser/parser.go

    		//   <- expr  => <-(expr) is a receive from an expression
    		//
    		// In the first case, the arrow must be re-associated with
    		// the channel type parsed already:
    		//
    		//   <- (chan type)    =>  (<-chan type)
    		//   <- (chan<- type)  =>  (<-chan (<-type))
    
    		x := p.parseUnaryExpr()
    
    		// determine which case we have
    		if typ, ok := x.(*ast.ChanType); ok {
    			// (<-type)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Dec 08 20:07:50 UTC 2023
    - 72.2K bytes
    - Viewed (0)
  2. src/runtime/malloc.go

    		// ~258MB, so this isn't too bad. (We could reserve a
    		// smaller amount of space up front if this is a
    		// problem.)
    		//
    		// 2. We hint the heap to start right above the end of
    		// the binary so we have the best chance of keeping it
    		// contiguous.
    		//
    		// 3. We try to stake out a reasonably large initial
    		// heap reservation.
    
    		const arenaMetaSize = (1 << arenaBits) * unsafe.Sizeof(heapArena{})
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 59.6K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/sys/windows/setupapi_windows.go

    )
    
    // DICS_FLAG specifies the scope of a device property change
    type DICS_FLAG uint32
    
    const (
    	DICS_FLAG_GLOBAL         DICS_FLAG = 0x00000001 // make change in all hardware profiles
    	DICS_FLAG_CONFIGSPECIFIC DICS_FLAG = 0x00000002 // make change in specified profile only
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Oct 26 00:11:50 UTC 2022
    - 67.2K bytes
    - Viewed (0)
  4. pkg/controller/history/controller_history_test.go

    	}
    	testFn := func(test *testcase, t *testing.T) {
    		client := fake.NewSimpleClientset()
    		informerFactory := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc())
    
    		stop := make(chan struct{})
    		defer close(stop)
    		informerFactory.Start(stop)
    		informer := informerFactory.Apps().V1().ControllerRevisions()
    		informerFactory.WaitForCacheSync(stop)
    		for i := range test.revisions {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 21 13:31:28 UTC 2023
    - 49.1K bytes
    - Viewed (0)
  5. pkg/kubelet/server/server_test.go

    			expectedCommand := "ls -a"
    			expectedStdin := "stdin"
    			expectedStdout := "stdout"
    			expectedStderr := "stderr"
    			done := make(chan struct{})
    			clientStdoutReadDone := make(chan struct{})
    			clientStderrReadDone := make(chan struct{})
    			execInvoked := false
    			attachInvoked := false
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.5K bytes
    - Viewed (0)
  6. pkg/controller/job/job_controller.go

    	// never return error
    	key, err := controller.KeyFunc(curJob)
    	if err != nil {
    		return
    	}
    
    	if curJob.Generation == oldJob.Generation {
    		// Delay the Job sync when no generation change to batch Job status updates,
    		// typically triggered by pod events.
    		jm.enqueueSyncJobBatched(logger, curJob)
    	} else {
    		// Trigger immediate sync when spec is changed.
    		jm.enqueueSyncJobImmediately(logger, curJob)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    	// there is no need for a PodSchedulingContext change.
    	if numDelayedAllocationPending == 1 && len(claimsWithBuiltinController) == 0 ||
    		numClaimsWithStatusInfo+len(claimsWithBuiltinController) == numDelayedAllocationPending && len(claimsWithBuiltinController) < numDelayedAllocationPending {
    		// TODO: can we increase the chance that the scheduler picks
    		// the same node as before when allocation is on-going,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  8. src/go/types/expr.go

    	case *Signature:
    		return "func"
    	case *Interface:
    		if isTypeParam(typ) {
    			return check.sprintf("type parameter %s", typ)
    		}
    		return "interface"
    	case *Map:
    		return "map"
    	case *Chan:
    		return "chan"
    	default:
    		return check.sprintf("%s", typ) // catch-all
    	}
    }
    
    // If e != nil, it must be the shift expression; it may be nil for non-constant shifts.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 02:09:54 UTC 2024
    - 49.7K bytes
    - Viewed (0)
  9. tensorflow/c/experimental/filesystem/filesystem_interface.h

    /// as well. Here is a short summary of what changes are allowed:
    ///   * adding a new method at the end of a table is allowed at any time;
    ///   * any other change to these tables is only allowed on a major TensorFlow
    ///     version change (e.g., from 2.x to 3.0). This is provided as an escape
    ///     hatch to allow cleaning up these tables. Since any of these changes
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Fri May 27 17:36:54 UTC 2022
    - 53.1K bytes
    - Viewed (0)
  10. src/net/http/request.go

    	matches     []string          // values for the matching wildcards in pat
    	otherValues map[string]string // for calls to SetPathValue that don't match a wildcard
    }
    
    // Context returns the request's context. To change the context, use
    // [Request.Clone] or [Request.WithContext].
    //
    // The returned context is always non-nil; it defaults to the
    // background context.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 49.4K bytes
    - Viewed (0)
Back to top