| /* |
| Copyright 2020 Google LLC |
| |
| Use of this source code is governed by a BSD-style |
| license that can be found in the LICENSE file or at |
| https://developers.google.com/open-source/licenses/bsd |
| */ |
| |
| #include "system.h" |
| |
| #include "basics.h" |
| #include "constants.h" |
| #include "pq.h" |
| #include "record.h" |
| #include "reftable-tests.h" |
| #include "test_framework.h" |
| |
| void merged_iter_pqueue_check(struct merged_iter_pqueue pq) |
| { |
| int i; |
| for (i = 1; i < pq.len; i++) { |
| int parent = (i - 1) / 2; |
| |
| EXPECT(pq_less(&pq.heap[parent], &pq.heap[i])); |
| } |
| } |
| |
| static void test_pq(void) |
| { |
| char *names[54] = { NULL }; |
| int N = ARRAY_SIZE(names) - 1; |
| |
| struct merged_iter_pqueue pq = { NULL }; |
| char *last = NULL; |
| |
| int i = 0; |
| for (i = 0; i < N; i++) { |
| char name[100]; |
| snprintf(name, sizeof(name), "%02d", i); |
| names[i] = xstrdup(name); |
| } |
| |
| i = 1; |
| do { |
| struct pq_entry e = { .rec = { .type = BLOCK_TYPE_REF, |
| .u.ref = { |
| .refname = names[i], |
| } } }; |
| merged_iter_pqueue_add(&pq, e); |
| merged_iter_pqueue_check(pq); |
| i = (i * 7) % N; |
| } while (i != 1); |
| |
| while (!merged_iter_pqueue_is_empty(pq)) { |
| struct pq_entry e = merged_iter_pqueue_remove(&pq); |
| struct reftable_record *rec = &e.rec; |
| merged_iter_pqueue_check(pq); |
| |
| EXPECT(reftable_record_type(rec) == BLOCK_TYPE_REF); |
| if (last) { |
| EXPECT(strcmp(last, rec->u.ref.refname) < 0); |
| } |
| // this is names[i], so don't dealloc. |
| last = rec->u.ref.refname; |
| rec->u.ref.refname = NULL; |
| reftable_record_release(rec); |
| } |
| for (i = 0; i < N; i++) { |
| reftable_free(names[i]); |
| } |
| |
| merged_iter_pqueue_release(&pq); |
| } |
| |
| int pq_test_main(int argc, const char *argv[]) |
| { |
| RUN_TEST(test_pq); |
| return 0; |
| } |