TimedMutex - don't return after exceeded timeout

golemfactory · Sep 10, 2024 · bc4e7e5 · bc4e7e5
1 parent 09d3a02
commit bc4e7e5
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/core/payment/src/timeout_lock.rs b/core/payment/src/timeout_lock.rs
@@ -106,11 +106,6 @@ impl TimedMutex {
                     match tokio::time::timeout(Duration::from_secs(10), receiver.recv()).await {
                         Err(_) => {
                             log::warn!("[TimedMutex] Long running task: {task_name}!");
-                            counter += 1;
-                            // five minutes
-                            if counter > 30 {
-                                return;
-                            }
                         }
                         Ok(None) => log::warn!("[TimedMutex] Unexpected mpsc close."),
                         Ok(Some(TimedMutexTaskMessage::Finish)) => break,