Chia-Network/chia-blockchain
1
0
Fork 0
mirror of https://github.com/Chia-Network/chia-blockchain.git synced 2024-09-19 06:39:51 +03:00
Code Issues Packages Projects Releases Wiki Activity

Don't farm compressed plots if context count is 0 (#16004)

Browse Source 
* Don't farm compressed plots if context count is 0

* Move checks outside cache.
This commit is contained in:
Florin Chirica 2023-08-11 21:40:49 +03:00 committed by GitHub
parent 67a0e91d8d
commit cbf971e7f5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
chia/plotting/manager.py
View File

@ -46,6 +46,7 @@ class PlotManager:
_refresh_callback: Callable
_initial: bool
max_compression_level_allowed: int
context_count: int
def __init__(
self,
@ -79,6 +80,7 @@ class PlotManager:
self._refresh_callback = refresh_callback
self._initial = True
self.max_compression_level_allowed = 0
self.context_count = 0
def __enter__(self):
self._lock.acquire()
@ -118,6 +120,7 @@ class PlotManager:
f"Falling back to CPU harvesting: {context_count} decompressors count, {thread_count} threads."
)
self.max_compression_level_allowed = max_compression_level_allowed
self.context_count = context_count
return HarvestingMode.GPU if is_using_gpu else HarvestingMode.CPU
def reset(self) -> None:
@ -337,17 +340,28 @@ class PlotManager:
"We assume the file is being copied."
)
return None
elif level > self.max_compression_level_allowed:
log.warning(
f"Not farming plot {file_path}. Plot compression level: {level}, "
f"max compression level allowed: {self.max_compression_level_allowed}."
)
return None
cache_entry = CacheEntry.from_disk_prover(prover)
self.cache.update(file_path, cache_entry)
assert cache_entry is not None
level = cache_entry.prover.get_compression_level()
if level > self.max_compression_level_allowed:
log.warning(
f"Not farming plot {file_path}. Plot compression level: {level}, "
f"max compression level allowed: {self.max_compression_level_allowed}."
)
return None
if level > 0 and self.context_count == 0:
log.warning(
f"Not farming compressed plot {file_path}. Plot compression level: {level}, "
f"because parallel_decompressor_count is set to 0 in config.yaml. Use a non-zero value"
" to start harvesting compressed plots."
)
return None
# Only use plots that correct keys associated with them
if cache_entry.farmer_public_key not in self.farmer_public_keys:
log.warning(f"Plot {file_path} has a farmer public key that is not in the farmer's pk list.")