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

sealing: round parts in fastPledgeCommitment

Browse Source
This commit is contained in:
Łukasz Magiera 2020-01-29 20:12:08 +01:00
parent f6b12a33a2
commit 367062aee4
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
garbage.go
View File

@ -5,6 +5,7 @@ import (
"context" "context"
"io" "io"
"math" "math"
"math/bits"
"math/rand" "math/rand"
"runtime" "runtime"
"sync" "sync"
@ -18,7 +19,9 @@ import (
) )
func (m *Sealing) fastPledgeCommitment(size uint64, parts uint64) (commP [sectorbuilder.CommLen]byte, err error) { func (m *Sealing) fastPledgeCommitment(size uint64, parts uint64) (commP [sectorbuilder.CommLen]byte, err error) {
piece := sectorbuilder.UserBytesForSectorSize((size / 127 + size) / parts) parts = 1 << bits.Len64(parts) // round down to nearest power of 2
piece := sectorbuilder.UserBytesForSectorSize((size/127 + size) / parts)
out := make([]sectorbuilder.PublicPieceInfo, parts) out := make([]sectorbuilder.PublicPieceInfo, parts)
var lk sync.Mutex var lk sync.Mutex
@ -28,7 +31,7 @@ func (m *Sealing) fastPledgeCommitment(size uint64, parts uint64) (commP [sector
go func(i uint64) { go func(i uint64) {
defer wg.Done() defer wg.Done()
commP, perr := sectorbuilder.GeneratePieceCommitment(io.LimitReader(rand.New(rand.NewSource(42 + int64(i))), int64(piece)), piece) commP, perr := sectorbuilder.GeneratePieceCommitment(io.LimitReader(rand.New(rand.NewSource(42+int64(i))), int64(piece)), piece)
lk.Lock() lk.Lock()
if perr != nil { if perr != nil {
@ -51,11 +54,11 @@ func (m *Sealing) fastPledgeCommitment(size uint64, parts uint64) (commP [sector
} }
func (m *Sealing) pledgeReader(size uint64, parts uint64) io.Reader { func (m *Sealing) pledgeReader(size uint64, parts uint64) io.Reader {
piece := sectorbuilder.UserBytesForSectorSize((size / 127 + size) / parts) piece := sectorbuilder.UserBytesForSectorSize((size/127 + size) / parts)
readers := make([]io.Reader, parts) readers := make([]io.Reader, parts)
for i := range readers { for i := range readers {
readers[i] = io.LimitReader(rand.New(rand.NewSource(42 + int64(i))), int64(piece)) readers[i] = io.LimitReader(rand.New(rand.NewSource(42+int64(i))), int64(piece))
} }
return io.MultiReader(readers...) return io.MultiReader(readers...)