Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 101 for Croock (0.37 sec)

  1. internal/config/lambda/event/targetlist.go

    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    	targets := make([]Target, 0, len(list.targets))
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    	}
    
    	return targets
    }
    
    // Empty returns true if targetList is empty.
    func (list *TargetList) Empty() bool {
    	list.RLock()
    	defer list.RUnlock()
    
    	return len(list.targets) == 0
    }
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  2. internal/kms/kes.go

    func (c *kesClient) Metrics(ctx context.Context) (kes.Metric, error) {
    	c.lock.RLock()
    	defer c.lock.RUnlock()
    
    	return c.client.Metrics(ctx)
    }
    
    // Version retrieves version information
    func (c *kesClient) Version(ctx context.Context) (string, error) {
    	c.lock.RLock()
    	defer c.lock.RUnlock()
    
    	return c.client.Version(ctx)
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Apr 16 15:43:39 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  3. 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
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  4. cmd/bucket-targets.go

    }
    
    // isOffline returns current liveness result of remote target. Add endpoint to
    // healthCheck map if missing and default to online status
    func (sys *BucketTargetSys) isOffline(ep *url.URL) bool {
    	sys.hMutex.RLock()
    	defer sys.hMutex.RUnlock()
    	if h, ok := sys.hc[ep.Host]; ok {
    		return !h.Online
    	}
    	go sys.initHC(ep)
    	return false
    }
    
    // markOffline sets endpoint to offline if network i/o timeout seen.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  5. cmd/handler-api.go

    }
    
    func (t *apiConfig) odirectEnabled() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return t.enableODirect
    }
    
    func (t *apiConfig) shouldGzipObjects() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return t.gzipObjects
    }
    
    func (t *apiConfig) permitRootAccess() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return t.rootAccess
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 08 09:22:27 GMT 2024
    - 10K bytes
    - Viewed (0)
  6. cmd/local-locker_test.go

    			Resources: []string{name},
    			Source:    t.Name(),
    			Owner:     "owner",
    			Quorum:    0,
    		}
    		ok, err := l.RLock(ctx, arg)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    			t.Fatal("did not get write lock")
    		}
    		// RLock twice
    		ok, err = l.RLock(ctx, arg)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    			t.Fatal("did not get write lock")
    		}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Mar 05 04:57:35 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  7. cmd/peer-s3-server.go

    	peerS3BucketForceDelete = "force-delete"
    )
    
    func healBucketLocal(ctx context.Context, bucket string, opts madmin.HealOpts) (res madmin.HealResultItem, err error) {
    	globalLocalDrivesMu.RLock()
    	localDrives := cloneDrives(globalLocalDrives)
    	globalLocalDrivesMu.RUnlock()
    
    	// Initialize sync waitgroup.
    	g := errgroup.WithNErrs(len(localDrives))
    
    	// Disk states slices
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 8.4K bytes
    - Viewed (0)
  8. internal/bucket/bandwidth/monitor.go

    }
    
    // GetReport gets the report for all bucket bandwidth details.
    func (m *Monitor) GetReport(selectBucket SelectionFunction) *BucketBandwidthReport {
    	m.mlock.RLock()
    	defer m.mlock.RUnlock()
    	return m.getReport(selectBucket)
    }
    
    func (m *Monitor) getReport(selectBucket SelectionFunction) *BucketBandwidthReport {
    	report := &BucketBandwidthReport{
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 6K bytes
    - Viewed (0)
  9. internal/event/targetlist.go

    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    	targets := []Target{}
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    	}
    
    	return targets
    }
    
    // List - returns available target IDs.
    func (list *TargetList) List() []TargetID {
    	list.RLock()
    	defer list.RUnlock()
    
    	keys := []TargetID{}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  10. internal/lsync/lrwmutex.go

    	const isWriteLock = true
    	return lm.lockLoop(ctx, id, source, timeout, isWriteLock)
    }
    
    // RLock holds a read lock on lm.
    //
    // If one or more read lock are already in use, it will grant another lock.
    // Otherwise the calling go routine blocks until the mutex is available.
    func (lm *LRWMutex) RLock() {
    	const isWriteLock = false
    	lm.lockLoop(context.Background(), lm.id, lm.source, 1<<63-1, isWriteLock)
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.8K bytes
    - Viewed (0)
Back to top