| 228 | size_t SnapshotPayloadParseState::depth() const { return stackParse.size(); } |
| 229 | |
| 230 | void SnapshotPayloadParseState::trimState() { |
| 231 | while (!stackParse.empty() && (stackParse.back().arraycur == stackParse.back().arraylen)) |
| 232 | stackParse.pop_back(); |
| 233 | |
| 234 | if (stackParse.empty()) { |
| 235 | flushQueuedKeys(); |
| 236 | while (*insertsInFlight > 0) { |
| 237 | // TODO: ProcessEventsWhileBlocked |
| 238 | aeReleaseLock(); |
| 239 | aeAcquireLock(); |
| 240 | } |
| 241 | } |
| 242 | } |
| 243 | |
| 244 | void SnapshotPayloadParseState::pushArray(long long size) { |
| 245 | if (stackParse.empty()) |
no test coverage detected