diff options
Diffstat (limited to 'ledger/bulletin.go')
-rw-r--r-- | ledger/bulletin.go | 25 |
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 } |