Struct GpuPlotter 

pub struct GpuPlotter<PG> { /* private fields */ }

GPU plotter

Implementations

impl<PG> GpuPlotter<PG>

where PG: PieceGetter + Clone + Send + Sync + 'static,

pub fn new( piece_getter: PG, downloading_semaphore: Arc<Semaphore>, gpu_records_encoders: Vec<GpuRecordsEncoder>, global_mutex: Arc<AsyncMutex<()>>, erasure_coding: ErasureCoding, registry: Option<&mut Registry>, ) -> Result<Self, TryFromIntError>

Create a new instance.

Returns an error if empty list of encoders is provided.

pub fn on_plotting_progress( &self, callback: HandlerFn3<Ed25519PublicKey, SectorIndex, SectorPlottingProgress>, ) -> HandlerId

Subscribe to plotting progress notifications

Trait Implementations

impl<PG> Debug for GpuPlotter<PG>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<PG> Drop for GpuPlotter<PG>

fn drop(&mut self)

Executes the destructor for this type.

impl<PG> Plotter for GpuPlotter<PG>

where PG: PieceGetter + Clone + Send + Sync + 'static,

fn has_free_capacity<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Whether plotter has free capacity to encode more sectors

fn plot_sector<'life0, 'async_trait>( &'life0 self, public_key: Ed25519PublicKey, sector_index: SectorIndex, farmer_protocol_info: FarmerProtocolInfo, pieces_in_sector: u16, _replotting: bool, progress_sender: Sender<SectorPlottingProgress>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Plot one sector, sending sector plotting events via the provided stream.

fn try_plot_sector<'life0, 'async_trait>( &'life0 self, public_key: Ed25519PublicKey, sector_index: SectorIndex, farmer_protocol_info: FarmerProtocolInfo, pieces_in_sector: u16, _replotting: bool, progress_sender: Sender<SectorPlottingProgress>, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Try to plot one sector, sending sector plotting events via the provided stream.