Method acquireLineageLocks

lineage.go:506–522

acquireLineageLocks acquires distributed locks for multiple shadow balances using MultiLocker. MultiLocker handles sorting (prevents deadlock) and deduplication automatically. This is used for both credit and debit lineage processing to prevent race conditions. Parameters: - ctx context.Context: Th

(ctx context.Context, balanceIDs []string)

// - *redlock.MultiLocker: The acquired multi-lock.
// - error: An error if the locks could not be acquired.
func (l *LedgerForge) acquireLineageLocks(ctx context.Context, balanceIDs []string) (*redlock.MultiLocker, error) {
	// Prefix all keys to avoid collision with main transaction locks
	lockKeys := make([]string, 0, len(balanceIDs))
	for _, id := range balanceIDs {
		lockKeys = append(lockKeys, fmt.Sprintf("lineage:%s", id))
	}

	// MultiLocker handles deduplication and sorts keys lexicographically
	locker := redlock.NewMultiLocker(l.redis, lockKeys, model.GenerateUUIDWithSuffix("loc"))

	err := locker.Lock(ctx, l.Config().Transaction.LockDuration)
	if err != nil {
		return nil, fmt.Errorf("failed to acquire lineage locks: %w", err)
	}

	return locker, nil
}

// getSourceAggregateBalance retrieves or creates the aggregate balance for the source identity.
//