- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 510 for locks (0.04 sec)
-
internal/config/browser/browser.go
config.KV{ Key: browserHSTSPreload, Value: config.EnableOff, }, config.KV{ Key: browserReferrerPolicy, Value: "strict-origin-when-cross-origin", }, } ) // configLock is a global lock for browser config var configLock sync.RWMutex // Config storage class configuration type Config struct { CSPPolicy string `json:"csp_policy"` HSTSSeconds int `json:"hsts_seconds"`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 00:58:58 UTC 2024 - 5.9K bytes - Viewed (0) -
cmd/erasure-sets.go
sets []*erasureObjects // Reference format. format *formatErasureV3 // erasureDisks mutex to lock erasureDisks. erasureDisksMu sync.RWMutex // Re-ordered list of disks per set. erasureDisks [][]StorageAPI // Distributed locker clients. erasureLockers setsDsyncLockers // Distributed lock owner (constant per running instance). erasureLockOwner string // List of endpoints provided on the command line.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1) -
guava-gwt/src/com/google/common/cache/Cache.gwt.xml
for prod and one for tests. However, unlike our other packages, as of this writing it has test supersource but no prod supersource. GWT happens to use the prod .gwt.xml, so it looks for no supersource for tests, either. This causes it to fail to find AtomicLongMapTest. Our workaround is to tell GWT that util.concurrent and all other packages
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jul 19 16:02:36 UTC 2024 - 1.6K bytes - Viewed (0) -
cmd/metrics-resource.go
} sfx += v } return string(name) + "_" + sfx } func updateResourceMetrics(subSys MetricSubsystem, name MetricName, val float64, labels map[string]string, isCumulative bool) { resourceMetricsMapMu.Lock() defer resourceMetricsMapMu.Unlock() subsysMetrics, found := resourceMetricsMap[subSys] if !found { subsysMetrics = ResourceMetrics{} } key := getResourceKey(name, labels)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 23:30:33 UTC 2024 - 17.2K bytes - Viewed (0) -
cmd/xl-storage-format_test.go
if unMarshalXLMeta.Erasure.DataBlocks != jsoniterXLMeta.Erasure.DataBlocks { t.Errorf("Expected the erasure data blocks to be %v, but got %v.", unMarshalXLMeta.Erasure.DataBlocks, jsoniterXLMeta.Erasure.DataBlocks) } if unMarshalXLMeta.Erasure.ParityBlocks != jsoniterXLMeta.Erasure.ParityBlocks { t.Errorf("Expected the erasure parity blocks to be %v, but got %v.", unMarshalXLMeta.Erasure.ParityBlocks, jsoniterXLMeta.Erasure.ParityBlocks) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 17.6K bytes - Viewed (0) -
docs/bigdata/README.md
fs.s3a.impl=org.apache.hadoop.fs.s3a.S3AFileSystem fs.s3a.committer.threads=2048 # Number of threads writing to MinIO fs.s3a.connection.maximum=8192 # Maximum number of concurrent conns fs.s3a.fast.upload.active.blocks=2048 # Number of parallel uploads fs.s3a.fast.upload.buffer=disk # Use disk as the buffer for uploads fs.s3a.fast.upload=true # Turn on fast upload mode fs.s3a.max.total.tasks=2048 # Maximum number of parallel tasks
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 14.7K bytes - Viewed (0) -
api/go1.txt
pkg sync, method (*Cond) Broadcast() pkg sync, method (*Cond) Signal() pkg sync, method (*Cond) Wait() pkg sync, method (*Mutex) Lock() pkg sync, method (*Mutex) Unlock() pkg sync, method (*Once) Do(func()) pkg sync, method (*RWMutex) Lock() pkg sync, method (*RWMutex) RLock() pkg sync, method (*RWMutex) RLocker() Locker pkg sync, method (*RWMutex) RUnlock() pkg sync, method (*RWMutex) Unlock()
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Aug 14 18:58:28 UTC 2013 - 1.7M bytes - Viewed (0) -
internal/disk/stat_netbsd.go
s := unix.Statvfs_t{} if err = unix.Statvfs(path, &s); err != nil { return Info{}, err } reservedBlocks := uint64(s.Bfree) - uint64(s.Bavail) info = Info{ Total: uint64(s.Frsize) * (uint64(s.Blocks) - reservedBlocks), Free: uint64(s.Frsize) * uint64(s.Bavail), Files: uint64(s.Files), Ffree: uint64(s.Ffree), FSType: string(s.Fstypename[:]), } if info.Free > info.Total {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 26 19:34:50 UTC 2024 - 1.8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/NameServiceClient.java
private static final String RO = Config.getProperty( "jcifs.smb1.resolveOrder" ); private static LogStream log = LogStream.getInstance(); private final Object LOCK = new Object(); private int lport, closeTimeout; private byte[] snd_buf, rcv_buf; private DatagramSocket socket; private DatagramPacket in, out; private HashMap responseTable = new HashMap();
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 17.4K bytes - Viewed (0) -
internal/disk/stat_linux_32bit.go
s := syscall.Statfs_t{} err = syscall.Statfs(path, &s) if err != nil { return Info{}, err } reservedBlocks := s.Bfree - s.Bavail info = Info{ Total: uint64(s.Frsize) * (s.Blocks - reservedBlocks), Free: uint64(s.Frsize) * s.Bavail, Files: s.Files, Ffree: s.Ffree, FSType: getFSType(s.Type), } // Check for overflows. // https://github.com/minio/minio/issues/8035
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 26 19:34:50 UTC 2024 - 2.6K bytes - Viewed (0)