Reset the head reader (this is used only for extent based remap queue after recovering the remap queue contents via fastpath extent reads)
| 1177 | // Reset the head reader (this is used only for extent based remap queue after recovering the remap |
| 1178 | // queue contents via fastpath extent reads) |
| 1179 | void resetHeadReader() { |
| 1180 | headReader.resetRead(); |
| 1181 | debug_printf("FIFOQueue(%s) read cursor reset\n", name.c_str()); |
| 1182 | } |
| 1183 | |
| 1184 | // Fast path extent peekAll (this zooms through the queue reading extents at a time) |
| 1185 | // Output interface is a promise stream and one vector of results per extent found is sent to the promise stream |
no test coverage detected