summaryrefslogtreecommitdiff
path: root/ledger/bulletin.go
diff options
context:
space:
mode:
Diffstat (limited to 'ledger/bulletin.go')
-rw-r--r--ledger/bulletin.go25
1 files changed, 22 insertions, 3 deletions
diff --git a/ledger/bulletin.go b/ledger/bulletin.go
index b7bb53ce7..1e95ee2ab 100644
--- a/ledger/bulletin.go
+++ b/ledger/bulletin.go
@@ -17,6 +17,8 @@
package ledger
import (
+ "context"
+ "database/sql"
"sync/atomic"
"github.com/algorand/go-deadlock"
@@ -78,7 +80,7 @@ func (b *bulletin) Wait(round basics.Round) chan struct{} {
return signal.signal
}
-func (b *bulletin) loadFromDisk(l ledgerForTracker) error {
+func (b *bulletin) loadFromDisk(l ledgerForTracker, _ basics.Round) error {
b.pendingNotificationRequests = make(map[basics.Round]notifier)
b.latestRound = l.Latest()
return nil
@@ -90,7 +92,7 @@ func (b *bulletin) close() {
func (b *bulletin) newBlock(blk bookkeeping.Block, delta ledgercore.StateDelta) {
}
-func (b *bulletin) committedUpTo(rnd basics.Round) basics.Round {
+func (b *bulletin) committedUpTo(rnd basics.Round) (retRound, lookback basics.Round) {
b.mu.Lock()
defer b.mu.Unlock()
@@ -104,5 +106,22 @@ func (b *bulletin) committedUpTo(rnd basics.Round) basics.Round {
}
b.latestRound = rnd
- return rnd
+ return rnd, basics.Round(0)
+}
+
+func (b *bulletin) prepareCommit(dcc *deferredCommitContext) error {
+ return nil
+}
+
+func (b *bulletin) commitRound(context.Context, *sql.Tx, *deferredCommitContext) error {
+ return nil
+}
+
+func (b *bulletin) postCommit(ctx context.Context, dcc *deferredCommitContext) {
+}
+
+func (b *bulletin) handleUnorderedCommit(uint64, basics.Round, basics.Round) {
+}
+func (b *bulletin) produceCommittingTask(committedRound basics.Round, dbRound basics.Round, dcr *deferredCommitRange) *deferredCommitRange {
+ return dcr
}