800b2ff feat: log when events end and when pushing a shutdown event — radicle-ci-broker

Radicle CI broker

feat: log when events end and when pushing a shutdown event

Lars Wirzenius committed 1 year ago

commit 800b2ffb44597c7acd53d74c13ec6bffcb869569
parent 866d6a879f880e8c3ec17c5b76300923c0d190d7

1 file changed +2 -0

modified src/queueadd.rs

@@ -70,6 +70,7 @@ impl QueueAdder {

             debug!("waiting for event from node");
             let events = source.event()?;
             if events.is_empty() {
                 info!("no more events from node control sockets");
                 break 'event_loop;
             } else {
                 for e in events {

@@ -83,6 +84,7 @@ impl QueueAdder {

         // Add a shutdown event to the queue so that the queue
         // processing thread knows to stop.
         if self.push_shutdown {
             info!("push a shutdown event into queue");
             self.db.push_queued_event(BrokerEvent::Shutdown)?;
         }