Fixed bug too many open IPC connect at same time.

This commit is contained in:
dinhln89 2018-06-26 17:56:44 +07:00
parent 9c0e456387
commit 0f75eb97b6

View file

@ -205,14 +205,14 @@ func New(ctx *node.ServiceContext, config *Config) (*Ethereum, error) {
endBlockNumber := startBlockNumber + rCheckpoint - 1 endBlockNumber := startBlockNumber + rCheckpoint - 1
signers := make(map[common.Address]*rewardLog) signers := make(map[common.Address]*rewardLog)
totalSigner := uint64(0) totalSigner := uint64(0)
// Get signers in blockSigner smartcontract.
client, err := contracts.GetEthClient(ctx)
if err != nil {
log.Error("Fail to connect IPC from blockSigner", "error", err)
return err
}
for i := startBlockNumber; i <= endBlockNumber; i++ { for i := startBlockNumber; i <= endBlockNumber; i++ {
// Get signers in blockSigner smartcontract.
client, err := contracts.GetEthClient(ctx)
if err != nil {
log.Error("Fail to connect IPC from blockSigner", "error", err)
return err
}
addrs, err := contracts.GetSignersFromContract(client, i) addrs, err := contracts.GetSignersFromContract(client, i)
if err != nil { if err != nil {
log.Error("Fail to get signers from smartcontract.", "error", err, "blockNumber", i) log.Error("Fail to get signers from smartcontract.", "error", err, "blockNumber", i)