| 2030 | } |
| 2031 | |
| 2032 | void disableRateControl() { |
| 2033 | if (dbFile && dbFile->getRateControl()) { |
| 2034 | TraceEvent(SevDebug, "KeyValueStoreSQLiteShutdownRateControl").detail("Filename", dbFile->getFilename()); |
| 2035 | Reference<IRateControl> rc = dbFile->getRateControl(); |
| 2036 | dbFile->setRateControl({}); |
| 2037 | rc->wakeWaiters(); |
| 2038 | } |
| 2039 | dbFile.clear(); |
| 2040 | |
| 2041 | if (walFile && walFile->getRateControl()) { |
| 2042 | TraceEvent(SevDebug, "KeyValueStoreSQLiteShutdownRateControl").detail("Filename", walFile->getFilename()); |
| 2043 | Reference<IRateControl> rc = walFile->getRateControl(); |
| 2044 | walFile->setRateControl({}); |
| 2045 | rc->wakeWaiters(); |
| 2046 | } |
| 2047 | walFile.clear(); |
| 2048 | } |
| 2049 | |
| 2050 | ACTOR static Future<Void> stopOnError(KeyValueStoreSQLite* self) { |
| 2051 | try { |
nothing calls this directly
no test coverage detected