logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-05-17 00:39:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove the returnedCollateral when the slot is not filled by the host

Browse Source
This commit is contained in:
Arnaud 2025-05-07 15:54:24 +02:00
parent 05e0192563
commit 2ae617d662
No known key found for this signature in database
GPG Key ID: B8FBC178F10CA7AE
1 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
codex/sales/states/cancelled.nim
View File

@ -31,24 +31,22 @@ method run*(
raiseAssert "no sale request" raiseAssert "no sale request"
try: try:
debug "Collecting collateral and partial payout", var returnedCollateral = UInt256.none
requestId = data.requestId, slotIndex = data.slotIndex
# The returnedCollateral is needed even if the slot is not filled by the host
# because a reservation could be created and the collateral assigned
# to that reservation. So if the slot is not filled by that host,
# the reservation will be deleted during cleanup and the collateral
# must be returned to the host.
let slot = Slot(request: request, slotIndex: data.slotIndex)
let currentCollateral = await market.currentCollateral(slot.id)
let returnedCollateral = currentCollateral.some
if await slotIsFilledByMe(market, data.requestId, data.slotIndex): if await slotIsFilledByMe(market, data.requestId, data.slotIndex):
debug "Collecting collateral and partial payout",
requestId = data.requestId, slotIndex = data.slotIndex
let slot = Slot(request: request, slotIndex: data.slotIndex)
let currentCollateral = await market.currentCollateral(slot.id)
try: try:
await market.freeSlot(slot.id) await market.freeSlot(slot.id)
except SlotStateMismatchError as e: except SlotStateMismatchError as e:
warn "Failed to free slot because slot is already free", error = e.msg warn "Failed to free slot because slot is already free", error = e.msg
returnedCollateral = currentCollateral.some
if onClear =? agent.context.onClear and request =? data.request: if onClear =? agent.context.onClear and request =? data.request:
onClear(request, data.slotIndex) onClear(request, data.slotIndex)