status-im
/
nim-codex
mirror of https://github.com/status-im/nim-codex.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

limit amount of slot queue workers to 1 

reason: proof generation does not happen in
separate threads yet, so to avoid taking too
long to provide initial storage proofs we only
pick up one slot at a time
This commit is contained in:
Mark Spanbroek 2024-11-07 11:32:57 +01:00
parent 69122d8aee
commit 20078676c1
No known key found for this signature in database
GPG Key ID: FBE3E9548D427C00
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
codex/sales/slotqueue.nim
View File

@ -58,7 +58,7 @@ type
QueueNotRunningError* = object of SlotQueueError QueueNotRunningError* = object of SlotQueueError
# Number of concurrent workers used for processing SlotQueueItems # Number of concurrent workers used for processing SlotQueueItems
const DefaultMaxWorkers = 3 const DefaultMaxWorkers = 1
# Cap slot queue size to prevent unbounded growth and make sifting more # Cap slot queue size to prevent unbounded growth and make sifting more
# efficient. Max size is not equivalent to the number of slots a host can # efficient. Max size is not equivalent to the number of slots a host can

2
tests/codex/sales/testsales.nim
View File

@ -311,7 +311,7 @@ asyncchecksuite "Sales":
createAvailability() # enough to fill a single slot createAvailability() # enough to fill a single slot
await market.requestStorage(request) await market.requestStorage(request)
let items = SlotQueueItem.init(request) let items = SlotQueueItem.init(request)
await sleepAsync(10.millis) # queue starts paused, allow items to be added to the queue await allowRequestToStart()
check eventually queue.paused check eventually queue.paused
# The first processed item/slot will be filled (eventually). Subsequent # The first processed item/slot will be filled (eventually). Subsequent
# items will be processed and eventually re-pushed with `seen = true`. Once # items will be processed and eventually re-pushed with `seen = true`. Once