Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 118 for logic (0.06 sec)

  1. pkg/scheduler/schedule_one.go

    	// assume modifies `assumedPod` by setting NodeName=scheduleResult.SuggestedHost
    	err = sched.assume(logger, assumedPod, scheduleResult.SuggestedHost)
    	if err != nil {
    		// This is most probably result of a BUG in retrying logic.
    		// We report an error here so that pod scheduling can be retried.
    		// This relies on the fact that Error will check if the pod has been bound
    		// to a node and if so will not add it back to the unscheduled pods queue
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  2. analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/symbols/descriptorBased/base/Kt1DescUtils.kt

            is PropertyDescriptorImpl -> KaFe10DescKotlinPropertySymbol(unwrapped, analysisContext)
            else -> null
        }
    }
    
    /**
     * This logic should be equivalent to
     * [org.jetbrains.kotlin.analysis.api.fir.KaSymbolByFirBuilder.unwrapSubstitutionOverrideIfNeeded]. But this method unwrap all fake
     * overrides that do not change the signature.
     */
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Tue Jun 11 15:45:42 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  3. src/cmd/link/internal/ld/deadcode.go

    // deadcode marks all reachable symbols.
    //
    // The basis of the dead code elimination is a flood fill of symbols,
    // following their relocations, beginning at *flagEntrySymbol.
    //
    // This flood fill is wrapped in logic for pruning unused methods.
    // All methods are mentioned by relocations on their receiver's *rtype.
    // These relocations are specially defined as R_METHODOFF by the compiler
    // so we can detect and manipulated them here.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 14:52:41 UTC 2024
    - 19K bytes
    - Viewed (0)
  4. platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/ConfigurationCacheState.kt

            val settingDir = serviceOf<BuildLayout>().settingsDir
            // Load Gradle properties from a file but skip applying system properties defined here.
            // System properties from the file may be mutated by the build logic, and the execution-time values are already restored by the EnvironmentChangeTracker.
            // Applying properties from file overwrites these modifications.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:30 UTC 2024
    - 34.8K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/listener_waypoint.go

    				istio_route.TranslateRequestMirrorPolicy(mirror.Destination, lb.serviceForHostname(host.Name(mirror.Destination.Host)), listenerPort, mp))
    		}
    	}
    
    	// TODO: eliminate this logic and use the total_weight option in envoy route
    	weighted := make([]*route.WeightedCluster_ClusterWeight, 0)
    	for _, dst := range in.Route {
    		weight := &wrappers.UInt32Value{Value: uint32(dst.Weight)}
    		if dst.Weight == 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  6. pilot/pkg/model/gateway.go

    			server.Port.Name + "." + cfg.Name + "." + cfg.Namespace + bind // Format: https.%d.%s.%s.%s.%s
    	}
    
    	return ""
    }
    
    // ParseGatewayRDSRouteName is used by the EnvoyFilter patching logic to match
    // a specific route configuration to patch.
    func ParseGatewayRDSRouteName(name string) (portNumber int, portName, gatewayName string) {
    	if strings.HasPrefix(name, "http.") {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 26K bytes
    - Viewed (0)
  7. subprojects/core-api/src/main/java/org/gradle/StartParameter.java

        }
    
        /**
         * Returns the project's cache dir.
         *
         * <p>Note that this directory is managed by Gradle, and it assumes full ownership of its contents.
         * Plugins and build logic should not store or modify any files or directories within this cache directory.
         *
         * @return project's cache dir, or null if the default location is to be used.
         */
        @Nullable
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 06:24:50 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  8. src/net/netip/netip.go

    func (ip Addr) IsGlobalUnicast() bool {
    	if ip.z == z0 {
    		// Invalid or zero-value.
    		return false
    	}
    
    	if ip.Is4In6() {
    		ip = ip.Unmap()
    	}
    
    	// Match package net's IsGlobalUnicast logic. Notably private IPv4 addresses
    	// and ULA IPv6 addresses are still considered "global unicast".
    	if ip.Is4() && (ip == IPv4Unspecified() || ip == AddrFrom4([4]byte{255, 255, 255, 255})) {
    		return false
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 17:10:01 UTC 2024
    - 43.2K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/cluster_builder.go

    		} else {
    			// Dual Stack
    			if features.EnableDualStack {
    				// using Cluster_ALL to enable Happy Eyeballsfor upstream connections
    				c.DnsLookupFamily = cluster.Cluster_ALL
    			} else {
    				// keep the original logic if Dual Stack is disable
    				c.DnsLookupFamily = cluster.Cluster_V4_ONLY
    			}
    		}
    		c.DnsRefreshRate = cb.req.Push.Mesh.DnsRefreshRate
    		c.RespectDnsTtl = true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 31.6K bytes
    - Viewed (0)
  10. pkg/istio-agent/agent.go

    				// is called by sdsServer.OnSecretUpdate, which triggers a push and eventually calls sdsservice.Generate
    				// TODO: extract the logic to detect expiration time, and use a simpler code to rotate to files.
    				_, _ = a.getWorkloadCerts(st)
    			})
    			_, _ = a.getWorkloadCerts(st)
    		}()
    	} else {
    		pkpConf := a.proxyConfig.GetPrivateKeyProvider()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 10:02:56 UTC 2024
    - 26.7K bytes
    - Viewed (0)
Back to top