summaryrefslogtreecommitdiff
path: root/ledger/notifier.go
diff options
context:
space:
mode:
Diffstat (limited to 'ledger/notifier.go')
-rw-r--r--ledger/notifier.go26
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
}