- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for check3 (0.87 sec)
-
pilot/pkg/xds/delta.go
} // Check if server is ready to accept clients and process new requests. // Currently ready means caches have been synced and hence can build // clusters correctly. Without this check, InitContext() call below would // initialize with empty config, leading to reconnected Envoys loosing // configuration. This is an additional safety check inaddition to adding
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
} for _, nie := range istioEndpoints { if oie, exists := omap[nie.Address]; exists { // If endpoint exists already, we should push if it's changed. // Skip this check if we already decide we need to push to avoid expensive checks if !needPush && !oie.Equals(nie) { needPush = true } newIstioEndpoints = append(newIstioEndpoints, nie) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/config/analysis/analyzers/destinationrule/ca-certificates.go
) // CaCertificateAnalyzer checks if CaCertificate is set in case mode is SIMPLE/MUTUAL type CaCertificateAnalyzer struct{} var _ analysis.Analyzer = &CaCertificateAnalyzer{} func (c *CaCertificateAnalyzer) Metadata() analysis.Metadata { return analysis.Metadata{ Name: "destinationrule.CaCertificateAnalyzer", Description: "Checks if caCertificates is set when TLS mode is SIMPLE/MUTUAL",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 07:22:31 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/bucket-handlers.go
postPolicyBucketTagging = "tagging" ) // Check if there are buckets on server without corresponding entry in etcd backend and // make entries. Here is the general flow // - Range over all the available buckets // - Check if a bucket has an entry in etcd backend // -- If no, make an entry // -- If yes, check if the entry matches local IP check if we // // need to update the entry then proceed to update //
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor.cc
stream_executor_->host_memory_deallocate(&device_, mem); } void* UnifiedMemoryAllocate(uint64 size) override { CHECK(stream_executor_->unified_memory_allocate); return stream_executor_->unified_memory_allocate(&device_, size); } void UnifiedMemoryDeallocate(void* mem) override { CHECK(stream_executor_->unified_memory_deallocate); stream_executor_->unified_memory_deallocate(&device_, mem); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 27.1K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// serviceHasSynced indicates whether services have been sync'd at least once. // Check this before trusting a response from the lister. serviceHasSynced cache.InformerSynced // nodeLister knows how to list nodes nodeLister corelisters.NodeLister // nodeHasSynced indicates whether nodes have been sync'd at least once. // Check this before trusting a response from the node lister. nodeHasSynced cache.InformerSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
// deleted by the status manager, but are not in pod workers. // First, the check for deletionTimestamp is a performance optimization as we // don't need to do anything with terminal pods without deletionTimestamp. // Second, the check for terminal pods is to avoid race conditions of triggering // deletion on Pending pods which are not yet added to pod workers. // Third, the check to skip pods known to pod workers is that the lifecycle of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
cmd/object-handlers.go
return core, nil } // Check if the destination bucket is on a remote site, this code only gets executed // when federation is enabled, ie when globalDNSConfig is non 'nil'. // // This function is similar to isRemoteCallRequired but specifically for COPY object API // if destination and source are same we do not need to check for destination bucket // to exist locally.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion.go
} else { reason = string(k8s.GatewayReasonAddressNotUsable) } gatewayConditions[string(k8s.GatewayConditionProgrammed)].error = &ConfigError{ // TODO: this only checks Service ready, we should also check Deployment ready? Reason: reason, Message: msg, } } obj.Status.(*kstatus.WrappedStatus).Mutate(func(s config.Status) config.Status { gs := s.(*k8s.GatewayStatus)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 84.7K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
return } if s3Error := checkRequestAuthType(ctx, r, policy.PutObjectAction, bucket, object); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } // Check if bucket encryption is enabled sseConfig, _ := globalBucketSSEConfigSys.Get(bucket) sseConfig.Apply(r.Header, sse.ApplyOptions{ AutoEncrypt: globalAutoEncryption, }) // Validate storage class metadata if present
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 38.8K bytes - Viewed (0)