fb03457 feat: always log the start and end result in the queueproc thread — radicle-ci-broker

rad:zwTxygwuz5LDGBq255RA2CbNGrz8

Radicle CI broker

feat: always log the start and end result in the queueproc thread

Lars Wirzenius committed 1 year ago

commit fb03457460e16ac81e4d714ac03d9cacb44c4dd6
parent 923a4f1

2 files changed +8 -4

modified src/logger.rs

@@ -407,10 +407,11 @@ pub fn queueproc_start() {

     );
 }
 pub fn queueproc_end() {
 pub fn queueproc_end(result: &Result<(), QueueError>) {
     debug!(
         msg_id = ?Id::QueueProcEnd,
         kind = %Kind::Debug,
         ?result,
         "thread to process events ends"
     );
 }

modified src/queueproc.rs

@@ -109,11 +109,15 @@ pub struct QueueProcessor {

 impl QueueProcessor {
     pub fn process_in_thread(mut self) -> JoinHandle<Result<(), QueueError>> {
         spawn(move || self.process_until_shutdown())
         spawn(move || {
             logger::queueproc_start();
             let result = self.process_until_shutdown();
             logger::queueproc_end(&result);
             result
         })
     }
     fn process_until_shutdown(&mut self) -> Result<(), QueueError> {
         logger::queueproc_start();
         let mut done = false;
         while !done {
             let mut first_error = None;

@@ -154,7 +158,6 @@ impl QueueProcessor {

             }
         }
         logger::queueproc_end();
         Ok(())
     }