Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 607 for stort (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top