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

sectorbuilder: Call AcquireSectorId in sync

Browse Source
This commit is contained in:
Łukasz Magiera 2019-11-14 22:18:22 +01:00
parent b88807b947
commit d5c620dc44
1 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
lib/sectorbuilder/sectorbuilder_test.go
View File

@ -33,12 +33,6 @@ func (s *seal) precommit(t *testing.T, sb *sectorbuilder.SectorBuilder, sid uint
dlen := sectorbuilder.UserBytesForSectorSize(sectorSize) dlen := sectorbuilder.UserBytesForSectorSize(sectorSize)
var err error var err error
s.sid, err = sb.AcquireSectorId()
if err != nil {
t.Fatalf("%+v", err)
}
assert.Equal(t, sid, s.sid)
r := io.LimitReader(rand.New(rand.NewSource(42 + int64(sid))), int64(dlen)) r := io.LimitReader(rand.New(rand.NewSource(42 + int64(sid))), int64(dlen))
s.ppi, err = sb.AddPiece(dlen, sid, r, []uint64{}) s.ppi, err = sb.AddPiece(dlen, sid, r, []uint64{})
if err != nil { if err != nil {
@ -133,7 +127,12 @@ func TestSealAndVerify(t *testing.T) {
} }
defer cleanup() defer cleanup()
s := seal{} si, err := sb.AcquireSectorId()
if err != nil {
t.Fatalf("%+v", err)
}
s := seal{sid: si}
s.precommit(t, sb, 1, func() {}) s.precommit(t, sb, 1, func() {})
@ -184,8 +183,17 @@ func TestSealAndVerify2(t *testing.T) {
var wg sync.WaitGroup var wg sync.WaitGroup
s1 := seal{} si1, err := sb.AcquireSectorId()
s2 := seal{} if err != nil {
t.Fatalf("%+v", err)
}
si2, err := sb.AcquireSectorId()
if err != nil {
t.Fatalf("%+v", err)
}
s1 := seal{sid: si1}
s2 := seal{sid: si2}
wg.Add(2) wg.Add(2)
go s1.precommit(t, sb, 1, wg.Done) go s1.precommit(t, sb, 1, wg.Done)