poanetwork
/
quorum
mirror of https://github.com/poanetwork/quorum.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

reactor event channels have large buffer to allow more tolerance

This commit is contained in:
zelig 2014-07-21 19:26:01 +01:00
parent 9f7d8ff302
commit 74abc457ad
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ethereal/ext_app.go
View File

@ -38,8 +38,8 @@ type ExtApplication struct {
func NewExtApplication(container AppContainer, lib *UiLib) *ExtApplication { func NewExtApplication(container AppContainer, lib *UiLib) *ExtApplication {
app := &ExtApplication{ app := &ExtApplication{
ethpub.NewPEthereum(lib.eth), ethpub.NewPEthereum(lib.eth),
make(chan ethreact.Event, 10), make(chan ethreact.Event, 100),
make(chan ethreact.Event, 10), make(chan ethreact.Event, 100),
make(chan bool), make(chan bool),
make(chan bool), make(chan bool),
container, container,

12
ethereal/gui.go
View File

@ -281,12 +281,12 @@ func (self *Gui) getObjectByName(objectName string) qml.Object {
func (gui *Gui) update() { func (gui *Gui) update() {
var ( var (
blockChan = make(chan ethreact.Event, 1) blockChan = make(chan ethreact.Event, 100)
txChan = make(chan ethreact.Event, 1) txChan = make(chan ethreact.Event, 100)
objectChan = make(chan ethreact.Event, 1) objectChan = make(chan ethreact.Event, 100)
peerChan = make(chan ethreact.Event, 1) peerChan = make(chan ethreact.Event, 100)
chainSyncChan = make(chan ethreact.Event, 1) chainSyncChan = make(chan ethreact.Event, 100)
miningChan = make(chan ethreact.Event, 1) miningChan = make(chan ethreact.Event, 100)
) )
peerUpdateTicker := time.NewTicker(5 * time.Second) peerUpdateTicker := time.NewTicker(5 * time.Second)