git-mirrors/continuwuity
1
0
Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity.git synced 2025-09-10 21:42:50 +02:00
Code Issues Projects Releases Packages Wiki Activity

reduce log volume (keeps 2 infos)

Browse source 
adjust log volume

demote a bunch of logs
This commit is contained in:
Jacob Taylor 2025-08-25 20:51:55 -07:00
commit a75eacd544
3 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/api/server/send.rs
View file

@ -79,7 +79,7 @@ pub(crate) async fn send_transaction_message_route(
} }
let txn_start_time = Instant::now(); let txn_start_time = Instant::now();
info!( trace!(
pdus = body.pdus.len(), pdus = body.pdus.len(),
edus = body.edus.len(), edus = body.edus.len(),
id = ?body.transaction_id, id = ?body.transaction_id,
@ -102,7 +102,7 @@ pub(crate) async fn send_transaction_message_route(
.filter_map(Result::ok) .filter_map(Result::ok)
.stream(); .stream();
info!( trace!(
pdus = body.pdus.len(), pdus = body.pdus.len(),
edus = body.edus.len(), edus = body.edus.len(),
elapsed = ?txn_start_time.elapsed(), elapsed = ?txn_start_time.elapsed(),
@ -198,7 +198,7 @@ async fn handle_room(
.and_then(|(_, event_id, value)| async move { .and_then(|(_, event_id, value)| async move {
services.server.check_running()?; services.server.check_running()?;
let pdu_start_time = Instant::now(); let pdu_start_time = Instant::now();
info!( trace!(
%room_id, %room_id,
%event_id, %event_id,
pdu = n + 1, pdu = n + 1,

2
src/service/rooms/event_handler/fetch_and_handle_outliers.rs
View file

@ -4,7 +4,7 @@ use std::{
}; };
use conduwuit::{ use conduwuit::{
Event, PduEvent, debug, debug_error, debug_warn, implement, Event, PduEvent, debug, debug_error, implement,
matrix::event::gen_event_id_canonical_json, trace, utils::continue_exponential_backoff_secs, matrix::event::gen_event_id_canonical_json, trace, utils::continue_exponential_backoff_secs,
warn, warn,
}; };

4
src/service/sending/sender.rs
View file

@ -882,7 +882,7 @@ impl Service {
.execute_on(&self.services.client.sender, &server, request) .execute_on(&self.services.client.sender, &server, request)
.await .await
.inspect(|_| { .inspect(|_| {
info!(%txn_id, %server, "Sent {} PDUs, {} EDUs", pdu_count, edu_count); trace!(%txn_id, %server, "Sent {} PDUs, {} EDUs", pdu_count, edu_count);
}) })
.inspect_err(|e| { .inspect_err(|e| {
info!(%txn_id, %server, "Failed to send transaction ({} PDUs, {} EDUs): {e:?}", pdu_count, edu_count); info!(%txn_id, %server, "Failed to send transaction ({} PDUs, {} EDUs): {e:?}", pdu_count, edu_count);
@ -890,7 +890,7 @@ impl Service {
for (event_id, result) in result.iter().flat_map(|resp| resp.pdus.iter()) { for (event_id, result) in result.iter().flat_map(|resp| resp.pdus.iter()) {
if let Err(e) = result { if let Err(e) = result {
warn!( trace!(
%txn_id, %server, %txn_id, %server,
"error sending PDU {event_id} to remote server: {e:?}" "error sending PDU {event_id} to remote server: {e:?}"
); );