Log warning when approaching the submit task limit.

Author: twittner

timeboost-builder/src/submit.rs

@@ -80,16 +80,24 @@ impl Submitter {
     }
 
     pub async fn submit(&mut self, cb: CertifiedBlock<Validated>) {
-        let Ok(permit) = Semaphore::acquire_owned(self.task_permits.clone()).await else {
-            return;
-        };
         let num = cb.cert().data().num();
         debug!(
             node  = %self.public_key(),
             num   = %num,
             tasks = %self.submitters.len(),
             "creating block handler"
         );
+        if self.submitters.len() > MAX_TASKS - 10 {
+            warn!(
+                node  = %self.public_key(),
+                num   = %num,
+                tasks = %self.submitters.len(),
+                "approaching task limit"
+            );
+        }
+        let Ok(permit) = Semaphore::acquire_owned(self.task_permits.clone()).await else {
+            return;
+        };
         self.submitters
             .spawn(self.handler.clone().handle(permit, cb));
         self.metrics.block_submit.set(*num as usize);