general/hacker-challenge
4
0
Fork 1
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix grpc client error

Browse Source 
reset timeout on inbound message insted of creating new timer which was triggering timeout
This commit is contained in:
Noor 2024-12-27 10:08:29 +00:00
parent 4a6e8c4c73
commit 8226f03e7c
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/grpc/server.rs
View File

@ -163,10 +163,11 @@ impl Update for NodeServer {
let error_status: Status; // Gets initialized inside loop let error_status: Status; // Gets initialized inside loop
let mut timeout = interval(state.get_timeout()); let mut timeout = interval(state.get_timeout());
timeout.tick().await;
loop { loop {
tokio::select! { tokio::select! {
Some(msg) = inbound.next() => { Some(msg) = inbound.next() => {
timeout = interval(state.get_timeout()); timeout.reset();
match msg { match msg {
Ok(update) => { Ok(update) => {
if update.ip == remote_ip { if update.ip == remote_ip {