| 860 | |
| 861 | wait(delay(CLIENT_KNOBS->CSI_STATUS_DELAY)); |
| 862 | } catch (Error& e) { |
| 863 | if (e.code() == error_code_actor_cancelled) { |
| 864 | throw; |
| 865 | } |
| 866 | cx->clientStatusUpdater.outStatusQ.clear(); |
| 867 | TraceEvent(SevWarnAlways, "UnableToWriteClientStatus").error(e); |
| 868 | wait(delay(10.0)); |
| 869 | } |
| 870 | } |
| 871 | } |
| 872 |
no test coverage detected