chk
/
AppFlowy-Cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore: modify log level for some cases (#754) 

* chore: modify log level for some cases

* chore: update logs
This commit is contained in:
Nathan.fooo 2024-08-27 14:57:00 +08:00 committed by GitHub
parent 612f459a38
commit a21c55cbcc
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
libs/client-api/src/collab_sync/collab_stream.rs
View File

@ -124,6 +124,7 @@ where
sv sv
}; };
let msg = Message::Sync(SyncMessage::SyncStep1(sv)).encode_v1(); let msg = Message::Sync(SyncMessage::SyncStep1(sv)).encode_v1();
trace!("Periodic sync step 1 for {}", object_id);
sink.queue_msg(|msg_id| { sink.queue_msg(|msg_id| {
ClientCollabMessage::new_update_sync(UpdateSync::new( ClientCollabMessage::new_update_sync(UpdateSync::new(
origin.clone(), origin.clone(),

2
services/appflowy-collaborate/src/collab/disk_cache.rs
View File

@ -77,7 +77,7 @@ impl CollabDiskCache {
query: QueryCollab, query: QueryCollab,
) -> Result<EncodedCollab, AppError> { ) -> Result<EncodedCollab, AppError> {
event!( event!(
Level::INFO, Level::DEBUG,
"try get {}:{} from disk", "try get {}:{} from disk",
query.collab_type, query.collab_type,
query.object_id query.object_id

2
services/appflowy-collaborate/src/group/cmd.rs
View File

@ -195,7 +195,7 @@ where
} }
} }
#[instrument(level = "info", skip_all)] #[instrument(level = "debug", skip_all)]
async fn create_group( async fn create_group(
&self, &self,
user: &RealtimeUser, user: &RealtimeUser,

11
services/appflowy-collaborate/src/rt_server.rs
View File

@ -18,7 +18,7 @@ use database::collab::CollabStorage;
use crate::client::client_msg_router::ClientMessageRouter; use crate::client::client_msg_router::ClientMessageRouter;
use crate::command::{spawn_collaboration_command, CLCommandReceiver}; use crate::command::{spawn_collaboration_command, CLCommandReceiver};
use crate::connect_state::ConnectState; use crate::connect_state::ConnectState;
use crate::error::RealtimeError; use crate::error::{CreateGroupFailedReason, RealtimeError};
use crate::group::cmd::{GroupCommand, GroupCommandRunner, GroupCommandSender}; use crate::group::cmd::{GroupCommand, GroupCommandRunner, GroupCommandSender};
use crate::group::manager::GroupManager; use crate::group::manager::GroupManager;
use crate::indexer::IndexerProvider; use crate::indexer::IndexerProvider;
@ -228,7 +228,14 @@ where
{ {
Ok(_) => { Ok(_) => {
if let Ok(Err(err)) = rx.await { if let Ok(Err(err)) = rx.await {
error!("Handle client collab message fail: {}", err); if !matches!(
err,
RealtimeError::CreateGroupFailed(
CreateGroupFailedReason::CollabWorkspaceIdNotMatch { .. }
)
) {
error!("Handle client collab message fail: {}", err);
}
} }
}, },
Err(err) => { Err(err) => {