- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 607 for stort (0.23 sec)
-
cmd/iam-store.go
func (store *IAMStoreSys) ListGroups(ctx context.Context) (res []string, err error) { cache := store.lock() defer store.unlock() return store.updateGroups(ctx, cache) } // listGroups - lists groups - fetch groups from cache func (store *IAMStoreSys) listGroups(ctx context.Context) (res []string, err error) { cache := store.rlock() defer store.runlock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Oct 14 16:35:37 UTC 2024 - 83.2K bytes - Viewed (0) -
internal/store/store.go
return } // replayItems - Reads the items from the store and replays. func replayItems[I any](store Store[I], doneCh <-chan struct{}, log logger, id string) <-chan Key { keyCh := make(chan Key) go func() { defer xioutil.SafeClose(keyCh) retryTicker := time.NewTicker(retryInterval) defer retryTicker.Stop() for { for _, key := range store.List() { select { case keyCh <- key:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 4.2K bytes - Viewed (0) -
cmd/iam-object-store.go
logger.Info("IAM expired STS purge took %.2fs", took) } // Store the newly populated map in the iam cache. This takes care of // removing stale entries from the existing map. cache.iamSTSAccountsMap = stsAccountsFromStore stsAccPoliciesFromStore.Range(func(k string, v MappedPolicy) bool { cache.iamSTSPolicyMap.Store(k, v) return true }) return nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 23:40:37 UTC 2024 - 26.6K bytes - Viewed (0) -
android/guava/src/com/google/common/primitives/Shorts.java
* @return the same value cast to {@code short} if it is in the range of the {@code short} type, * {@link Short#MAX_VALUE} if it is too large, or {@link Short#MIN_VALUE} if it is too small */ public static short saturatedCast(long value) { if (value > Short.MAX_VALUE) { return Short.MAX_VALUE; } if (value < Short.MIN_VALUE) { return Short.MIN_VALUE; } return (short) value; }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Aug 27 16:47:48 UTC 2024 - 25.5K bytes - Viewed (0) -
guava/src/com/google/common/primitives/Shorts.java
* @return the same value cast to {@code short} if it is in the range of the {@code short} type, * {@link Short#MAX_VALUE} if it is too large, or {@link Short#MIN_VALUE} if it is too small */ public static short saturatedCast(long value) { if (value > Short.MAX_VALUE) { return Short.MAX_VALUE; } if (value < Short.MIN_VALUE) { return Short.MIN_VALUE; } return (short) value; }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Aug 27 16:47:48 UTC 2024 - 25.5K bytes - Viewed (0) -
gorm.go
} // Debug start debug mode func (db *DB) Debug() (tx *DB) { tx = db.getInstance() return tx.Session(&Session{ Logger: db.Logger.LogMode(logger.Info), }) } // Set store value with key into current db instance's context func (db *DB) Set(key string, value interface{}) *DB { tx := db.getInstance() tx.Statement.Settings.Store(key, value) return tx }
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Oct 09 11:29:48 UTC 2024 - 12.1K bytes - Viewed (0) -
internal/store/queuestore.go
return } // Del - Deletes an entry from the store. func (store *QueueStore[_]) Del(key Key) error { store.Lock() defer store.Unlock() return store.del(key) } // Len returns the entry count. func (store *QueueStore[_]) Len() int { store.RLock() l := len(store.entries) defer store.RUnlock() return l } // lockless call func (store *QueueStore[_]) del(key Key) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.6K bytes - Viewed (0) -
guava/src/com/google/common/hash/LittleEndianByteArray.java
result |= (input[offset + i] & 0xFFL) << (i * 8); } return result; } /** * Store 8 bytes into the provided array at the indicated offset, using the value provided. * * @param sink the output byte array * @param offset the offset into the array at which to start writing * @param value the value to write */ static void store64(byte[] sink, int offset, long value) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 9.8K bytes - Viewed (0) -
cmd/data-usage-cache.go
for oidx < len(v) { intOld, intNew := ObjectsHistogramIntervalsV1[oidx], ObjectsHistogramIntervals[nidx] // skip intervals that aren't common to both histograms if intOld.start != intNew.start || intOld.end != intNew.end { nidx++ continue } h[nidx] += v[oidx] oidx++ nidx++ } } // toMap returns the map to a map[string]uint64. func (h *sizeHistogram) toMap() map[string]uint64 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 34.7K bytes - Viewed (0) -
src/archive/zip/writer.go
return err } if _, err := io.WriteString(w.cw, h.Comment); err != nil { return err } } end := w.cw.count records := uint64(len(w.dir)) size := uint64(end - start) offset := uint64(start) if f := w.testHookCloseSizeOffset; f != nil { f(size, offset) } if records >= uint16max || size >= uint32max || offset >= uint32max { var buf [directory64EndLen + directory64LocLen]byte
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Sep 23 14:32:33 UTC 2024 - 19.4K bytes - Viewed (0)