| 85 | } |
| 86 | |
| 87 | ThreadFuture<int64_t> ThreadSafeDatabase::rebootWorker(const StringRef& address, bool check, int duration) { |
| 88 | DatabaseContext* db = this->db; |
| 89 | Key addressKey = address; |
| 90 | return onMainThread([db, addressKey, check, duration]() -> Future<int64_t> { |
| 91 | db->checkDeferredError(); |
| 92 | return db->rebootWorker(addressKey, check, duration); |
| 93 | }); |
| 94 | } |
| 95 | |
| 96 | ThreadFuture<Void> ThreadSafeDatabase::forceRecoveryWithDataLoss(const StringRef& dcid) { |
| 97 | DatabaseContext* db = this->db; |
nothing calls this directly
no test coverage detected