Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 43 for RWMutex (0.19 sec)

  1. internal/logger/targets.go

    	// Can be swapped to another while holding swapMu
    	systemTargets  = []Target{}
    	swapSystemMuRW sync.RWMutex
    
    	// auditTargets is the list of enabled audit loggers
    	// Must be immutable at all times.
    	// Can be swapped to another while holding swapMu
    	auditTargets  = []Target{}
    	swapAuditMuRW sync.RWMutex
    
    	// This is always set represent /dev/console target
    	consoleTgt Target
    )
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 22:56:14 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  2. internal/event/targetlist.go

    	currentSendCalls  atomic.Int64
    	totalEvents       atomic.Int64
    	eventsSkipped     atomic.Int64
    	eventsErrorsTotal atomic.Int64
    
    	sync.RWMutex
    	targets map[TargetID]Target
    	queue   chan asyncEvent
    	ctx     context.Context
    
    	statLock    sync.RWMutex
    	targetStats map[TargetID]targetStat
    }
    
    type targetStat struct {
    	// The number of concurrent async Send calls per targets
    	currentSendCalls int64
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  3. internal/bucket/bandwidth/monitor.go

    type bucketThrottle struct {
    	*rate.Limiter
    	NodeBandwidthPerSec int64
    }
    
    // Monitor holds the state of the global bucket monitor
    type Monitor struct {
    	tlock sync.RWMutex // mutex for bucket throttling
    	mlock sync.RWMutex // mutex for bucket measurement
    
    	bucketsThrottle    map[BucketOptions]*bucketThrottle
    	bucketsMeasurement map[BucketOptions]*bucketMeasurement // Buckets with objects in flight
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 6K bytes
    - Viewed (0)
  4. cmd/bucket-targets.go

    }
    
    // BucketTargetSys represents bucket targets subsystem
    type BucketTargetSys struct {
    	sync.RWMutex
    	arnRemotesMap map[string]arnTarget
    	targetsMap    map[string][]madmin.BucketTarget
    	hMutex        sync.RWMutex
    	hc            map[string]epHealth
    	hcClient      *madmin.AnonymousClient
    	aMutex        sync.RWMutex
    	arnErrsMap    map[string]arnErrs // map of ARN to error count of failures to get target
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  5. cmd/http-stats.go

    	currentS3Requests *HTTPAPIStats
    	totalS3Requests   *HTTPAPIStats
    	totalS34xxErrors  *HTTPAPIStats
    	totalS35xxErrors  *HTTPAPIStats
    	totalS3Canceled   *HTTPAPIStats
    }
    
    type bucketHTTPStats struct {
    	sync.RWMutex
    	httpStats map[string]bucketHTTPAPIStats
    }
    
    func newBucketHTTPStats() *bucketHTTPStats {
    	return &bucketHTTPStats{
    		httpStats: make(map[string]bucketHTTPAPIStats),
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 11.4K bytes
    - Viewed (0)
  6. prepare_stmt.go

    }
    
    type PreparedStmtDB struct {
    	Stmts       map[string]*Stmt
    	PreparedSQL []string
    	Mux         *sync.RWMutex
    	ConnPool
    }
    
    func NewPreparedStmtDB(connPool ConnPool) *PreparedStmtDB {
    	return &PreparedStmtDB{
    		ConnPool:    connPool,
    		Stmts:       make(map[string]*Stmt),
    		Mux:         &sync.RWMutex{},
    		PreparedSQL: make([]string, 0, 100),
    	}
    }
    
    func (db *PreparedStmtDB) GetDBConn() (*sql.DB, error) {
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Thu Mar 28 08:47:39 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  7. cmd/ilm-config.go

    	"github.com/minio/minio/internal/config/ilm"
    )
    
    var globalILMConfig = ilmConfig{
    	cfg: ilm.Config{
    		ExpirationWorkers: 100,
    		TransitionWorkers: 100,
    	},
    }
    
    type ilmConfig struct {
    	mu  sync.RWMutex
    	cfg ilm.Config
    }
    
    func (c *ilmConfig) getExpirationWorkers() int {
    	c.mu.RLock()
    	defer c.mu.RUnlock()
    
    	return c.cfg.ExpirationWorkers
    }
    
    func (c *ilmConfig) getTransitionWorkers() int {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 05 02:50:24 GMT 2024
    - 1.3K bytes
    - Viewed (0)
  8. cmd/tier.go

    type TierConfigMgr struct {
    	sync.RWMutex `msg:"-"`
    	drivercache  map[string]WarmBackend `msg:"-"`
    
    	Tiers           map[string]madmin.TierConfig `json:"tiers"`
    	lastRefreshedAt time.Time                    `msg:"-"`
    }
    
    type tierMetrics struct {
    	sync.RWMutex  // protects requestsCount only
    	requestsCount map[string]struct {
    		success int64
    		failure int64
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  9. cmd/bucket-replication-stats.go

    	Cache             map[string]*BucketReplicationStats
    	mostRecentStats   BucketStatsMap
    	registry          metrics.Registry
    	sync.RWMutex                 // mutex for Cache
    	mostRecentStatsMu sync.Mutex // mutex for mostRecentStats
    
    	wlock sync.RWMutex // mutex for active workers
    
    	movingAvgTicker *time.Ticker // Ticker for calculating moving averages
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.4K bytes
    - Viewed (0)
  10. internal/config/browser/browser.go

    			Value: config.EnableOff,
    		},
    		config.KV{
    			Key:   browserReferrerPolicy,
    			Value: "strict-origin-when-cross-origin",
    		},
    	}
    )
    
    // configLock is a global lock for browser config
    var configLock sync.RWMutex
    
    // Config storage class configuration
    type Config struct {
    	CSPPolicy             string `json:"csp_policy"`
    	HSTSSeconds           int    `json:"hsts_seconds"`
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 5.8K bytes
    - Viewed (0)
Back to top