| 1444 | } |
| 1445 | |
| 1446 | func (l *LedgerForge) acquireTransactionLocker(ctx context.Context, locker *redlock.MultiLocker) error { |
| 1447 | lockCfg := l.Config().Transaction |
| 1448 | if lockCfg.LockWaitTimeout > 0 { |
| 1449 | return locker.WaitLock(ctx, lockCfg.LockDuration, lockCfg.LockWaitTimeout) |
| 1450 | } |
| 1451 | return locker.Lock(ctx, lockCfg.LockDuration) |
| 1452 | } |
| 1453 | |
| 1454 | func (l *LedgerForge) loadBalancesForQueuedBatch(ctx context.Context, balanceIDs []string) (map[string]*model.Balance, []*model.Balance, error) { |
| 1455 | balancesByID := make(map[string]*model.Balance, len(balanceIDs)) |