fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-04-25 06:42:16 +00:00
Code Issues Projects Releases Wiki Activity

feedback tweaks

Browse Source
This commit is contained in:
Sean Braithwaite 2019-09-12 12:50:25 -04:00
parent 5474528db1
commit c62b7fbd7e
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
blockchain/v2/routine.go
View File

@ -23,12 +23,12 @@ type handleFunc = func(event Event) (Event, error)
// sent events and produce `last()` event representing the terminal state. // sent events and produce `last()` event representing the terminal state.
type Routine struct { type Routine struct {
name string name string
handle handleFunc
queue *queue.PriorityQueue queue *queue.PriorityQueue
out chan Event // XXX: actually item out chan Event
fin chan error fin chan error
rdy chan struct{} rdy chan struct{}
running *uint32 running *uint32
handle handleFunc
logger log.Logger logger log.Logger
metrics *Metrics metrics *Metrics
} }
@ -38,8 +38,8 @@ var queueSize int = 10
func newRoutine(name string, handleFunc handleFunc) *Routine { func newRoutine(name string, handleFunc handleFunc) *Routine {
return &Routine{ return &Routine{
name: name, name: name,
queue: queue.NewPriorityQueue(queueSize, true),
handle: handleFunc, handle: handleFunc,
queue: queue.NewPriorityQueue(queueSize, true),
out: make(chan Event, queueSize), out: make(chan Event, queueSize),
rdy: make(chan struct{}, 1), rdy: make(chan struct{}, 1),
fin: make(chan error, 1), fin: make(chan error, 1),

4
blockchain/v2/routine_test.go
View File

@ -143,8 +143,12 @@ func TestPriority(t *testing.T) {
}() }()
time.Sleep(10 * time.Millisecond) time.Sleep(10 * time.Millisecond)
assert.True(t, routine.isRunning(),
"expected an started routine")
assert.True(t, routine.trySend(highPriorityEvent{}), assert.True(t, routine.trySend(highPriorityEvent{}),
"expected send to succeed even when saturated") "expected send to succeed even when saturated")
assert.Equal(t, done, <-routine.final()) assert.Equal(t, done, <-routine.final())
assert.False(t, routine.isRunning(),
"expected an started routine")
} }