Skip to content

Commit c31f656

Browse files
committed
Revert "fix high cpu usage when event/drop stream errors keep retrying"
This reverts commit 7ea8550.
1 parent 7ea8550 commit c31f656

2 files changed

Lines changed: 0 additions & 5 deletions

File tree

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

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -119,20 +119,17 @@ 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));
123122
continue;
124123
}
125124

126125
Ok(other) => {
127126
let err = eyre!("unexpected control reply: {other:?}");
128127
tracing::warn!("{err:?}");
129-
std::thread::sleep(Duration::from_millis(100));
130128
continue;
131129
}
132130
Err(err) => {
133131
let err = err.wrap_err("failed to receive incoming event");
134132
tracing::warn!("{err:?}");
135-
std::thread::sleep(Duration::from_millis(100));
136133
continue;
137134
}
138135
};

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -124,13 +124,11 @@ 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));
128127
continue;
129128
}
130129
Err(err) => {
131130
let err = eyre!(err).wrap_err("failed to receive incoming drop event");
132131
tracing::warn!("{err:?}");
133-
std::thread::sleep(Duration::from_millis(100));
134132
continue;
135133
}
136134
};

0 commit comments

Comments
 (0)