Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 748 for wlock (0.2 sec)

  1. kotlin-js-store/yarn.lock

    Yuri Schimke <******@****.***> 1690028931 +0100
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Jul 22 12:28:51 UTC 2023
    - 87.4K bytes
    - Viewed (0)
  2. internal/event/targetlist.go

    }
    
    // List - returns available target IDs.
    func (list *TargetList) List() []TargetID {
    	list.RLock()
    	defer list.RUnlock()
    
    	keys := []TargetID{}
    	for k := range list.targets {
    		keys = append(keys, k)
    	}
    
    	return keys
    }
    
    func (list *TargetList) get(id TargetID) (Target, bool) {
    	list.RLock()
    	defer list.RUnlock()
    
    	target, ok := list.targets[id]
    	return target, ok
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  3. internal/config/lambda/event/targetlist.go

    	return targets
    }
    
    // Empty returns true if targetList is empty.
    func (list *TargetList) Empty() bool {
    	list.RLock()
    	defer list.RUnlock()
    
    	return len(list.targets) == 0
    }
    
    // List - returns available target IDs.
    func (list *TargetList) List(region string) []ARN {
    	list.RLock()
    	defer list.RUnlock()
    
    	keys := make([]ARN, 0, len(list.targets))
    	for k := range list.targets {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  4. cmd/metacache-manager.go

    func (m *metacacheManager) deleteBucketCache(bucket string) {
    	m.init.Do(m.initManager)
    	m.mu.Lock()
    	b, ok := m.buckets[bucket]
    	if !ok {
    		m.mu.Unlock()
    		return
    	}
    	delete(m.buckets, bucket)
    	m.mu.Unlock()
    
    	// Since deletes may take some time we try to do it without
    	// holding lock to m all the time.
    	b.mu.Lock()
    	defer b.mu.Unlock()
    	for k, v := range b.caches {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  5. cmd/admin-heal-ops.go

    func (h *healSequence) getScannedItemsCount() int64 {
    	var count int64
    	h.mutex.RLock()
    	defer h.mutex.RUnlock()
    
    	for _, v := range h.scannedItemsMap {
    		count += v
    	}
    	return count
    }
    
    // getScannedItemsMap - returns map of all scanned items against type
    func (h *healSequence) getScannedItemsMap() map[madmin.HealItemType]int64 {
    	h.mutex.RLock()
    	defer h.mutex.RUnlock()
    
    	// Make a copy before returning the value
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  6. internal/logger/reqinfo.go

    func (r *ReqInfo) GetTags() []KeyVal {
    	if r == nil {
    		return nil
    	}
    	r.RLock()
    	defer r.RUnlock()
    	return append(make([]KeyVal, 0, len(r.tags)), r.tags...)
    }
    
    // GetTagsMap - returns the user defined tags in a map structure
    func (r *ReqInfo) GetTagsMap() map[string]string {
    	if r == nil {
    		return nil
    	}
    	r.RLock()
    	defer r.RUnlock()
    	m := make(map[string]string, len(r.tags))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  7. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanExecutor.java

                    Throwable t) {
                // record the error and mark the project as failed
                Clock clock = getClock(mavenProject);
                buildContext.getResult().addException(t);
                buildContext
                        .getResult()
                        .addBuildSummary(new BuildFailure(mavenProject, clock.execTime(), clock.wallTime(), t));
    
                // notify listeners about "soft" project build failures only
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Oct 16 06:12:36 UTC 2025
    - 55.1K bytes
    - Viewed (0)
  8. internal/dsync/locker.go

    type NetLocker interface {
    	// Do read lock for given LockArgs.  It should return
    	// * a boolean to indicate success/failure of the operation
    	// * an error on failure of lock request operation.
    	RLock(ctx context.Context, args LockArgs) (bool, error)
    
    	// Do write lock for given LockArgs. It should return
    	// * a boolean to indicate success/failure of the operation
    	// * an error on failure of lock request operation.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jan 18 20:44:38 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  9. cmd/http-stats.go

    	if stats == nil {
    		return 0
    	}
    
    	stats.RLock()
    	defer stats.RUnlock()
    
    	val, ok := stats.apiStats[api]
    	if ok {
    		return val
    	}
    
    	return 0
    }
    
    // Load returns the recorded stats.
    func (stats *HTTPAPIStats) Load(toLower bool) map[string]int {
    	if stats == nil {
    		return map[string]int{}
    	}
    
    	stats.RLock()
    	defer stats.RUnlock()
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  10. internal/config/browser/browser.go

    }
    
    // GetCSPolicy - Get the Content security Policy
    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
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jun 21 00:58:58 UTC 2024
    - 5.9K bytes
    - Viewed (0)
Back to top