Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 217 for cunlock (0.09 sec)

  1. src/main/java/jcifs/internal/smb1/com/SmbComLockingAndX.java

            bufferIndex += 2;
    
            this.timeout = SMBUtil.readInt4(buffer, bufferIndex);
            bufferIndex += 4;
    
            int nunlocks = SMBUtil.readInt2(buffer, bufferIndex);
            this.unlocks = new LockingAndXRange[nunlocks];
            bufferIndex += 2;
    
            int nlocks = SMBUtil.readInt2(buffer, bufferIndex);
            this.locks = new LockingAndXRange[nlocks];
            bufferIndex += 2;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 4.9K bytes
    - Viewed (0)
  2. cmd/site-replication-utils.go

    			sm.peerResyncMap[peer.DeploymentID] = resyncState{resyncID: rs.ResyncID, LastSaved: time.Time{}}
    			sm.resyncStatus[rs.ResyncID] = rs
    		}
    		sm.Unlock()
    	}
    	return nil
    }
    
    func (sm *siteResyncMetrics) report(dID string) *madmin.SiteResyncMetrics {
    	sm.RLock()
    	defer sm.RUnlock()
    	rst, ok := sm.peerResyncMap[dID]
    	if !ok {
    		return nil
    	}
    	rs, ok := sm.resyncStatus[rst.resyncID]
    	if !ok {
    		return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. internal/pubsub/pubsub.go

    	}
    	ps.Lock()
    	defer ps.Unlock()
    
    	sub := &Sub[T]{ch: subCh, types: Mask(mask.Mask()), filter: filter}
    	ps.subs = append(ps.subs, sub)
    
    	// We hold a lock, so we are safe to update
    	combined := Mask(atomic.LoadUint64(&ps.types))
    	combined.Merge(Mask(mask.Mask()))
    	atomic.StoreUint64(&ps.types, uint64(combined))
    
    	go func() {
    		<-doneCh
    
    		ps.Lock()
    		defer ps.Unlock()
    		var remainTypes Mask
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. cmd/lock-rest-server.go

    func (l *lockRESTServer) RUnlockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    	resp := lockRPCRUnlock.NewResponse()
    
    	// Ignore the RUnlock() "reply" return value because if err == nil, "reply" is always true.
    	// Consequently, if err != nil, reply is always false
    	_, err := l.ll.RUnlock(context.Background(), *args)
    	return l.makeResp(resp, err)
    }
    
    // ForceUnlockHandler - query expired lock status.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. internal/config/batch/batch.go

    func (opts Config) ExpirationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    	return opts.ExpirationWorkersWait
    }
    
    // ReplicationWait returns the duration for which a batch replication worker
    // would wait before working on next object.
    func (opts Config) ReplicationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    	return opts.ReplicationWorkersWait
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  6. internal/config/browser/browser.go

    func (browseCfg *Config) GetCSPolicy() string {
    	configLock.RLock()
    	defer configLock.RUnlock()
    	return browseCfg.CSPPolicy
    }
    
    // GetHSTSSeconds - Get the Content security Policy
    func (browseCfg *Config) GetHSTSSeconds() int {
    	configLock.RLock()
    	defer configLock.RUnlock()
    	return browseCfg.HSTSSeconds
    }
    
    // IsHSTSIncludeSubdomains - is HSTS 'includeSubdomains' directive enabled
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 00:58:58 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  7. internal/config/heal/heal.go

    func (opts Config) BitrotScanCycle() (d time.Duration) {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.cache.bitrotCycle
    }
    
    // Clone safely the heal configuration
    func (opts Config) Clone() (int, time.Duration, string) {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.IOCount, opts.Sleep, opts.Bitrot
    }
    
    // GetWorkers returns the number of workers, -1 is none configured
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  8. internal/config/callhome/callhome.go

    // Enabled - indicates if callhome is enabled or not
    func (c *Config) Enabled() bool {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	return c.Enable
    }
    
    // FrequencyDur - returns the currently configured callhome frequency
    func (c *Config) FrequencyDur() time.Duration {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	if c.Frequency == 0 {
    		return callhomeCycleDefault
    	}
    
    	return c.Frequency
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  9. cmd/bootstrap-messages.go

    	bs.mu.Lock()
    	defer bs.mu.Unlock()
    
    	if len(bs.info) > bootstrapTraceLimit {
    		return
    	}
    	bs.info = append(bs.info, info)
    }
    
    func (bs *bootstrapTracer) Events() []madmin.TraceInfo {
    	traceInfo := make([]madmin.TraceInfo, 0, bootstrapTraceLimit)
    
    	bs.mu.RLock()
    	for _, i := range bs.info {
    		traceInfo = append(traceInfo, i)
    	}
    	bs.mu.RUnlock()
    
    	return traceInfo
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  10. cmd/event-notification.go

    func (evnot *EventNotifier) RemoveNotification(bucketName string) {
    	evnot.Lock()
    	defer evnot.Unlock()
    
    	delete(evnot.bucketRulesMap, bucketName)
    }
    
    // RemoveAllBucketTargets - closes and removes all notification targets.
    func (evnot *EventNotifier) RemoveAllBucketTargets() {
    	evnot.Lock()
    	defer evnot.Unlock()
    
    	targetIDSet := event.NewTargetIDSet()
    	for k := range evnot.targetList.TargetMap() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
Back to top