From 8c4632a44a01f61cc4e21a32536e8596b3cc4461 Mon Sep 17 00:00:00 2001
From: Kubat <mael.martin31@gmail.com>
Date: Wed, 15 Dec 2021 14:41:29 +0100
Subject: [PATCH] Add some timing infos
---
src/matrix.rs | 23 +++++++++++++----------
1 file changed, 13 insertions(+), 10 deletions(-)
diff --git a/src/matrix.rs b/src/matrix.rs
index 814e36e..10ea74d 100644
--- a/src/matrix.rs
+++ b/src/matrix.rs
@@ -16,7 +16,7 @@ use matrix_sdk::{
},
Client, Result, SyncSettings,
};
-use std::{convert::TryFrom, lazy::SyncLazy, process::abort, sync::Arc, sync::Mutex};
+use std::{convert::TryFrom, lazy::SyncLazy, process::abort, sync::Arc, sync::Mutex, time};
use tokio::time::{sleep, Duration};
async fn join_room(room: &Invited) {
@@ -101,6 +101,7 @@ pub async fn connect_and_handle(config: Config) -> Result<()> {
let on_msg_room_event = |ev: SyncMessageEvent<MessageEventContent>,
room: Room,
_encryption_info: Option<EncryptionInfo>| async {
+ let now = time::Instant::now();
let sender_id = ev.sender;
if sender_id.as_str() == room.own_user_id().as_str() {
return ();
@@ -126,15 +127,17 @@ pub async fn connect_and_handle(config: Config) -> Result<()> {
res = pkg.handle(&joined, &sender_id, args);
}
- joined
- .send(
- AnyMessageEventContent::RoomMessage(
- MessageEventContent::text_html(res.clone(), res),
- ),
- None,
- )
- .await
- .unwrap();
+ let msg = AnyMessageEventContent::RoomMessage(
+ MessageEventContent::text_html(res.clone(), res),
+ );
+ let elapsed_before_send = now.elapsed();
+ joined.send(msg, None).await.unwrap();
+ let elapsed_after_send = now.elapsed();
+ warn!(
+ "Elapsed before send {}ms, elapsed after send {}ms",
+ elapsed_before_send.as_millis(),
+ elapsed_after_send.as_millis()
+ );
}
}
}
--
GitLab