diff options
author | Mission Liao <mission.liao@dexon.org> | 2018-09-25 14:10:16 +0800 |
---|---|---|
committer | Wei-Ning Huang <aitjcize@gmail.com> | 2018-09-25 14:10:16 +0800 |
commit | 6c8d26d2e797e8420fc3de4b15e4c556f968aba0 (patch) | |
tree | 22beecc01da7a9ce5cac36135a89010d6d4ed4f2 /core/nonblocking-application.go | |
parent | ca935bdbac190766f29fb73433a82ee5806bc8f9 (diff) | |
download | dexon-consensus-6c8d26d2e797e8420fc3de4b15e4c556f968aba0.tar dexon-consensus-6c8d26d2e797e8420fc3de4b15e4c556f968aba0.tar.gz dexon-consensus-6c8d26d2e797e8420fc3de4b15e4c556f968aba0.tar.bz2 dexon-consensus-6c8d26d2e797e8420fc3de4b15e4c556f968aba0.tar.lz dexon-consensus-6c8d26d2e797e8420fc3de4b15e4c556f968aba0.tar.xz dexon-consensus-6c8d26d2e797e8420fc3de4b15e4c556f968aba0.tar.zst dexon-consensus-6c8d26d2e797e8420fc3de4b15e4c556f968aba0.zip |
core: add debug (#133)
* Split interface
* Rename nonblocking-application to nonblocking
Parts needs nonblocking gets more.
* Implement core.nonBlocking based on interface split
* Fix: the witness parent hash could be parent on compaction chain.
* Rename Application.DeliverBlock to BlockDeliver
To sync with naming of other methods.
* Change methods' fingerprint
- BlockConfirmed provides block hash only.
- BlockDeliver provde a whole block.
Diffstat (limited to 'core/nonblocking-application.go')
-rw-r--r-- | core/nonblocking-application.go | 166 |
1 files changed, 0 insertions, 166 deletions
diff --git a/core/nonblocking-application.go b/core/nonblocking-application.go deleted file mode 100644 index 98f92fc..0000000 --- a/core/nonblocking-application.go +++ /dev/null @@ -1,166 +0,0 @@ -// Copyright 2018 The dexon-consensus-core Authors -// This file is part of the dexon-consensus-core library. -// -// The dexon-consensus-core library is free software: you can redistribute it -// and/or modify it under the terms of the GNU Lesser General Public License as -// published by the Free Software Foundation, either version 3 of the License, -// or (at your option) any later version. -// -// The dexon-consensus-core library is distributed in the hope that it will be -// useful, but WITHOUT ANY WARRANTY; without even the implied warranty of -// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser -// General Public License for more details. -// -// You should have received a copy of the GNU Lesser General Public License -// along with the dexon-consensus-core library. If not, see -// <http://www.gnu.org/licenses/>. - -package core - -import ( - "fmt" - "sync" - "time" - - "github.com/dexon-foundation/dexon-consensus-core/common" - "github.com/dexon-foundation/dexon-consensus-core/core/types" -) - -type blockConfirmedEvent struct { - block *types.Block -} - -type stronglyAckedEvent struct { - blockHash common.Hash -} - -type totalOrderingDeliverEvent struct { - blockHashes common.Hashes - early bool -} - -type deliverBlockEvent struct { - blockHash common.Hash - timestamp time.Time -} - -type witnessAckEvent struct { - witnessAck *types.WitnessAck -} - -// nonBlockingApplication implements Application and is a decorator for -// Application that makes the methods to be non-blocking. -type nonBlockingApplication struct { - app Application - eventChan chan interface{} - events []interface{} - eventsChange *sync.Cond - running sync.WaitGroup -} - -func newNonBlockingApplication(app Application) *nonBlockingApplication { - nonBlockingApp := &nonBlockingApplication{ - app: app, - eventChan: make(chan interface{}, 6), - events: make([]interface{}, 0, 100), - eventsChange: sync.NewCond(&sync.Mutex{}), - } - go nonBlockingApp.run() - return nonBlockingApp -} - -func (app *nonBlockingApplication) addEvent(event interface{}) { - app.eventsChange.L.Lock() - defer app.eventsChange.L.Unlock() - app.events = append(app.events, event) - app.eventsChange.Broadcast() -} - -func (app *nonBlockingApplication) run() { - // This go routine consume the first event from events and call the - // corresponding method of app. - for { - var event interface{} - func() { - app.eventsChange.L.Lock() - defer app.eventsChange.L.Unlock() - for len(app.events) == 0 { - app.eventsChange.Wait() - } - event = app.events[0] - app.events = app.events[1:] - app.running.Add(1) - }() - switch e := event.(type) { - case stronglyAckedEvent: - app.app.StronglyAcked(e.blockHash) - case blockConfirmedEvent: - app.app.BlockConfirmed(e.block) - case totalOrderingDeliverEvent: - app.app.TotalOrderingDeliver(e.blockHashes, e.early) - case deliverBlockEvent: - app.app.DeliverBlock(e.blockHash, e.timestamp) - case witnessAckEvent: - app.app.WitnessAckDeliver(e.witnessAck) - default: - fmt.Printf("Unknown event %v.", e) - } - app.running.Done() - app.eventsChange.Broadcast() - } -} - -// wait will wait for all event in events finishes. -func (app *nonBlockingApplication) wait() { - app.eventsChange.L.Lock() - defer app.eventsChange.L.Unlock() - for len(app.events) > 0 { - app.eventsChange.Wait() - } - app.running.Wait() -} - -// PreparePayload cannot be non-blocking. -func (app *nonBlockingApplication) PreparePayload( - position types.Position) []byte { - return app.app.PreparePayload(position) -} - -// VerifyPayloads cannot be non-blocking. -func (app *nonBlockingApplication) VerifyPayloads(payloads []byte) bool { - return app.app.VerifyPayloads(payloads) -} - -// BlockConfirmed is called when a block is confirmed and added to lattice. -func (app *nonBlockingApplication) BlockConfirmed(block *types.Block) { - app.addEvent(blockConfirmedEvent{block}) -} - -// StronglyAcked is called when a block is strongly acked. -func (app *nonBlockingApplication) StronglyAcked(blockHash common.Hash) { - app.addEvent(stronglyAckedEvent{blockHash}) -} - -// TotalOrderingDeliver is called when the total ordering algorithm deliver -// a set of block. -func (app *nonBlockingApplication) TotalOrderingDeliver( - blockHashes common.Hashes, early bool) { - app.addEvent(totalOrderingDeliverEvent{blockHashes, early}) -} - -// DeliverBlock is called when a block is add to the compaction chain. -func (app *nonBlockingApplication) DeliverBlock( - blockHash common.Hash, timestamp time.Time) { - app.addEvent(deliverBlockEvent{blockHash, timestamp}) -} - -// BlockProcessedChan returns a channel to receive the block hashes that have -// finished processing by the application. -func (app *nonBlockingApplication) BlockProcessedChan() <-chan types.WitnessResult { - return app.app.BlockProcessedChan() -} - -// WitnessAckDeliver is called when a witness ack is created. -func (app *nonBlockingApplication) WitnessAckDeliver(witnessAck *types.WitnessAck) { - app.addEvent(witnessAckEvent{witnessAck}) -} |