- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 109 for Morlock (0.48 sec)
-
src/main/java/jcifs/internal/smb1/com/SmbComOpenAndX.java
// flags (not the same as flags constructor argument) static final int FLAGS_RETURN_ADDITIONAL_INFO = 0x01; static final int FLAGS_REQUEST_OPLOCK = 0x02; static final int FLAGS_REQUEST_BATCH_OPLOCK = 0x04; // Access Mode Encoding for desiredAccess static final int SHARING_COMPATIBILITY = 0x00; static final int SHARING_DENY_READ_WRITE_EXECUTE = 0x10;
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 7K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
return true, nil case errLockConflict, errLockNotFound: return false, nil default: return false, err } } func (restClient *ReconnectRESTClient) RLock(ctx context.Context, args LockArgs) (status bool, err error) { return restClient.Call("/v1/rlock", args) } func (restClient *ReconnectRESTClient) Lock(ctx context.Context, args LockArgs) (status bool, err error) { return restClient.Call("/v1/lock", args) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 20 17:36:09 GMT 2022 - 4.4K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
func (r *ReplicationStats) updateMovingAvg() { r.RLock() for _, s := range r.Cache { for _, st := range s.Stats { st.XferRateLrg.measure.updateExponentialMovingAverage(time.Now()) st.XferRateSml.measure.updateExponentialMovingAverage(time.Now()) } } r.RUnlock() } // ActiveWorkers returns worker stats func (r *ReplicationStats) ActiveWorkers() ActiveWorkerStat { r.wlock.RLock() defer r.wlock.RUnlock()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
func (lh *lockServerHandler) RLockHandler(w http.ResponseWriter, r *http.Request) { args, err := getLockArgs(r) if err != nil { lh.writeErrorResponse(w, err) return } reply, err := lh.lsrv.RLock(&args) if err == nil && !reply { err = errLockConflict } if err != nil { lh.writeErrorResponse(w, err) return } } func stopLockServers() { for i := 0; i < numberOfNodes; i++ {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/tree/Smb2TreeConnectResponse.java
/** * */ public static final int SMB2_SHAREFLAG_ACCESS_BASED_DIRECTORY_ENUM = 0x800; /** * */ public static final int SMB2_SHAREFLAG_FORCE_LEVEL2_OPLOCK = 0x1000; /** * */ public static final int SMB2_SHAREFLAG_ENABLE_HASH_V1 = 0x2000; /** * */ public static final int SMB2_SHAREFLAG_ENABLE_HASH_V2 = 0x4000; /**
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Mon May 23 14:35:20 GMT 2022 - 6.1K bytes - Viewed (0) -
docs/site-replication/run-multi-site-oidc.sh
if [ $? -eq 0 ]; then echo "expected object to be deleted permanently after replication, exiting.." exit_1 fi ./mc mb --with-lock minio3/newbucket-olock sleep 5 enabled_minio2=$(./mc stat --json minio2/newbucket-olock | jq -r .ObjectLock.enabled) if [ $? -ne 0 ]; then echo "expected bucket to be mirrored with object-lock but not present, exiting..." exit_1 fi
Shell Script - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Feb 26 21:30:28 GMT 2024 - 8.4K bytes - Viewed (0) -
internal/config/storageclass/storage-class.go
// // is returned, the caller is expected to choose the right parity // at that point. func (sCfg *Config) GetParityForSC(sc string) (parity int) { ConfigLock.RLock() defer ConfigLock.RUnlock() switch strings.TrimSpace(sc) { case RRS: if !sCfg.initialized { return -1 } return sCfg.RRS.Parity default: if !sCfg.initialized { return -1 }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.8K bytes - Viewed (0) -
internal/config/subnet/config.go
// Registered indicates if cluster is registered or not func (c *Config) Registered() bool { configLock.RLock() defer configLock.RUnlock() return len(c.APIKey) > 0 } // ApplyEnv - applies the current subnet config to Console UI specific environment variables. func (c *Config) ApplyEnv() { configLock.RLock() defer configLock.RUnlock() if c.License != "" { os.Setenv("CONSOLE_SUBNET_LICENSE", c.License) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Nov 24 17:59:35 GMT 2023 - 3.8K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
// 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 { return info.Netns } return nil } // make sure uid is in the cache, even if we don't have a netns
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
cmd/namespace-lock.go
} // nsLock - provides primitives for locking critical namespace regions. type nsLock struct { ref int32 *lsync.LRWMutex } // nsLockMap - namespace lock map, provides primitives to Lock, // Unlock, RLock and RUnlock. type nsLockMap struct { // Indicates if namespace is part of a distributed setup. isDistErasure bool lockMap map[string]*nsLock lockMapMutex sync.Mutex } // Lock the namespace resource.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0)