Make sure plotting and piece announcement specifically doesn't block farming

Author: nazar-pc

crates/subspace-farmer/src/single_disk_plot.rs

@@ -46,7 +46,7 @@ use subspace_rpc_primitives::{SlotInfo, SolutionResponse};
 use thiserror::Error;
 use tokio::runtime::Handle;
 use tokio::sync::broadcast;
-use tracing::{debug, error, info, info_span, trace, Instrument, Span};
+use tracing::{debug, error, info, info_span, trace, warn, Instrument, Span};
 use ulid::Ulid;
 
 // Refuse to compile on non-64-bit platforms, offsets may fail on those when converting from u64 to
@@ -715,23 +715,29 @@ impl SingleDiskPlot {
                                 Err(error) => Err(PlottingError::LowLevel(error))?,
                             };
 
-                            let mut metadata_header = metadata_header.lock();
-                            metadata_header.sector_count += 1;
-                            metadata_header_mmap
-                                .copy_from_slice(metadata_header.encode().as_slice());
+                            {
+                                let mut metadata_header = metadata_header.lock();
+                                metadata_header.sector_count += 1;
+                                metadata_header_mmap
+                                    .copy_from_slice(metadata_header.encode().as_slice());
+                            }
 
                             handlers.sector_plotted.call_simple(&plotted_sector);
 
                             // TODO: Migrate this over to using `on_sector_plotted` instead
                             // Publish pieces-by-sector if we use DSN
-                            let publishing_result = handle.block_on(
-                                piece_publisher.publish_pieces(plotted_sector.piece_indexes),
-                            );
-
-                            // cancelled
-                            if publishing_result.is_err() {
-                                return;
-                            }
+                            tokio::spawn({
+                                let piece_publisher = piece_publisher.clone();
+
+                                async move {
+                                    if let Err(error) = piece_publisher
+                                        .publish_pieces(plotted_sector.piece_indexes)
+                                        .await
+                                    {
+                                        warn!(%sector_index, %error, "Failed to publish pieces to DSN");
+                                    }
+                                }
+                            });
                         }
                     };
 

crates/subspace-farmer/src/single_disk_plot/piece_publisher.rs

@@ -14,6 +14,7 @@ use tracing::{debug, error, trace};
 const PUBLISH_PIECE_BY_SECTOR_WAITING_DURATION_IN_SECS: u64 = 1;
 
 // Piece-by-sector DSN publishing helper.
+#[derive(Clone)]
 pub(crate) struct PieceSectorPublisher {
     dsn_node: Node,
     cancelled: Arc<AtomicBool>,