| 1656 | void init() override { conn.open(false); } |
| 1657 | |
| 1658 | Reference<ReadCursor> getCursor() { |
| 1659 | Reference<ReadCursor> cursor = *ppReadCursor; |
| 1660 | if (!cursor || cursor->get().kvBytesRead > SERVER_KNOBS->SQLITE_CURSOR_MAX_LIFETIME_BYTES) { |
| 1661 | *ppReadCursor = cursor = makeReference<ReadCursor>(); |
| 1662 | cursor->init(conn); |
| 1663 | } |
| 1664 | return cursor; |
| 1665 | } |
| 1666 | |
| 1667 | struct ReadValueAction final : TypedAction<Reader, ReadValueAction>, FastAllocated<ReadValueAction> { |
| 1668 | Key key; |
no test coverage detected