f Sleep and retry pushing to queue if it is full

Author: tnull

src/tx_broadcaster.rs

@@ -59,9 +59,37 @@ where
 	L::Target: Logger,
 {
 	fn broadcast_transactions(&self, txs: &[&Transaction]) {
-		let package = txs.iter().map(|&t| t.clone()).collect::<Vec<Transaction>>();
-		self.queue_sender.try_send(package).unwrap_or_else(|e| {
-			log_error!(self.logger, "Failed to broadcast transactions: {}", e);
-		});
+		let mut package = txs.iter().map(|&t| t.clone()).collect::<Vec<Transaction>>();
+		let mut retries_left = 10;
+
+		loop {
+			match self.queue_sender.try_send(package) {
+				Ok(()) => {
+					break;
+				}
+				Err(mpsc::error::TrySendError::Full(pkg)) => {
+					if retries_left > 0 {
+						log_debug!(
+							self.logger,
+							"Failed to broadcast transactions due to full queue. Retrying."
+						);
+						std::thread::sleep(Duration::from_millis(100));
+						package = pkg;
+						retries_left -= 1;
+						continue;
+					} else {
+						log_error!(
+							self.logger,
+							"Failed to broadcast transactions due to full queue. Aborting."
+						);
+						break;
+					}
+				}
+				Err(e) => {
+					log_error!(self.logger, "Failed to broadcast transactions: {}", e);
+					break;
+				}
+			}
+		}
 	}
 }