Skip to content

Commit

Permalink
chore(reqactor): correct typos
Browse files Browse the repository at this point in the history
  • Loading branch information
keroro520 committed Jan 15, 2025
1 parent 14f56a6 commit 17883a2
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions reqactor/src/backend.rs
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ impl Backend {

// Signal the request key to the internal channel, to move on to the next step, whatever the result is
//
// NOTE: Why signal whatever the result is? It's for fault tolerence, to ensure the request will be
// NOTE: Why signal whatever the result is? It's for fault tolerance, to ensure the request will be
// handled even when something unexpected happens.
self.ensure_internal_signal(request_key).await;

Expand Down Expand Up @@ -200,9 +200,9 @@ impl Backend {
);
}
Err(err) => {
// Fault tolerence: re-enqueue the internal signal after 3 seconds
// Fault tolerance: re-enqueue the internal signal after 3 seconds
tracing::warn!(
"Actor Backend failed to get status of internal signal {request_key}: {err:?}, performing fault tolerence and retrying later"
"Actor Backend failed to get status of internal signal {request_key}: {err:?}, performing fault tolerance and retrying later"
);
self.ensure_internal_signal_after(request_key, Duration::from_secs(3))
.await;
Expand All @@ -212,7 +212,7 @@ impl Backend {

// Ensure signal the request key to the internal channel.
//
// Note that this function will retry sending the signal until successed.
// Note that this function will retry sending the signal until success.
async fn ensure_internal_signal(&mut self, request_key: RequestKey) {
let mut ticker = tokio::time::interval(Duration::from_secs(3));
let internal_tx = self.internal_tx.clone();
Expand Down

0 comments on commit 17883a2

Please sign in to comment.