- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 239 for aloop (0.07 sec)
-
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/annotations/firAnnotationUtils.kt
useSiteSession: FirSession, annotationContainer: FirAnnotationContainer = firSymbol.fir, ): Boolean { return if (firSymbol.isFromCompilerRequiredAnnotationsPhase(classId, useSiteSession)) { // this loop by index is required to avoid possible ConcurrentModificationException val annotations = annotationContainer.resolvedCompilerRequiredAnnotations(firSymbol) for (index in annotations.indices) {
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:42 UTC 2024 - 9.9K bytes - Viewed (0) -
src/encoding/base32/base32.go
func (enc *Encoding) Encode(dst, src []byte) { if len(src) == 0 { return } // enc is a pointer receiver, so the use of enc.encode within the hot // loop below means a nil check at every operation. Lift that nil check // outside of the loop to speed up the encoder. _ = enc.encode di, si := 0, 0 n := (len(src) / 5) * 5 for si < n { // Combining two 32 bit loads allows the same code to be used
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 16:25:54 UTC 2024 - 15.9K bytes - Viewed (0) -
src/compress/flate/deflate.go
return } d.maxInsertIndex = d.windowEnd - (minMatchLength - 1) Loop: for { if d.index > d.windowEnd { panic("index > windowEnd") } lookahead := d.windowEnd - d.index if lookahead < minMatchLength+maxMatchLength { if !d.sync { break Loop } if d.index > d.windowEnd { panic("index > windowEnd") } if lookahead == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:32:40 UTC 2024 - 20.3K bytes - Viewed (0) -
pilot/pkg/xds/sds.go
var authzResult *bool var authzError error // isAuthorized is a small wrapper around credscontroller.Authorize so we only call it once instead of each time in the loop isAuthorized := func() bool { if authzResult != nil { return *authzResult } res := false if err := secrets.Authorize(proxy.VerifiedIdentity.ServiceAccount, proxy.VerifiedIdentity.Namespace); err == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 15 23:04:36 UTC 2024 - 15.8K bytes - Viewed (0) -
src/cmd/go/internal/modload/import.go
return err == nil && !fi.IsDir() }) if haveGoMod { return "", false, nil } parent := filepath.Dir(d) if parent == d { // Break the loop, as otherwise we'd loop // forever if d=="." and mdir=="". break } d = parent } } // Now committed to returning dir (not ""). // Are there Go source files in the directory?
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 07 15:21:14 UTC 2024 - 27.7K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
Long: `The Kubernetes controller manager is a daemon that embeds the core control loops shipped with Kubernetes. In applications of robotics and automation, a control loop is a non-terminating loop that regulates the state of the system. In Kubernetes, a controller is a control loop that watches the shared state of the cluster through the apiserver and makes changes attempting to move the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
} // NewDesiredStateOfWorldPopulator returns a new instance of // DesiredStateOfWorldPopulator. // // kubeClient - used to fetch PV and PVC objects from the API server // loopSleepDuration - the amount of time the populator loop sleeps between // successive executions // // podManager - the kubelet podManager that is the source of truth for the pods // that exist on this host // // desiredStateOfWorld - the cache to populate
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
} func newETCD3Check(c storagebackend.Config, timeout time.Duration, stopCh <-chan struct{}) (func() error, error) { // constructing the etcd v3 client blocks and times out if etcd is not available. // retry in a loop in the background until we successfully create the client, storing the client or error encountered lock := sync.RWMutex{} var prober *etcd3ProberMonitor clientErr := fmt.Errorf("etcd client connection not yet established")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
src/cmd/doc/main.go
telemetry.CountFlags("doc/flag:", *flag.CommandLine) if chdir != "" { if err := os.Chdir(chdir); err != nil { return err } } var paths []string var symbol, method string // Loop until something is printed. dirs.Reset() for i := 0; ; i++ { buildPackage, userPath, sym, more := parseArgs(flagSet.Args()) if i > 0 && !more { // Ignore the "more" bit on the first iteration.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 12.2K bytes - Viewed (0) -
analysis/analysis-api/src/org/jetbrains/kotlin/analysis/api/symbols/KtSymbolProvider.kt
* it is not possible to create [KaValueParameterSymbol], hence an error will be raised. * * If [KtParameter.isLoopParameter] is `true`, i.e. if the given [KtParameter] is a loop variable in `for` expression, then the function * returns [KaLocalVariableSymbol]. * * Otherwise, returns [KaValueParameterSymbol]. */ public fun KtParameter.getParameterSymbol(): KaVariableLikeSymbol =
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Thu May 23 17:29:30 UTC 2024 - 10.6K bytes - Viewed (0)