Skip to content

Commit 7ea8550

Browse files
committed
fix high cpu usage when event/drop stream errors keep retrying
1 parent 492a4b0 commit 7ea8550

2 files changed

Lines changed: 5 additions & 0 deletions

File tree

apis/rust/node/src/event_stream/thread.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,17 +119,20 @@ fn event_stream_loop(
119119
Ok(DaemonReply::Result(Err(err))) => {
120120
let err = eyre!(err).wrap_err("error in incoming event");
121121
tracing::error!("{err:?}");
122+
std::thread::sleep(Duration::from_millis(100));
122123
continue;
123124
}
124125

125126
Ok(other) => {
126127
let err = eyre!("unexpected control reply: {other:?}");
127128
tracing::warn!("{err:?}");
129+
std::thread::sleep(Duration::from_millis(100));
128130
continue;
129131
}
130132
Err(err) => {
131133
let err = err.wrap_err("failed to receive incoming event");
132134
tracing::warn!("{err:?}");
135+
std::thread::sleep(Duration::from_millis(100));
133136
continue;
134137
}
135138
};

apis/rust/node/src/node/drop_stream.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -124,11 +124,13 @@ fn drop_stream_loop(
124124
Ok(other) => {
125125
let err = eyre!("unexpected drop reply: {other:?}");
126126
tracing::warn!("{err:?}");
127+
std::thread::sleep(Duration::from_millis(100));
127128
continue;
128129
}
129130
Err(err) => {
130131
let err = eyre!(err).wrap_err("failed to receive incoming drop event");
131132
tracing::warn!("{err:?}");
133+
std::thread::sleep(Duration::from_millis(100));
132134
continue;
133135
}
134136
};

0 commit comments

Comments
 (0)