Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 46 for atomsvc (0.08 sec)

  1. cmd/bucket-replication-metrics.go

    func (p *ProxyMetric) add(p2 ProxyMetric) {
    	atomic.AddUint64(&p.GetTotal, p2.GetTotal)
    	atomic.AddUint64(&p.HeadTotal, p2.HeadTotal)
    	atomic.AddUint64(&p.GetTagTotal, p2.GetTagTotal)
    	atomic.AddUint64(&p.PutTagTotal, p2.PutTagTotal)
    	atomic.AddUint64(&p.RmvTagTotal, p2.RmvTagTotal)
    	atomic.AddUint64(&p.GetFailedTotal, p2.GetFailedTotal)
    	atomic.AddUint64(&p.HeadFailedTotal, p2.HeadFailedTotal)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  2. api/go1.23.txt

    pkg sync/atomic, func OrUint32(*uint32, uint32) uint32 #61395
    pkg sync/atomic, func OrUint64(*uint64, uint64) uint64 #61395
    pkg sync/atomic, func OrUintptr(*uintptr, uintptr) uintptr #61395
    pkg sync/atomic, method (*Int32) And(int32) int32 #61395
    pkg sync/atomic, method (*Int32) Or(int32) int32 #61395
    pkg sync/atomic, method (*Int64) And(int64) int64 #61395
    pkg sync/atomic, method (*Int64) Or(int64) int64 #61395
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jun 25 17:08:08 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. api/go1.19.txt

    pkg sync/atomic, method (*Uintptr) Load() uintptr #50860
    pkg sync/atomic, method (*Uintptr) Store(uintptr) #50860
    pkg sync/atomic, method (*Uintptr) Swap(uintptr) uintptr #50860
    pkg sync/atomic, type Bool struct #50860
    pkg sync/atomic, type Int32 struct #50860
    pkg sync/atomic, type Int64 struct #50860
    pkg sync/atomic, type Pointer[$0 interface{}] struct #50860
    pkg sync/atomic, type Uint32 struct #50860
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Dec 02 16:29:41 UTC 2022
    - 17.9K bytes
    - Viewed (0)
  4. cmd/http-stats.go

    	serverStats := ServerHTTPStats{}
    	serverStats.S3RequestsIncoming = atomic.SwapUint64(&st.s3RequestsIncoming, 0)
    	serverStats.S3RequestsInQueue = atomic.LoadInt32(&st.s3RequestsInQueue)
    	serverStats.TotalS3RejectedAuth = atomic.LoadUint64(&st.rejectedRequestsAuth)
    	serverStats.TotalS3RejectedTime = atomic.LoadUint64(&st.rejectedRequestsTime)
    	serverStats.TotalS3RejectedHeader = atomic.LoadUint64(&st.rejectedRequestsHeader)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  5. cmd/bucket-replication-stats.go

    	defer r.qCache.Unlock()
    	v, ok := r.qCache.bucketStats[bucket]
    	if !ok {
    		v = newInQueueStats(r.registry, bucket)
    	}
    	atomic.AddInt64(&v.nowBytes, sz)
    	atomic.AddInt64(&v.nowCount, 1)
    	r.qCache.bucketStats[bucket] = v
    	atomic.AddInt64(&r.qCache.srQueueStats.nowBytes, sz)
    	atomic.AddInt64(&r.qCache.srQueueStats.nowCount, 1)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 13.6K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    	diskHealthOK int32 = iota
    	diskHealthFaulty
    )
    
    type diskHealthTracker struct {
    	// atomic time of last success
    	lastSuccess int64
    
    	// atomic time of last time a token was grabbed.
    	lastStarted int64
    
    	// Atomic status of disk.
    	status atomic.Int32
    
    	// Atomic number indicates if a disk is hung
    	waiting atomic.Int32
    }
    
    // newDiskHealthTracker creates a new disk health tracker.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  7. cmd/perf-tests.go

    }
    
    func (n *netPerfRX) Connect() {
    	n.Lock()
    	defer n.Unlock()
    	n.activeConnections++
    	atomic.StoreUint64(&n.RX, 0)
    	n.lastToConnect = time.Now()
    }
    
    func (n *netPerfRX) Disconnect() {
    	n.Lock()
    	defer n.Unlock()
    	n.activeConnections--
    	if n.firstToDisconnect.IsZero() {
    		n.RXSample = atomic.LoadUint64(&n.RX)
    		n.firstToDisconnect = time.Now()
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  8. cmd/local-locker.go

    type localLocker struct {
    	mutex     sync.Mutex
    	waitMutex atomic.Int32
    	lockMap   map[string][]lockRequesterInfo
    	lockUID   map[string]string // UUID -> resource map.
    
    	// the following are updated on every cleanup defined in lockValidityDuration
    	readers         atomic.Int32
    	writers         atomic.Int32
    	lastCleanup     atomic.Pointer[time.Time]
    	locksOverloaded atomic.Int64
    }
    
    // getMutex will lock the mutex.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  9. cmd/generic-handlers.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"fmt"
    	"net"
    	"net/http"
    	"path"
    	"runtime/debug"
    	"slices"
    	"strings"
    	"sync/atomic"
    	"time"
    	"unicode"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/minio-go/v7/pkg/s3utils"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio/internal/grid"
    	xnet "github.com/minio/pkg/v3/net"
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.7K bytes
    - Viewed (1)
  10. doc/go_mem.html

    twice.
    </p>
    
    <h3 id="atomic">Atomic Values</h3>
    
    <p>
    The APIs in the <a href="/pkg/sync/atomic/"><code>sync/atomic</code></a>
    package are collectively “atomic operations”
    that can be used to synchronize the execution of different goroutines.
    If the effect of an atomic operation <i>A</i> is observed by atomic operation <i>B</i>,
    then <i>A</i> is synchronized before <i>B</i>.
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Aug 05 15:41:37 UTC 2025
    - 26.6K bytes
    - Viewed (0)
Back to top