diff options
| author | Douglas Rumbaugh <dbr4@psu.edu> | 2023-08-24 17:00:31 -0400 |
|---|---|---|
| committer | Douglas Rumbaugh <dbr4@psu.edu> | 2023-08-24 17:00:31 -0400 |
| commit | 076e104b8672924c3d80cd1da2fdb5ebee1766ac (patch) | |
| tree | e33a8081c61899c5d1a471401605e55716ca3ff4 /include/util/Cursor.h | |
| parent | 1cb522b36382381ef3f1494f24b0c6a98f8843a9 (diff) | |
| download | dynamic-extension-076e104b8672924c3d80cd1da2fdb5ebee1766ac.tar.gz | |
Migrated over to using psudb-common utilities/headers
Diffstat (limited to 'include/util/Cursor.h')
| -rw-r--r-- | include/util/Cursor.h | 14 |
1 files changed, 5 insertions, 9 deletions
diff --git a/include/util/Cursor.h b/include/util/Cursor.h index 815458c..1b0b8ed 100644 --- a/include/util/Cursor.h +++ b/include/util/Cursor.h @@ -9,9 +9,11 @@ */ #pragma once -#include "util/base.h" #include "framework/RecordInterface.h" -#include "io/PagedFile.h" + +#include "psu-ds/BloomFilter.h" +#include "psu-ds/PriorityQueue.h" +#include "psu-util/alignment.h" namespace de { template<typename R> @@ -37,19 +39,13 @@ struct Cursor { * not be closed. */ template<typename R> -inline static bool advance_cursor(Cursor<R> &cur, PagedFileIterator *iter = nullptr) { +inline static bool advance_cursor(Cursor<R> &cur) { cur.ptr++; cur.cur_rec_idx++; if (cur.cur_rec_idx >= cur.rec_cnt) return false; if (cur.ptr >= cur.end) { - if (iter && iter->next()) { - cur.ptr = (R*)iter->get_item(); - cur.end = cur.ptr + (PAGE_SIZE / sizeof(R)); - return true; - } - return false; } return true; |