Radish alpha
r
rad:zwTxygwuz5LDGBq255RA2CbNGrz8
Radicle CI broker
Radicle
Git
feat: log event queue length at log level "trace"
Merged liw opened 1 year ago

This reduces log spam.

Signed-off-by: Lars Wirzenius liw@liw.fi

2 files changed +8 -2 c8d6c0f5 5b5ba29e
modified src/logger.rs
@@ -5,7 +5,7 @@ use std::sync::Once;
use std::{path::Path, sync::Mutex, time::Duration};

use radicle::{git::raw::Oid, identity::RepoId, node::Event};
-
use slog::{debug, error, info, o, warn, Drain};
+
use slog::{debug, error, info, o, trace, warn, Drain};
use slog_scope::GlobalLoggerGuard;

use crate::{
@@ -160,6 +160,12 @@ pub fn queueproc_channel_disconnect() {
    );
}

+
pub fn queueproc_queue_length(len: usize) {
+
    trace!(
+
        slog_scope::logger(),
+
        "event queue length"; "length" => len);
+
}
+

pub fn queueproc_picked_event(id: &QueueId, event: &QueuedCiEvent) {
    info!(
        slog_scope::logger(),
modified src/queueproc.rs
@@ -100,7 +100,7 @@ impl QueueProcessor {

    fn pick_event(&self) -> Result<Option<QueuedCiEvent>, QueueError> {
        let ids = self.db.queued_ci_events().map_err(QueueError::db)?;
-
        logger::debug2(format!("queue in db has {} events", ids.len()));
+
        logger::queueproc_queue_length(ids.len());

        let mut queue = vec![];
        for id in ids.iter() {