| 1787 | } |
| 1788 | |
| 1789 | Future<Void> init() override { |
| 1790 | if (openFuture.isValid()) { |
| 1791 | return openFuture; |
| 1792 | } |
| 1793 | auto a = std::make_unique<Writer::OpenAction>( |
| 1794 | path, metrics, &readSemaphore, &fetchSemaphore, errorListener, counters); |
| 1795 | openFuture = a->done.getFuture(); |
| 1796 | writeThread->post(a.release()); |
| 1797 | return openFuture; |
| 1798 | } |
| 1799 | |
| 1800 | void set(KeyValueRef kv, const Arena*) override { |
| 1801 | if (writeBatch == nullptr) { |
no test coverage detected