Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 279 for sliced (0.9 sec)

  1. cmd/speedtest.go

    				enableSha256:    opts.enableSha256,
    				enableMultipart: opts.enableMultipart,
    				creds:           opts.creds,
    			}
    
    			results := globalNotificationSys.SpeedTest(ctx, sopts)
    			sort.Slice(results, func(i, j int) bool {
    				return results[i].Endpoint < results[j].Endpoint
    			})
    
    			totalPut := uint64(0)
    			totalGet := uint64(0)
    			for _, result := range results {
    				totalPut += result.Uploads
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  2. cmd/admin-heal-ops.go

    	FailureDetail string            `json:"Detail,omitempty"`
    	StartTime     time.Time         `json:"StartTime"`
    
    	// settings for the heal sequence
    	HealSettings madmin.HealOpts `json:"Settings"`
    
    	// slice of available heal result records
    	Items []madmin.HealResultItem `json:"Items"`
    }
    
    // structure to hold state of all heal sequences in server memory
    type allHealState struct {
    	sync.RWMutex
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  3. cmd/metacache-bucket.go

    			if _, ok := remove[id]; ok {
    				continue
    			}
    			remainCaches = append(remainCaches, cache)
    		}
    		if len(remainCaches) > metacacheMaxEntries {
    			// Sort oldest last...
    			sort.Slice(remainCaches, func(i, j int) bool {
    				return remainCaches[i].lastHandout.Before(remainCaches[j].lastHandout)
    			})
    			// Keep first metacacheMaxEntries...
    			for _, cache := range remainCaches[metacacheMaxEntries:] {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  4. internal/stmt_store/stmt_store.go

    	//   error: An error if the statement preparation fails.
    	New(ctx context.Context, key string, isTransaction bool, connPool ConnPool, locker sync.Locker) (*Stmt, error)
    
    	// Keys returns a slice of all cache keys in the store.
    	Keys() []string
    
    	// Get retrieves a Stmt object from the store based on the given key.
    	// Parameters:
    	//   key: The key used to look up the Stmt object.
    	// Returns:
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Sun Apr 27 06:05:16 UTC 2025
    - 6K bytes
    - Viewed (0)
  5. cmd/data-usage-utils.go

    	for tier, stats := range ts {
    		infos = append(infos, madmin.TierInfo{
    			Name:  tier,
    			Type:  globalTierConfigMgr.TierType(tier),
    			Stats: stats,
    		})
    	}
    
    	sort.Slice(infos, func(i, j int) bool {
    		if infos[i].Type == "internal" {
    			return true
    		}
    		if infos[j].Type == "internal" {
    			return false
    		}
    		return infos[i].Name < infos[j].Name
    	})
    	return infos
    }
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  6. internal/lru/lru.go

    		if now.After(ent.ExpiresAt) {
    			continue
    		}
    		maps[ent.Key] = ent.Value
    		// keys = append(keys, ent.Key)
    	}
    	return maps
    }
    
    // Keys returns a slice of the keys in the cache, from oldest to newest.
    // Expired entries are filtered out.
    func (c *LRU[K, V]) Keys() []K {
    	c.mu.Lock()
    	defer c.mu.Unlock()
    	keys := make([]K, 0, len(c.items))
    	now := time.Now()
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  7. src/bytes/compare_test.go

    			if cmp != -1 {
    				t.Errorf(`CompareBbigger(%d,%d) = %d`, len, k, cmp)
    			}
    			b[k] = a[k]
    		}
    	}
    }
    
    func TestEndianBaseCompare(t *testing.T) {
    	// This test compares byte slices that are almost identical, except one
    	// difference that for some j, a[j]>b[j] and a[j+1]<b[j+1]. If the implementation
    	// compares large chunks with wrong endianness, it gets wrong result.
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Jul 13 23:11:42 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/cache/Striped64.java

       * contention levels will recur, so the cells will eventually be
       * needed again; and for short-lived ones, it does not matter.
       */
    
      /**
       * Padded variant of AtomicLong supporting only raw accesses plus CAS. The value field is placed
       * between pads, hoping that the JVM doesn't reorder them.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jan 15 22:17:15 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  9. cmd/signature-v4-parser.go

    	// credElement is fetched first to skip replacing the space in access key.
    	credElement := strings.TrimPrefix(strings.Split(strings.TrimSpace(v4Auth), ",")[0], signV4Algorithm)
    	// Replace all spaced strings, some clients can send spaced
    	// parameters and some won't. So we pro-actively remove any spaces
    	// to make parsing easier.
    	v4Auth = strings.ReplaceAll(v4Auth, " ", "")
    	if v4Auth == "" {
    		return sv, ErrAuthHeaderEmpty
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/base/Utf8.java

       */
      public static boolean isWellFormed(byte[] bytes) {
        return isWellFormed(bytes, 0, bytes.length);
      }
    
      /**
       * Returns whether the given byte array slice is a well-formed UTF-8 byte sequence, as defined by
       * {@link #isWellFormed(byte[])}. Note that this can be false even when {@code
       * isWellFormed(bytes)} is true.
       *
       * @param bytes the input buffer
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 7K bytes
    - Viewed (0)
Back to top