Fix verifiable manifest initialization (#839)
* fix verifiable manifest initialization * fix linearstrategy, use verifiableStrategy to select blocks for slots * check for both strategies in attribute inheritance test
This commit is contained in:
parent
4619260dc1
commit
8138ef5afd
|
@ -49,8 +49,8 @@ func getLinearIndicies(
|
||||||
self.checkIteration(iteration)
|
self.checkIteration(iteration)
|
||||||
|
|
||||||
let
|
let
|
||||||
first = self.firstIndex + iteration * (self.step + 1)
|
first = self.firstIndex + iteration * self.step
|
||||||
last = min(first + self.step, self.lastIndex)
|
last = min(first + self.step - 1, self.lastIndex)
|
||||||
|
|
||||||
getIter(first, last, 1)
|
getIter(first, last, 1)
|
||||||
|
|
||||||
|
@ -94,4 +94,4 @@ func init*(
|
||||||
firstIndex: firstIndex,
|
firstIndex: firstIndex,
|
||||||
lastIndex: lastIndex,
|
lastIndex: lastIndex,
|
||||||
iterations: iterations,
|
iterations: iterations,
|
||||||
step: divUp((lastIndex - firstIndex), iterations))
|
step: divUp((lastIndex - firstIndex + 1), iterations))
|
||||||
|
|
|
@ -231,7 +231,7 @@ func new*(
|
||||||
treeCid: Cid,
|
treeCid: Cid,
|
||||||
datasetSize: NBytes,
|
datasetSize: NBytes,
|
||||||
ecK, ecM: int,
|
ecK, ecM: int,
|
||||||
strategy: StrategyType): Manifest =
|
strategy = SteppedStrategy): Manifest =
|
||||||
## Create an erasure protected dataset from an
|
## Create an erasure protected dataset from an
|
||||||
## unprotected one
|
## unprotected one
|
||||||
##
|
##
|
||||||
|
@ -277,7 +277,7 @@ func new*(
|
||||||
ecM: int,
|
ecM: int,
|
||||||
originalTreeCid: Cid,
|
originalTreeCid: Cid,
|
||||||
originalDatasetSize: NBytes,
|
originalDatasetSize: NBytes,
|
||||||
strategy: StrategyType): Manifest =
|
strategy = SteppedStrategy): Manifest =
|
||||||
|
|
||||||
Manifest(
|
Manifest(
|
||||||
treeCid: treeCid,
|
treeCid: treeCid,
|
||||||
|
@ -299,7 +299,7 @@ func new*(
|
||||||
verifyRoot: Cid,
|
verifyRoot: Cid,
|
||||||
slotRoots: openArray[Cid],
|
slotRoots: openArray[Cid],
|
||||||
cellSize = DefaultCellSize,
|
cellSize = DefaultCellSize,
|
||||||
strategy = SteppedStrategy): ?!Manifest =
|
strategy = LinearStrategy): ?!Manifest =
|
||||||
## Create a verifiable dataset from an
|
## Create a verifiable dataset from an
|
||||||
## protected one
|
## protected one
|
||||||
##
|
##
|
||||||
|
@ -324,6 +324,7 @@ func new*(
|
||||||
ecM: manifest.ecM,
|
ecM: manifest.ecM,
|
||||||
originalTreeCid: manifest.treeCid,
|
originalTreeCid: manifest.treeCid,
|
||||||
originalDatasetSize: manifest.originalDatasetSize,
|
originalDatasetSize: manifest.originalDatasetSize,
|
||||||
|
protectedStrategy: manifest.protectedStrategy,
|
||||||
verifiable: true,
|
verifiable: true,
|
||||||
verifyRoot: verifyRoot,
|
verifyRoot: verifyRoot,
|
||||||
slotRoots: @slotRoots,
|
slotRoots: @slotRoots,
|
||||||
|
|
|
@ -534,7 +534,9 @@ proc onStore(
|
||||||
trace "Unable to fetch manifest for cid", cid, err = err.msg
|
trace "Unable to fetch manifest for cid", cid, err = err.msg
|
||||||
return failure(err)
|
return failure(err)
|
||||||
|
|
||||||
without builder =? Poseidon2Builder.new(self.networkStore, manifest), err:
|
without builder =? Poseidon2Builder.new(
|
||||||
|
self.networkStore, manifest, manifest.verifiableStrategy
|
||||||
|
), err:
|
||||||
trace "Unable to create slots builder", err = err.msg
|
trace "Unable to create slots builder", err = err.msg
|
||||||
return failure(err)
|
return failure(err)
|
||||||
|
|
||||||
|
@ -559,8 +561,8 @@ proc onStore(
|
||||||
|
|
||||||
return success()
|
return success()
|
||||||
|
|
||||||
without indexer =? manifest.protectedStrategy.init(
|
without indexer =? manifest.verifiableStrategy.init(
|
||||||
0, manifest.numSlotBlocks() - 1, manifest.numSlots).catch, err:
|
0, manifest.blocksCount - 1, manifest.numSlots).catch, err:
|
||||||
trace "Unable to create indexing strategy from protected manifest", err = err.msg
|
trace "Unable to create indexing strategy from protected manifest", err = err.msg
|
||||||
return failure(err)
|
return failure(err)
|
||||||
|
|
||||||
|
|
|
@ -134,7 +134,7 @@ asyncchecksuite "Test Node - Host contracts":
|
||||||
return success()
|
return success()
|
||||||
|
|
||||||
(await onStore(request, 1.u256, onBlocks)).tryGet()
|
(await onStore(request, 1.u256, onBlocks)).tryGet()
|
||||||
check fetchedBytes == 262144
|
check fetchedBytes == 12 * DefaultBlockSize.uint
|
||||||
|
|
||||||
let indexer = verifiable.protectedStrategy.init(
|
let indexer = verifiable.protectedStrategy.init(
|
||||||
0, verifiable.numSlotBlocks() - 1, verifiable.numSlots)
|
0, verifiable.numSlotBlocks() - 1, verifiable.numSlots)
|
||||||
|
|
|
@ -58,6 +58,14 @@ suite "Indexing strategies":
|
||||||
expect IndexingWrongIterationsError:
|
expect IndexingWrongIterationsError:
|
||||||
discard LinearStrategy.init(0, 10, 0)
|
discard LinearStrategy.init(0, 10, 0)
|
||||||
|
|
||||||
|
test "should split elements evenly when possible":
|
||||||
|
let
|
||||||
|
l = LinearStrategy.init(0, 11, 3)
|
||||||
|
check:
|
||||||
|
toSeq(l.getIndicies(0)) == @[0, 1, 2, 3].mapIt(it)
|
||||||
|
toSeq(l.getIndicies(1)) == @[4, 5, 6, 7].mapIt(it)
|
||||||
|
toSeq(l.getIndicies(2)) == @[8, 9, 10, 11].mapIt(it)
|
||||||
|
|
||||||
test "linear - oob":
|
test "linear - oob":
|
||||||
expect IndexingError:
|
expect IndexingError:
|
||||||
discard linear.getIndicies(3)
|
discard linear.getIndicies(3)
|
||||||
|
|
|
@ -74,3 +74,36 @@ checksuite "Manifest":
|
||||||
test "Should encode/decode to/from verifiable manifest":
|
test "Should encode/decode to/from verifiable manifest":
|
||||||
check:
|
check:
|
||||||
encodeDecode(verifiableManifest) == verifiableManifest
|
encodeDecode(verifiableManifest) == verifiableManifest
|
||||||
|
|
||||||
|
|
||||||
|
suite "Manifest - Attribute Inheritance":
|
||||||
|
proc makeProtectedManifest(strategy: StrategyType): Manifest =
|
||||||
|
Manifest.new(
|
||||||
|
manifest = Manifest.new(
|
||||||
|
treeCid = Cid.example,
|
||||||
|
blockSize = 1.MiBs,
|
||||||
|
datasetSize = 100.MiBs,
|
||||||
|
),
|
||||||
|
treeCid = Cid.example,
|
||||||
|
datasetSize = 200.MiBs,
|
||||||
|
ecK = 1,
|
||||||
|
ecM = 1,
|
||||||
|
strategy = strategy
|
||||||
|
)
|
||||||
|
|
||||||
|
test "Should preserve interleaving strategy for protected manifest in verifiable manifest":
|
||||||
|
var verifiable = Manifest.new(
|
||||||
|
manifest = makeProtectedManifest(SteppedStrategy),
|
||||||
|
verifyRoot = Cid.example,
|
||||||
|
slotRoots = @[Cid.example, Cid.example]
|
||||||
|
).tryGet()
|
||||||
|
|
||||||
|
check verifiable.protectedStrategy == SteppedStrategy
|
||||||
|
|
||||||
|
verifiable = Manifest.new(
|
||||||
|
manifest = makeProtectedManifest(LinearStrategy),
|
||||||
|
verifyRoot = Cid.example,
|
||||||
|
slotRoots = @[Cid.example, Cid.example]
|
||||||
|
).tryGet()
|
||||||
|
|
||||||
|
check verifiable.protectedStrategy == LinearStrategy
|
||||||
|
|
Loading…
Reference in New Issue