diff options
Diffstat (limited to 'ledger/notifier.go')
-rw-r--r-- | ledger/notifier.go | 26 |
1 files changed, 23 insertions, 3 deletions
diff --git a/ledger/notifier.go b/ledger/notifier.go index d5a0d4886..e922c73e1 100644 --- a/ledger/notifier.go +++ b/ledger/notifier.go @@ -17,6 +17,8 @@ package ledger import ( + "context" + "database/sql" "sync" "github.com/algorand/go-deadlock" @@ -85,7 +87,7 @@ func (bn *blockNotifier) close() { bn.closing.Wait() } -func (bn *blockNotifier) loadFromDisk(l ledgerForTracker) error { +func (bn *blockNotifier) loadFromDisk(l ledgerForTracker, _ basics.Round) error { bn.cond = sync.NewCond(&bn.mu) bn.running = true bn.pendingBlocks = nil @@ -108,6 +110,24 @@ func (bn *blockNotifier) newBlock(blk bookkeeping.Block, delta ledgercore.StateD bn.cond.Broadcast() } -func (bn *blockNotifier) committedUpTo(rnd basics.Round) basics.Round { - return rnd +func (bn *blockNotifier) committedUpTo(rnd basics.Round) (retRound, lookback basics.Round) { + return rnd, basics.Round(0) +} + +func (bn *blockNotifier) prepareCommit(dcc *deferredCommitContext) error { + return nil +} + +func (bn *blockNotifier) commitRound(context.Context, *sql.Tx, *deferredCommitContext) error { + return nil +} + +func (bn *blockNotifier) postCommit(ctx context.Context, dcc *deferredCommitContext) { +} + +func (bn *blockNotifier) handleUnorderedCommit(uint64, basics.Round, basics.Round) { +} + +func (bn *blockNotifier) produceCommittingTask(committedRound basics.Round, dbRound basics.Round, dcr *deferredCommitRange) *deferredCommitRange { + return dcr } |