Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for swap (0.12 sec)

  1. cmd/xl-storage-disk-id-check.go

    	// alloc on every call, so we have a clean entry to swap in.
    	t := time.Now().Unix()
    	e.init.Do(func() {
    		e.cached.Store(&AccElem{})
    		atomic.StoreInt64(&e.cachedSec, t)
    	})
    	acc := e.cached.Load()
    	if lastT := atomic.LoadInt64(&e.cachedSec); lastT != t {
    		// Check if lastT was changed by someone else.
    		if atomic.CompareAndSwapInt64(&e.cachedSec, lastT, t) {
    			// Now we swap in a new.
    			newAcc := &AccElem{}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

      }
    
      /**
       * Returns a plan to reuse a pooled connection, or null if the pool doesn't have a connection for
       * this address.
       *
       * If [planToReplace] is non-null, this will swap it for a pooled connection if that pooled
       * connection uses HTTP/2. That results in fewer sockets overall and thus fewer TCP slow starts.
       */
      internal fun planReusePooledConnection(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 12K bytes
    - Viewed (0)
  3. internal/logger/logger.go

    func uniq(data sort.Interface) (size int) {
    	p, l := 0, data.Len()
    	if l <= 1 {
    		return l
    	}
    	for i := 1; i < l; i++ {
    		if !data.Less(p, i) {
    			continue
    		}
    		p++
    		if p < i {
    			data.Swap(p, i)
    		}
    	}
    	return p + 1
    }
    
    // Remove any duplicates and return unique entries.
    func uniqueEntries(paths []string) []string {
    	sort.Strings(paths)
    	n := uniq(sort.StringSlice(paths))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  4. cmd/bucket-targets.go

    				epHealth.offlineDuration = prev.offlineDuration
    				epHealth.lastHCAt = prev.lastHCAt
    				epHealth.latency = prev.latency
    			}
    			m[t.Endpoint] = epHealth
    		}
    	}
    	// swap out the map
    	sys.hc = m
    	sys.hMutex.Unlock()
    }
    
    func (sys *BucketTargetSys) healthStats() map[string]epHealth {
    	sys.hMutex.RLock()
    	defer sys.hMutex.RUnlock()
    	m := make(map[string]epHealth, len(sys.hc))
    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. helm-releases/minio-5.2.0.tgz

    building packages. # This supports shell glob matching, relative path matching, and # negation (prefixed with !). Only one pattern per line. .DS_Store # Common VCS dirs .git/ .gitignore .bzr/ .bzrignore .hg/ .hgignore .svn/ # Common backup files *.swp *.bak *.tmp *~ # Various IDEs .project .idea/ *.tmproj # OWNERS file for Kubernetes OWNERS minio/README.md # MinIO Community Helm Chart [![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io) [![license](https://img.shields.io/badge/l...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 10:14:37 GMT 2024
    - 21.7K bytes
    - Viewed (0)
Back to top