cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

Work on competitve test a bit

Browse Source 
Signed-off-by: Jakub Sztandera <kubuxu@protocol.ai>
This commit is contained in:
Jakub Sztandera 2020-08-11 14:59:27 +02:00
parent 0091f3a9ce
commit 4da3aedacb
No known key found for this signature in database
GPG Key ID: 9A9AF56F8B3879BA
1 changed files with 30 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
chain/messagepool/selection_test.go
View File

@ -2,6 +2,7 @@ package messagepool
import ( import (
"context" "context"
"math"
"math/big" "math/big"
"math/rand" "math/rand"
"testing" "testing"
@ -859,7 +860,7 @@ func TestOptimalMessageSelection3(t *testing.T) {
} }
} }
func testCompetitiveMessageSelection(t *testing.T) { func testCompetitiveMessageSelection(t *testing.T, rng *rand.Rand) {
// in this test we use 100 actors and send 10 blocks of messages. // in this test we use 100 actors and send 10 blocks of messages.
// actors send with an exponentially decreasing premium. // actors send with an exponentially decreasing premium.
// a number of miners select with varying ticket quality and we compare the // a number of miners select with varying ticket quality and we compare the
@ -867,7 +868,7 @@ func testCompetitiveMessageSelection(t *testing.T) {
mp, tma := makeTestMpool() mp, tma := makeTestMpool()
nActors := 100 nActors := 300
// the actors // the actors
var actors []address.Address var actors []address.Address
var wallets []*wallet.Wallet var wallets []*wallet.Wallet
@ -899,11 +900,12 @@ func testCompetitiveMessageSelection(t *testing.T) {
} }
nMessages := 10 * int(build.BlockGasLimit/gasLimit) nMessages := 10 * int(build.BlockGasLimit/gasLimit)
t.Log("nMessages", nMessages)
nonces := make([]uint64, nActors) nonces := make([]uint64, nActors)
for i := 0; i < nMessages; i++ { for i := 0; i < nMessages; i++ {
from := rand.Intn(nActors) from := rng.Intn(nActors)
to := rand.Intn(nActors) to := rng.Intn(nActors)
premium := 1 + rand.Intn(1000) premium := 20000*math.Exp(-3.*rand.Float64()) + 5000
nonce := nonces[from] nonce := nonces[from]
nonces[from]++ nonces[from]++
m := makeTestMessage(wallets[from], actors[from], actors[to], uint64(nonce), gasLimit, uint64(premium)) m := makeTestMessage(wallets[from], actors[from], actors[to], uint64(nonce), gasLimit, uint64(premium))
@ -917,10 +919,20 @@ func testCompetitiveMessageSelection(t *testing.T) {
} }
// 2. optimal selection // 2. optimal selection
nMiners := 10 minersRand := rng.Float64()
winerProba := noWinnersProb()
i := 0
for ; i < MaxBlocks && minersRand > 0; i++ {
minersRand -= winerProba[i]
}
nMiners := i
if nMiners == 0 {
nMiners = 1
}
optMsgs := make(map[cid.Cid]*types.SignedMessage) optMsgs := make(map[cid.Cid]*types.SignedMessage)
for i := 0; i < nMiners; i++ { for i := 0; i < nMiners; i++ {
tq := rand.Float64() tq := rng.Float64()
msgs, err := mp.SelectMessages(ts, tq) msgs, err := mp.SelectMessages(ts, tq)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
@ -930,8 +942,9 @@ func testCompetitiveMessageSelection(t *testing.T) {
} }
} }
t.Log("greedy capacity", len(greedyMsgs)) t.Logf("nMiners: %d", nMiners)
t.Log("optimal capacity", len(optMsgs)) t.Logf("greedy capacity %d, optimal capacity %d (x%.1f)", len(greedyMsgs),
len(optMsgs), float64(len(optMsgs))/float64(len(greedyMsgs)))
if len(greedyMsgs) > len(optMsgs) { if len(greedyMsgs) > len(optMsgs) {
t.Fatal("greedy capacity higher than optimal capacity; wtf") t.Fatal("greedy capacity higher than optimal capacity; wtf")
} }
@ -946,10 +959,14 @@ func testCompetitiveMessageSelection(t *testing.T) {
optReward.Add(optReward, mp.getGasReward(m, baseFee, ts)) optReward.Add(optReward, mp.getGasReward(m, baseFee, ts))
} }
t.Log("greedy reward", greedyReward) nMinersBig := big.NewInt(int64(nMiners))
t.Log("optimal reward", optReward) greedyAvgReward, _ := new(big.Rat).SetFrac(greedyReward, nMinersBig).Float64()
optimalAvgReward, _ := new(big.Rat).SetFrac(optReward, nMinersBig).Float64()
t.Logf("greedy reward: %f, optimal reward: %f (x%.1f)", greedyAvgReward,
optimalAvgReward, optimalAvgReward/greedyAvgReward)
if greedyReward.Cmp(optReward) > 0 { if greedyReward.Cmp(optReward) > 0 {
t.Fatal("greedy reward higher than optimal reward; booh") t.Fatal("greedy reward raw higher than optimal reward; booh")
} }
} }
@ -957,7 +974,6 @@ func TestCompetitiveMessageSelection(t *testing.T) {
seeds := []int64{1947, 1976, 2020, 2100, 10000} seeds := []int64{1947, 1976, 2020, 2100, 10000}
for _, seed := range seeds { for _, seed := range seeds {
t.Log("running competitve message selection with seed", seed) t.Log("running competitve message selection with seed", seed)
rand.Seed(seed) testCompetitiveMessageSelection(t, rand.New(rand.NewSource(seed)))
testCompetitiveMessageSelection(t)
} }
} }