| 793 | } |
| 794 | |
| 795 | void deeplake_table_am_routine::scan_set_tidrange(TableScanDesc scan, ItemPointer mintid, ItemPointer maxtid) |
| 796 | { |
| 797 | CHECK_FOR_INTERRUPTS(); |
| 798 | |
| 799 | DeeplakeScanData* scan_data = get_scan_data(scan); |
| 800 | scan_data->min_tid = utils::tid_to_row_number(mintid); |
| 801 | scan_data->max_tid = utils::tid_to_row_number(maxtid); |
| 802 | scan_data->current_tid = utils::tid_to_row_number(mintid); |
| 803 | |
| 804 | if (scan_data->min_tid > scan_data->max_tid || scan_data->current_tid > scan_data->max_tid || |
| 805 | scan_data->current_tid < scan_data->min_tid) { |
| 806 | return; |
| 807 | } |
| 808 | |
| 809 | scan_data->tid_range_scan_active = true; |
| 810 | |
| 811 | // Reset the scan state to start from the beginning of the range |
| 812 | scan_data->scan_state.set_current_position(scan_data->current_tid); |
| 813 | MemoryContextReset(scan_data->memory_context); |
| 814 | } |
| 815 | |
| 816 | bool deeplake_table_am_routine::scan_getnextslot_tidrange(TableScanDesc scan, |
| 817 | ScanDirection direction, |
nothing calls this directly
no test coverage detected