Method processDueQueue

x/verification/keeper/queue.go:19–54

(ctx sdk.Context, queuePrefix byte, blockTime time.Time, limit uint32, process func([]byte, time.Time) error)

}

func (k *keeper) processDueQueue(ctx sdk.Context, queuePrefix byte, blockTime time.Time, limit uint32, process func([]byte, time.Time) error) error {
	if limit == 0 {
		return nil
	}

	store := storeprefix.NewStore(ctx.KVStore(k.skey), singletonKey(queuePrefix))
	iter := store.Iterator(nil, nil)
	defer func() {
		_ = iter.Close()
	}()

	entries := make([]dueQueueEntry, 0, limit)
	for ; iter.Valid() && uint32(len(entries)) < limit; iter.Next() {
		dueTime, err := decodeQueueTime(iter.Key())
		if err != nil {
			return err
		}
		if dueTime.After(blockTime) {
			break
		}

		entries = append(entries, dueQueueEntry{
			key:     append([]byte(nil), iter.Key()...),
			dueTime: dueTime,
		})
	}

	for _, entry := range entries {
		if err := process(entry.key, entry.dueTime); err != nil {
			return err
		}
		store.Delete(entry.key)
	}

	return nil
}

func decodeQueueTime(key []byte) (time.Time, error) {
	if len(key) < 8 {