Should always return the top down messages, only when ipc parent_client is down after exponential retries
(
&self,
height: BlockHeight,
)
| 141 | /// Should always return the top down messages, only when ipc parent_client is down after exponential |
| 142 | /// retries |
| 143 | async fn validator_changes( |
| 144 | &self, |
| 145 | height: BlockHeight, |
| 146 | ) -> anyhow::Result<Vec<StakingChangeRequest>> { |
| 147 | let r = self.inner.validator_changes(height).await?; |
| 148 | |
| 149 | if let Some(v) = r { |
| 150 | return Ok(v); |
| 151 | } |
| 152 | |
| 153 | let r = retry!( |
| 154 | self.config.exponential_back_off, |
| 155 | self.config.exponential_retry_limit, |
| 156 | self.parent_client |
| 157 | .get_validator_changes(height) |
| 158 | .await |
| 159 | .map(|r| r.value) |
| 160 | ); |
| 161 | |
| 162 | handle_null_round(r, Vec::new) |
| 163 | } |
| 164 | |
| 165 | /// Should always return the top down messages, only when ipc parent_client is down after exponential |
| 166 | /// retries |
no test coverage detected