- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 138 for RUnlock (0.03 sec)
-
cmd/object_api_suite_test.go
globalCompressConfig.Enabled = true globalCompressConfig.MimeTypes = mimeTypes globalCompressConfig.Extensions = extensions globalCompressConfig.AllowEncrypted = encrypt globalCompressConfigMu.Unlock() if encrypt { globalAutoEncryption = encrypt KMS, err := kms.ParseSecretKey("my-minio-key:5lF+0pJM0OWwlQrvK2S/I7W9mO4a6rJJI7wzj7v09cw=") if err != nil { t.Fatal(err) } GlobalKMS = KMS }Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.5K bytes - Viewed (0) -
cmd/metrics-v3-cache.go
v.ioStats[d] = getDriveIOStatMetrics(getDiffStats(ps, cs), duration) } } } } prevDriveIOStats = currentStats prevDriveIOStatsRefreshedAt = now prevDriveIOStatsMu.Unlock() return } return cachevalue.NewFromFunc(1*time.Minute, cachevalue.Opts{ReturnLastGood: true}, loadDriveMetrics) } func newCPUMetricsCache() *cachevalue.Cache[madmin.CPUMetrics] {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 8K bytes - Viewed (0) -
cmd/naughty-disk_test.go
} func (d *naughtyDisk) Close() (err error) { if err = d.calcError(); err != nil { return err } return d.disk.Close() } func (d *naughtyDisk) calcError() (err error) { d.mu.Lock() defer d.mu.Unlock() d.callNR++ if err, ok := d.errors[d.callNR]; ok { return err } if d.defaultErr != nil { return d.defaultErr } return nil }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 10.1K bytes - Viewed (0) -
docs/smb3-features/01-smb3-lease-design.md
leases.put(newKey, newEntry); pathToLease.put(path, newKey); return newKey; } finally { lock.writeLock().unlock(); } } public void updateLease(Smb2LeaseKey key, int grantedState) { LeaseEntry entry = leases.get(key); if (entry != null) { entry.updateState(grantedState);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 22K bytes - Viewed (0) -
cmd/prepare-storage.go
return func(endpoint Endpoint, err error, once bool) { reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String()) ctx := logger.SetReqInfo(GlobalContext, reqInfo) mutex.Lock() defer mutex.Unlock() m, ok := printOnce[endpoint] if !ok { m = make(map[string]int) printOnce[endpoint] = m if once { m[err.Error()]++ peersLogAlwaysIf(ctx, err) return } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (1) -
src/main/java/jcifs/SmbConstants.java
*/ int DEFAULT_CONN_TIMEOUT = 35000; /** * No flags set in SMB header. */ int FLAGS_NONE = 0x00; /** * Obsolete lock and read/write and unlock flag. */ int FLAGS_LOCK_AND_READ_WRITE_AND_UNLOCK = 0x01; /** * Receive buffer has been posted flag. */ int FLAGS_RECEIVE_BUFFER_POSTED = 0x02; /**Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:49:49 UTC 2025 - 12.8K bytes - Viewed (0) -
ci/official/containers/ml_build_arm64/builder.devtoolset/gcc9-fixups.patch
+ { while (*ep != NULL) if (!strncmp (*ep, name, len) && (*ep)[len] == '=') { @@ -332,6 +333,7 @@ unsetenv (const char *name) } else ++ep; + } UNLOCK; diff --git a/support/Makefile b/support/Makefile index a253698..2f4e2a9 100644 --- a/support/Makefile +++ b/support/Makefile @@ -167,13 +167,6 @@ CFLAGS-support_paths.c = \ -DINSTDIR_PATH=\"$(prefix)\" \Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Mon Nov 11 19:25:56 UTC 2024 - 8.9K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lock/Smb2LockTest.java
void testExclusiveLockFlag() { assertEquals(0x2, Smb2Lock.SMB2_LOCKFLAG_EXCLUSIVE_LOCK); } @Test @DisplayName("Should have correct unlock flag value") void testUnlockFlag() { assertEquals(0x4, Smb2Lock.SMB2_LOCKFLAG_UNLOCK); } @Test @DisplayName("Should have correct fail immediately flag value")
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 10.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbConstants.java
/** LM compatibility level */ int LM_COMPATIBILITY = Config.getInt("jcifs.smb1.smb.lmCompatibility", 3); /** No flags set */ int FLAGS_NONE = 0x00; /** Lock and read write and unlock flag */ int FLAGS_LOCK_AND_READ_WRITE_AND_UNLOCK = 0x01; /** Receive buffer posted flag */ int FLAGS_RECEIVE_BUFFER_POSTED = 0x02; /** Path names are caseless flag */ int FLAGS_PATH_NAMES_CASELESS = 0x08;Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 10.3K bytes - Viewed (0) -
cmd/admin-handlers_test.go
if err != nil { return nil, nil, err } // Make objLayer available to all internal services via globalObjectAPI. globalObjLayerMutex.Lock() globalObjectAPI = objLayer globalObjLayerMutex.Unlock() return objLayer, erasureDirs, nil } // cmdType - Represents different service subcomands like status, stop // and restart. type cmdType int const ( restartCmd cmdType = iota stopCmd )Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (1)