- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Rashed (0.18 sec)
-
cmd/xl-storage-disk-id-check.go
t := time.Now().Unix() e.init.Do(func() { e.cached.Store(&AccElem{}) atomic.StoreInt64(&e.cachedSec, t) }) acc := e.cached.Load() if lastT := atomic.LoadInt64(&e.cachedSec); lastT != t { // Check if lastT was changed by someone else. if atomic.CompareAndSwapInt64(&e.cachedSec, lastT, t) { // Now we swap in a new. newAcc := &AccElem{} old := e.cached.Swap(newAcc) var a AccElem
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 21:22:15 GMT 2024 - 32.7K bytes - Viewed (0) -
ReadMe.md
repository for all Gradle builds. Gradle will check hashes (md5 and sha256) of used dependencies and will fail builds with `Dependency verification failed` errors when local artifacts are absent or have different hashes listed in the [verification-metadata.xml](https://github.com/JetBrains/kotlin/blob/master/gradle/verification-metadata.xml) file.
Plain Text - Registered: Fri Apr 12 08:18:09 GMT 2024 - Last Modified: Thu Apr 11 14:28:46 GMT 2024 - 8.7K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultSuperPomProvider.java
import org.apache.maven.api.services.xml.XmlReaderRequest; @Named @Singleton public class DefaultSuperPomProvider implements SuperPomProvider { private final ModelProcessor modelProcessor; /** * The cached super POM, lazily created. */ private static final Map<String, Model> SUPER_MODELS = new ConcurrentHashMap<>(); @Inject public DefaultSuperPomProvider(ModelProcessor modelProcessor) {
Java - Registered: Sun Apr 14 03:35:08 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 3K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
} p.addToCacheUnderLock(uid, workload) return workload.Netns } // Update the cache with the given uid and nspath. Return the Netns for the given uid. // If uid is already present, a cached Netns is returned, and the given nspath is ignored. func (p *podNetnsCache) Get(uid string) Netns { // lock current snapshot pod map p.mu.RLock() defer p.mu.RUnlock() if info, f := p.currentPodCache[uid]; f {
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/project/PomConstructionTest.java
assertEquals("PASSED", pom.getValue(prefix + "propertiesFile")); assertEquals("PASSED", pom.getValue(prefix + "parent")); assertEquals("PASSED-1", pom.getValue(prefix + "stringParams/stringParam[1]")); assertEquals("PASSED-3", pom.getValue(prefix + "stringParams/stringParam[2]")); assertEquals("PASSED-2", pom.getValue(prefix + "stringParams/stringParam[3]"));
Java - Registered: Sun Apr 14 03:35:08 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 93.2K bytes - Viewed (0) -
internal/config/heal/heal.go
// maximum sleep duration between objects to slow down heal operation. Sleep time.Duration `json:"sleep"` IOCount int `json:"iocount"` DriveWorkers int `json:"drive_workers"` // Cached value from Bitrot field cache struct { // -1: bitrot enabled, 0: bitrot disabled, > 0: bitrot cycle bitrotCycle time.Duration } } // BitrotScanCycle returns the configured cycle for the scanner healing
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/metrics-v3-cache.go
package cmd import ( "sync" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/cachevalue" ) // metricsCache - cache for metrics. // // When serving metrics, this cache is passed to the MetricsLoaderFn. // // This cache is used for metrics that would result in network/storage calls. type metricsCache struct { dataUsageInfo *cachevalue.Cache[DataUsageInfo]
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 17:46:34 GMT 2024 - 6.7K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/policies.go
"sigs.k8s.io/yaml" "istio.io/istio/pkg/maps" "istio.io/istio/pkg/slices" ) // PolicyFilter is used to pass filter information into service based config writer print functions type PolicyFilter struct { Namespace string } // Verify returns true if the passed workload matches the filter fields func (wf *PolicyFilter) Verify(pol *ZtunnelPolicy) bool { if wf.Namespace != "" {
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 2.5K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
} func GetFd(f fs.File) (uintptr, error) { if fdable, ok := f.(interface{ Fd() uintptr }); ok { return fdable.Fd(), nil } return 0, fmt.Errorf("unable to get fd") } /// mostly copy pasted from spire below: // regexes listed here have to exclusively match a cgroup path // the regexes must include two named groups "poduid" and "containerid"
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0) -
cmd/storage-rest-client.go
// value is cached we should attempt to invalidate it if such calls // were attempted. This can lead to false success under certain conditions // - this change attempts to avoid stale information if the underlying // transport is already down. return "", errDiskNotFound } // This call should never be over the network, this is always // a cached value - caller should make sure to use this
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 17:45:28 GMT 2024 - 26.7K bytes - Viewed (0)