diff options
| author | Douglas Rumbaugh <dbr4@psu.edu> | 2023-05-15 16:48:56 -0400 |
|---|---|---|
| committer | Douglas Rumbaugh <dbr4@psu.edu> | 2023-05-15 16:48:56 -0400 |
| commit | ff000799c3254f52e0beabbe9c62d10c3fc4178e (patch) | |
| tree | 49a1a045678315e8e215fd80409973679b793043 /include/util/Cursor.h | |
| parent | 418e9b079e559c86f3a5b276f712ad2f5d66533c (diff) | |
| download | dynamic-extension-ff000799c3254f52e0beabbe9c62d10c3fc4178e.tar.gz | |
Record format generalization
Currently, tombstone counting is bugged. But the rest of it appears to
be working.
Diffstat (limited to 'include/util/Cursor.h')
| -rw-r--r-- | include/util/Cursor.h | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/include/util/Cursor.h b/include/util/Cursor.h index 2339800..2609ae5 100644 --- a/include/util/Cursor.h +++ b/include/util/Cursor.h @@ -14,10 +14,10 @@ #include "io/PagedFile.h" namespace de { -template<typename K, typename V, typename W=void> +template<typename R> struct Cursor { - Record<K,V,W> *ptr; - const Record<K,V,W> *end; + R *ptr; + R *end; size_t cur_rec_idx; size_t rec_cnt; @@ -36,8 +36,8 @@ struct Cursor { * be updated to be equal to end, and false will be returned. Iterators will * not be closed. */ -template<typename K, typename V, typename W> -inline static bool advance_cursor(Cursor<K,V,W> &cur, PagedFileIterator *iter = nullptr) { +template<typename R> +inline static bool advance_cursor(Cursor<R> &cur, PagedFileIterator *iter = nullptr) { cur.ptr++; cur.cur_rec_idx++; @@ -45,8 +45,8 @@ inline static bool advance_cursor(Cursor<K,V,W> &cur, PagedFileIterator *iter = if (cur.ptr >= cur.end) { if (iter && iter->next()) { - cur.ptr = (Record<K,V,W>*)iter->get_item(); - cur.end = cur.ptr + (PAGE_SIZE / sizeof(Record<K,V,W>)); + cur.ptr = (R*)iter->get_item(); + cur.end = cur.ptr + (PAGE_SIZE / sizeof(R)); return true; } @@ -62,14 +62,14 @@ inline static bool advance_cursor(Cursor<K,V,W> &cur, PagedFileIterator *iter = * This allows for "peaking" at the next largest element after the current * largest is processed. */ -template <typename K, typename V, typename W> -inline static Cursor<K,V,W> *get_next(std::vector<Cursor<K,V,W>> &cursors, Cursor<K,V,W> *current=nullptr) { - const Record<K,V,W> *min_rec = nullptr; - Cursor<K,V,W> *result = nullptr; +template <typename R> +inline static Cursor<R> *get_next(std::vector<Cursor<R>> &cursors, Cursor<R> *current=nullptr) { + const R *min_rec = nullptr; + Cursor<R> *result = nullptr; for (size_t i=0; i< cursors.size(); i++) { - if (cursors[i] == (Cursor<K,V,W>) {0} ) continue; + if (cursors[i] == (Cursor<R>) {0} ) continue; - const Record<K,V,W> *rec = (&cursors[i] == current) ? cursors[i].ptr + 1 : cursors[i].ptr; + const R *rec = (&cursors[i] == current) ? cursors[i].ptr + 1 : cursors[i].ptr; if (rec >= cursors[i].end) continue; if (min_rec == nullptr) { |