ghe0/brain-mock
1
0
Fork 1
Code Issues Pull Requests 2 Packages Projects Releases Wiki Activity

updater branch merge #1

Merged
ghe0 merged 10 commits from updater into main 2024-12-25 22:59:18 +00:00
Conversation 0 Commits 10 Files Changed 5 +2 -2
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit b27ea64722 - Show all commits

4
src/grpc.rs
View File

@ -167,7 +167,7 @@ impl BrainDaemonService for BrainDaemonMock {
req: Request<NodePubkey>,
) -> Result<Response<Self::GetUpdateVMStream>, Status> {
let req = req.into_inner();
info!("Daemon {} requested GetNewVMReqsStream", req.node_pubkey);
info!("Daemon {} requested UpdateVMReqsStream", req.node_pubkey);
let (grpc_tx, grpc_rx) = mpsc::channel(6);
let (data_tx, mut data_rx) = mpsc::channel(6);
self.data
@ -196,7 +196,7 @@ impl BrainDaemonService for BrainDaemonMock {
while let Some(confirmation) = confirmations.next().await {
match confirmation {
Ok(c) => {
info!("Received confirmation from daemon: {c:?}")
info!("Received update confirmation from daemon: {c:?}")
}
Err(e) => {
log::warn!("Daemon disconnected from Streaming<UpdateVmResp>: {e:?}")