Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
whqwjb
go-ethereum
提交
1e63a015
G
go-ethereum
项目概览
whqwjb
/
go-ethereum
与 Fork 源项目一致
从无法访问的项目Fork
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
G
go-ethereum
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
未验证
提交
1e63a015
编写于
8月 23, 2018
作者:
P
Péter Szilágyi
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
miner: add two stress tests based on clique and ethash
上级
92381ee0
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
414 addition
and
0 deletion
+414
-0
miner/stress_clique.go
miner/stress_clique.go
+217
-0
miner/stress_ethash.go
miner/stress_ethash.go
+197
-0
未找到文件。
miner/stress_clique.go
0 → 100644
浏览文件 @
1e63a015
// Copyright 2018 The go-ethereum Authors
// This file is part of the go-ethereum library.
//
// The go-ethereum 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 go-ethereum 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 go-ethereum library. If not, see <http://www.gnu.org/licenses/>.
// +build none
// This file contains a miner stress test based on the Clique consensus engine.
package
main
import
(
"bytes"
"crypto/ecdsa"
"fmt"
"io/ioutil"
"math/big"
"math/rand"
"os"
"time"
"github.com/ethereum/go-ethereum/accounts/keystore"
"github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/common/fdlimit"
"github.com/ethereum/go-ethereum/core"
"github.com/ethereum/go-ethereum/core/types"
"github.com/ethereum/go-ethereum/crypto"
"github.com/ethereum/go-ethereum/eth"
"github.com/ethereum/go-ethereum/eth/downloader"
"github.com/ethereum/go-ethereum/log"
"github.com/ethereum/go-ethereum/node"
"github.com/ethereum/go-ethereum/p2p"
"github.com/ethereum/go-ethereum/p2p/discover"
"github.com/ethereum/go-ethereum/params"
)
func
main
()
{
log
.
Root
()
.
SetHandler
(
log
.
LvlFilterHandler
(
log
.
LvlInfo
,
log
.
StreamHandler
(
os
.
Stderr
,
log
.
TerminalFormat
(
true
))))
fdlimit
.
Raise
(
2048
)
// Generate a batch of accounts to seal and fund with
faucets
:=
make
([]
*
ecdsa
.
PrivateKey
,
128
)
for
i
:=
0
;
i
<
len
(
faucets
);
i
++
{
faucets
[
i
],
_
=
crypto
.
GenerateKey
()
}
sealers
:=
make
([]
*
ecdsa
.
PrivateKey
,
4
)
for
i
:=
0
;
i
<
len
(
sealers
);
i
++
{
sealers
[
i
],
_
=
crypto
.
GenerateKey
()
}
// Create a Clique network based off of the Rinkeby config
genesis
:=
makeGenesis
(
faucets
,
sealers
)
var
(
nodes
[]
*
node
.
Node
enodes
[]
string
)
for
_
,
sealer
:=
range
sealers
{
// Start the node and wait until it's up
node
,
err
:=
makeSealer
(
genesis
,
enodes
)
if
err
!=
nil
{
panic
(
err
)
}
defer
node
.
Stop
()
for
node
.
Server
()
.
NodeInfo
()
.
Ports
.
Listener
==
0
{
time
.
Sleep
(
250
*
time
.
Millisecond
)
}
// Connect the node to al the previous ones
for
_
,
enode
:=
range
enodes
{
enode
,
err
:=
discover
.
ParseNode
(
enode
)
if
err
!=
nil
{
panic
(
err
)
}
node
.
Server
()
.
AddPeer
(
enode
)
}
// Start tracking the node and it's enode url
nodes
=
append
(
nodes
,
node
)
enode
:=
fmt
.
Sprintf
(
"enode://%s@127.0.0.1:%d"
,
node
.
Server
()
.
NodeInfo
()
.
ID
,
node
.
Server
()
.
NodeInfo
()
.
Ports
.
Listener
)
enodes
=
append
(
enodes
,
enode
)
// Inject the signer key and start sealing with it
store
:=
node
.
AccountManager
()
.
Backends
(
keystore
.
KeyStoreType
)[
0
]
.
(
*
keystore
.
KeyStore
)
signer
,
err
:=
store
.
ImportECDSA
(
sealer
,
""
)
if
err
!=
nil
{
panic
(
err
)
}
if
err
:=
store
.
Unlock
(
signer
,
""
);
err
!=
nil
{
panic
(
err
)
}
}
// Iterate over all the nodes and start signing with them
time
.
Sleep
(
3
*
time
.
Second
)
for
_
,
node
:=
range
nodes
{
var
ethereum
*
eth
.
Ethereum
if
err
:=
node
.
Service
(
&
ethereum
);
err
!=
nil
{
panic
(
err
)
}
if
err
:=
ethereum
.
StartMining
(
1
);
err
!=
nil
{
panic
(
err
)
}
}
time
.
Sleep
(
3
*
time
.
Second
)
// Start injecting transactions from the faucet like crazy
nonces
:=
make
([]
uint64
,
len
(
faucets
))
for
{
index
:=
rand
.
Intn
(
len
(
faucets
))
// Fetch the accessor for the relevant signer
var
ethereum
*
eth
.
Ethereum
if
err
:=
nodes
[
index
%
len
(
nodes
)]
.
Service
(
&
ethereum
);
err
!=
nil
{
panic
(
err
)
}
// Create a self transaction and inject into the pool
tx
,
err
:=
types
.
SignTx
(
types
.
NewTransaction
(
nonces
[
index
],
crypto
.
PubkeyToAddress
(
faucets
[
index
]
.
PublicKey
),
new
(
big
.
Int
),
21000
,
big
.
NewInt
(
100000000000
),
nil
),
types
.
HomesteadSigner
{},
faucets
[
index
])
if
err
!=
nil
{
panic
(
err
)
}
if
err
:=
ethereum
.
TxPool
()
.
AddLocal
(
tx
);
err
!=
nil
{
panic
(
err
)
}
nonces
[
index
]
++
// Wait if we're too saturated
if
pend
,
_
:=
ethereum
.
TxPool
()
.
Stats
();
pend
>
2048
{
time
.
Sleep
(
100
*
time
.
Millisecond
)
}
}
}
// makeGenesis creates a custom Clique genesis block based on some pre-defined
// signer and faucet accounts.
func
makeGenesis
(
faucets
[]
*
ecdsa
.
PrivateKey
,
sealers
[]
*
ecdsa
.
PrivateKey
)
*
core
.
Genesis
{
// Create a Clique network based off of the Rinkeby config
genesis
:=
core
.
DefaultRinkebyGenesisBlock
()
genesis
.
GasLimit
=
25000000
genesis
.
Config
.
ChainID
=
big
.
NewInt
(
18
)
genesis
.
Config
.
Clique
.
Period
=
1
genesis
.
Config
.
EIP150Hash
=
common
.
Hash
{}
genesis
.
Alloc
=
core
.
GenesisAlloc
{}
for
_
,
faucet
:=
range
faucets
{
genesis
.
Alloc
[
crypto
.
PubkeyToAddress
(
faucet
.
PublicKey
)]
=
core
.
GenesisAccount
{
Balance
:
new
(
big
.
Int
)
.
Exp
(
big
.
NewInt
(
2
),
big
.
NewInt
(
128
),
nil
),
}
}
// Sort the signers and embed into the extra-data section
signers
:=
make
([]
common
.
Address
,
len
(
sealers
))
for
i
,
sealer
:=
range
sealers
{
signers
[
i
]
=
crypto
.
PubkeyToAddress
(
sealer
.
PublicKey
)
}
for
i
:=
0
;
i
<
len
(
signers
);
i
++
{
for
j
:=
i
+
1
;
j
<
len
(
signers
);
j
++
{
if
bytes
.
Compare
(
signers
[
i
][
:
],
signers
[
j
][
:
])
>
0
{
signers
[
i
],
signers
[
j
]
=
signers
[
j
],
signers
[
i
]
}
}
}
genesis
.
ExtraData
=
make
([]
byte
,
32
+
len
(
signers
)
*
common
.
AddressLength
+
65
)
for
i
,
signer
:=
range
signers
{
copy
(
genesis
.
ExtraData
[
32
+
i
*
common
.
AddressLength
:
],
signer
[
:
])
}
// Return the genesis block for initialization
return
genesis
}
func
makeSealer
(
genesis
*
core
.
Genesis
,
nodes
[]
string
)
(
*
node
.
Node
,
error
)
{
// Define the basic configurations for the Ethereum node
datadir
,
_
:=
ioutil
.
TempDir
(
""
,
""
)
config
:=
&
node
.
Config
{
Name
:
"geth"
,
Version
:
params
.
Version
,
DataDir
:
datadir
,
P2P
:
p2p
.
Config
{
ListenAddr
:
"0.0.0.0:0"
,
NoDiscovery
:
true
,
MaxPeers
:
25
,
},
NoUSB
:
true
,
}
// Start the node and configure a full Ethereum node on it
stack
,
err
:=
node
.
New
(
config
)
if
err
!=
nil
{
return
nil
,
err
}
if
err
:=
stack
.
Register
(
func
(
ctx
*
node
.
ServiceContext
)
(
node
.
Service
,
error
)
{
return
eth
.
New
(
ctx
,
&
eth
.
Config
{
Genesis
:
genesis
,
NetworkId
:
genesis
.
Config
.
ChainID
.
Uint64
(),
SyncMode
:
downloader
.
FullSync
,
DatabaseCache
:
256
,
DatabaseHandles
:
256
,
TxPool
:
core
.
DefaultTxPoolConfig
,
GPO
:
eth
.
DefaultConfig
.
GPO
,
MinerGasPrice
:
big
.
NewInt
(
1
),
MinerRecommit
:
time
.
Second
,
})
});
err
!=
nil
{
return
nil
,
err
}
// Start the node and return if successful
return
stack
,
stack
.
Start
()
}
miner/stress_ethash.go
0 → 100644
浏览文件 @
1e63a015
// Copyright 2018 The go-ethereum Authors
// This file is part of the go-ethereum library.
//
// The go-ethereum 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 go-ethereum 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 go-ethereum library. If not, see <http://www.gnu.org/licenses/>.
// +build none
// This file contains a miner stress test based on the Ethash consensus engine.
package
main
import
(
"crypto/ecdsa"
"fmt"
"io/ioutil"
"math/big"
"math/rand"
"os"
"path/filepath"
"time"
"github.com/ethereum/go-ethereum/accounts/keystore"
"github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/common/fdlimit"
"github.com/ethereum/go-ethereum/consensus/ethash"
"github.com/ethereum/go-ethereum/core"
"github.com/ethereum/go-ethereum/core/types"
"github.com/ethereum/go-ethereum/crypto"
"github.com/ethereum/go-ethereum/eth"
"github.com/ethereum/go-ethereum/eth/downloader"
"github.com/ethereum/go-ethereum/log"
"github.com/ethereum/go-ethereum/node"
"github.com/ethereum/go-ethereum/p2p"
"github.com/ethereum/go-ethereum/p2p/discover"
"github.com/ethereum/go-ethereum/params"
)
func
main
()
{
log
.
Root
()
.
SetHandler
(
log
.
LvlFilterHandler
(
log
.
LvlInfo
,
log
.
StreamHandler
(
os
.
Stderr
,
log
.
TerminalFormat
(
true
))))
fdlimit
.
Raise
(
2048
)
// Generate a batch of accounts to seal and fund with
faucets
:=
make
([]
*
ecdsa
.
PrivateKey
,
128
)
for
i
:=
0
;
i
<
len
(
faucets
);
i
++
{
faucets
[
i
],
_
=
crypto
.
GenerateKey
()
}
// Pre-generate the ethash mining DAG so we don't race
ethash
.
MakeDataset
(
1
,
filepath
.
Join
(
os
.
Getenv
(
"HOME"
),
".ethash"
))
// Create an Ethash network based off of the Ropsten config
genesis
:=
makeGenesis
(
faucets
)
var
(
nodes
[]
*
node
.
Node
enodes
[]
string
)
for
i
:=
0
;
i
<
4
;
i
++
{
// Start the node and wait until it's up
node
,
err
:=
makeMiner
(
genesis
,
enodes
)
if
err
!=
nil
{
panic
(
err
)
}
defer
node
.
Stop
()
for
node
.
Server
()
.
NodeInfo
()
.
Ports
.
Listener
==
0
{
time
.
Sleep
(
250
*
time
.
Millisecond
)
}
// Connect the node to al the previous ones
for
_
,
enode
:=
range
enodes
{
enode
,
err
:=
discover
.
ParseNode
(
enode
)
if
err
!=
nil
{
panic
(
err
)
}
node
.
Server
()
.
AddPeer
(
enode
)
}
// Start tracking the node and it's enode url
nodes
=
append
(
nodes
,
node
)
enode
:=
fmt
.
Sprintf
(
"enode://%s@127.0.0.1:%d"
,
node
.
Server
()
.
NodeInfo
()
.
ID
,
node
.
Server
()
.
NodeInfo
()
.
Ports
.
Listener
)
enodes
=
append
(
enodes
,
enode
)
// Inject the signer key and start sealing with it
store
:=
node
.
AccountManager
()
.
Backends
(
keystore
.
KeyStoreType
)[
0
]
.
(
*
keystore
.
KeyStore
)
if
_
,
err
:=
store
.
NewAccount
(
""
);
err
!=
nil
{
panic
(
err
)
}
}
// Iterate over all the nodes and start signing with them
time
.
Sleep
(
3
*
time
.
Second
)
for
_
,
node
:=
range
nodes
{
var
ethereum
*
eth
.
Ethereum
if
err
:=
node
.
Service
(
&
ethereum
);
err
!=
nil
{
panic
(
err
)
}
if
err
:=
ethereum
.
StartMining
(
1
);
err
!=
nil
{
panic
(
err
)
}
}
time
.
Sleep
(
3
*
time
.
Second
)
// Start injecting transactions from the faucets like crazy
nonces
:=
make
([]
uint64
,
len
(
faucets
))
for
{
index
:=
rand
.
Intn
(
len
(
faucets
))
// Fetch the accessor for the relevant signer
var
ethereum
*
eth
.
Ethereum
if
err
:=
nodes
[
index
%
len
(
nodes
)]
.
Service
(
&
ethereum
);
err
!=
nil
{
panic
(
err
)
}
// Create a self transaction and inject into the pool
tx
,
err
:=
types
.
SignTx
(
types
.
NewTransaction
(
nonces
[
index
],
crypto
.
PubkeyToAddress
(
faucets
[
index
]
.
PublicKey
),
new
(
big
.
Int
),
21000
,
big
.
NewInt
(
100000000000
+
rand
.
Int63n
(
65536
)),
nil
),
types
.
HomesteadSigner
{},
faucets
[
index
])
if
err
!=
nil
{
panic
(
err
)
}
if
err
:=
ethereum
.
TxPool
()
.
AddLocal
(
tx
);
err
!=
nil
{
panic
(
err
)
}
nonces
[
index
]
++
// Wait if we're too saturated
if
pend
,
_
:=
ethereum
.
TxPool
()
.
Stats
();
pend
>
2048
{
time
.
Sleep
(
100
*
time
.
Millisecond
)
}
}
}
// makeGenesis creates a custom Ethash genesis block based on some pre-defined
// faucet accounts.
func
makeGenesis
(
faucets
[]
*
ecdsa
.
PrivateKey
)
*
core
.
Genesis
{
genesis
:=
core
.
DefaultTestnetGenesisBlock
()
genesis
.
Difficulty
=
params
.
MinimumDifficulty
genesis
.
GasLimit
=
25000000
genesis
.
Config
.
ChainID
=
big
.
NewInt
(
18
)
genesis
.
Config
.
EIP150Hash
=
common
.
Hash
{}
genesis
.
Alloc
=
core
.
GenesisAlloc
{}
for
_
,
faucet
:=
range
faucets
{
genesis
.
Alloc
[
crypto
.
PubkeyToAddress
(
faucet
.
PublicKey
)]
=
core
.
GenesisAccount
{
Balance
:
new
(
big
.
Int
)
.
Exp
(
big
.
NewInt
(
2
),
big
.
NewInt
(
128
),
nil
),
}
}
return
genesis
}
func
makeMiner
(
genesis
*
core
.
Genesis
,
nodes
[]
string
)
(
*
node
.
Node
,
error
)
{
// Define the basic configurations for the Ethereum node
datadir
,
_
:=
ioutil
.
TempDir
(
""
,
""
)
config
:=
&
node
.
Config
{
Name
:
"geth"
,
Version
:
params
.
Version
,
DataDir
:
datadir
,
P2P
:
p2p
.
Config
{
ListenAddr
:
"0.0.0.0:0"
,
NoDiscovery
:
true
,
MaxPeers
:
25
,
},
NoUSB
:
true
,
UseLightweightKDF
:
true
,
}
// Start the node and configure a full Ethereum node on it
stack
,
err
:=
node
.
New
(
config
)
if
err
!=
nil
{
return
nil
,
err
}
if
err
:=
stack
.
Register
(
func
(
ctx
*
node
.
ServiceContext
)
(
node
.
Service
,
error
)
{
return
eth
.
New
(
ctx
,
&
eth
.
Config
{
Genesis
:
genesis
,
NetworkId
:
genesis
.
Config
.
ChainID
.
Uint64
(),
SyncMode
:
downloader
.
FullSync
,
DatabaseCache
:
256
,
DatabaseHandles
:
256
,
TxPool
:
core
.
DefaultTxPoolConfig
,
GPO
:
eth
.
DefaultConfig
.
GPO
,
Ethash
:
eth
.
DefaultConfig
.
Ethash
,
MinerGasPrice
:
big
.
NewInt
(
1
),
MinerRecommit
:
time
.
Second
,
})
});
err
!=
nil
{
return
nil
,
err
}
// Start the node and return if successful
return
stack
,
stack
.
Start
()
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录