Browse Source

boost sendQueue for votes

pull/67/head
Jae Kwon 10 years ago
parent
commit
32f7babf87
1 changed files with 9 additions and 6 deletions
  1. +9
    -6
      consensus/reactor.go

+ 9
- 6
consensus/reactor.go View File

@ -84,16 +84,19 @@ func (conR *ConsensusReactor) GetChannels() []*p2p.ChannelDescriptor {
// TODO optimize // TODO optimize
return []*p2p.ChannelDescriptor{ return []*p2p.ChannelDescriptor{
&p2p.ChannelDescriptor{ &p2p.ChannelDescriptor{
Id: StateChannel,
Priority: 5,
Id: StateChannel,
Priority: 5,
SendQueueCapacity: 100,
}, },
&p2p.ChannelDescriptor{ &p2p.ChannelDescriptor{
Id: DataChannel,
Priority: 5,
Id: DataChannel,
Priority: 5,
SendQueueCapacity: 2,
}, },
&p2p.ChannelDescriptor{ &p2p.ChannelDescriptor{
Id: VoteChannel,
Priority: 5,
Id: VoteChannel,
Priority: 5,
SendQueueCapacity: 40,
}, },
} }
} }


Loading…
Cancel
Save