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

chore: update logs

This commit is contained in:
nathan 2024-04-04 09:47:40 +08:00
parent 6657b6295a
commit aa4df32f6d
3 changed files with 4 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -91,10 +91,7 @@ where
let msg = match collab_message_result { let msg = match collab_message_result {
Ok(msg) => msg, Ok(msg) => msg,
Err(err) => { Err(err) => {
warn!( warn!("Stream error:{}, stop receive incoming changes", err.into());
"Stream error: {}, stop receive incoming changes",
err.into()
);
break; break;
}, },
}; };

2
libs/collab-rt/src/collaborate/group_cmd.rs
View File

@ -223,7 +223,7 @@ pub async fn forward_message_to_group(
.stream_tx .stream_tx
.send(RealtimeMessage::ClientCollabV2([pair].into())); .send(RealtimeMessage::ClientCollabV2([pair].into()));
if let Err(err) = err { if let Err(err) = err {
warn!("Send user:{} message to group error: {}", user.uid, err,); warn!("Send user:{} message to group:{}", user.uid, err);
client_msg_router.remove(user); client_msg_router.remove(user);
} }
} }

7
libs/collab-rt/src/collaborate/group_persistence.rs
View File

@ -88,7 +88,7 @@ where
} }
}, },
Err(err) => { Err(err) => {
warn!("fail to encode collab {} error:{:?}", self.object_id, err); warn!("fail to encode collab {}=>{:?}", self.object_id, err);
}, },
} }
} }
@ -127,10 +127,7 @@ where
} }
}, },
Err(err) => { Err(err) => {
warn!( warn!("attempt to encode collab {}=>{:?}", self.object_id, err);
"attempt to encode collab {} error:{:?}",
self.object_id, err
);
}, },
} }