diff options
Diffstat (limited to 'src/third_party/wiredtiger/test/cursor_order/cursor_order_file.c')
| -rw-r--r-- | src/third_party/wiredtiger/test/cursor_order/cursor_order_file.c | 133 |
1 files changed, 65 insertions, 68 deletions
diff --git a/src/third_party/wiredtiger/test/cursor_order/cursor_order_file.c b/src/third_party/wiredtiger/test/cursor_order/cursor_order_file.c index 94bcb40f667..898bc75486c 100644 --- a/src/third_party/wiredtiger/test/cursor_order/cursor_order_file.c +++ b/src/third_party/wiredtiger/test/cursor_order/cursor_order_file.c @@ -31,91 +31,88 @@ static void file_create(SHARED_CONFIG *cfg, const char *name) { - WT_CONNECTION *conn; - WT_SESSION *session; - int ret; - char config[128]; + WT_CONNECTION *conn; + WT_SESSION *session; + int ret; + char config[128]; - conn = cfg->conn; + conn = cfg->conn; - testutil_check(conn->open_session(conn, NULL, NULL, &session)); + testutil_check(conn->open_session(conn, NULL, NULL, &session)); - testutil_check(__wt_snprintf(config, sizeof(config), - "key_format=%s," - "internal_page_max=%d," - "split_deepen_min_child=200," - "leaf_page_max=%d," - "%s", - cfg->ftype == ROW ? "S" : "r", 16 * 1024, 128 * 1024, - cfg->ftype == FIX ? ",value_format=3t" : "")); + testutil_check(__wt_snprintf(config, sizeof(config), + "key_format=%s," + "internal_page_max=%d," + "split_deepen_min_child=200," + "leaf_page_max=%d," + "%s", + cfg->ftype == ROW ? "S" : "r", 16 * 1024, 128 * 1024, + cfg->ftype == FIX ? ",value_format=3t" : "")); - if ((ret = session->create(session, name, config)) != 0) - if (ret != EEXIST) - testutil_die(ret, "session.create"); + if ((ret = session->create(session, name, config)) != 0) + if (ret != EEXIST) + testutil_die(ret, "session.create"); - testutil_check(session->close(session, NULL)); + testutil_check(session->close(session, NULL)); } void load(SHARED_CONFIG *cfg, const char *name) { - WT_CONNECTION *conn; - WT_CURSOR *cursor; - WT_ITEM *value, _value; - WT_SESSION *session; - size_t len; - uint64_t keyno; - char keybuf[64], valuebuf[64]; - - conn = cfg->conn; - - file_create(cfg, name); - - testutil_check(conn->open_session(conn, NULL, NULL, &session)); - - testutil_check( - session->open_cursor(session, name, NULL, "bulk", &cursor)); - - value = &_value; - for (keyno = 1; keyno <= cfg->nkeys; ++keyno) { - if (cfg->ftype == ROW) { - testutil_check(__wt_snprintf( - keybuf, sizeof(keybuf), "%016" PRIu64, keyno)); - cursor->set_key(cursor, keybuf); - } else - cursor->set_key(cursor, (uint32_t)keyno); - value->data = valuebuf; - if (cfg->ftype == FIX) - cursor->set_value(cursor, 0x01); - else { - testutil_check(__wt_snprintf_len_set( - valuebuf, sizeof(valuebuf), - &len, "%37" PRIu64, keyno)); - value->size = (uint32_t)len; - cursor->set_value(cursor, value); - } - testutil_check(cursor->insert(cursor)); - } - - /* Setup the starting key range for the workload phase. */ - cfg->key_range = cfg->nkeys; - testutil_check(cursor->close(cursor)); - testutil_check(session->checkpoint(session, NULL)); - - testutil_check(session->close(session, NULL)); + WT_CONNECTION *conn; + WT_CURSOR *cursor; + WT_ITEM *value, _value; + WT_SESSION *session; + size_t len; + uint64_t keyno; + char keybuf[64], valuebuf[64]; + + conn = cfg->conn; + + file_create(cfg, name); + + testutil_check(conn->open_session(conn, NULL, NULL, &session)); + + testutil_check(session->open_cursor(session, name, NULL, "bulk", &cursor)); + + value = &_value; + for (keyno = 1; keyno <= cfg->nkeys; ++keyno) { + if (cfg->ftype == ROW) { + testutil_check(__wt_snprintf(keybuf, sizeof(keybuf), "%016" PRIu64, keyno)); + cursor->set_key(cursor, keybuf); + } else + cursor->set_key(cursor, (uint32_t)keyno); + value->data = valuebuf; + if (cfg->ftype == FIX) + cursor->set_value(cursor, 0x01); + else { + testutil_check( + __wt_snprintf_len_set(valuebuf, sizeof(valuebuf), &len, "%37" PRIu64, keyno)); + value->size = (uint32_t)len; + cursor->set_value(cursor, value); + } + testutil_check(cursor->insert(cursor)); + } + + /* Setup the starting key range for the workload phase. */ + cfg->key_range = cfg->nkeys; + testutil_check(cursor->close(cursor)); + testutil_check(session->checkpoint(session, NULL)); + + testutil_check(session->close(session, NULL)); } void verify(SHARED_CONFIG *cfg, const char *name) { - WT_CONNECTION *conn; - WT_SESSION *session; + WT_CONNECTION *conn; + WT_SESSION *session; - conn = cfg->conn; + conn = cfg->conn; - testutil_check(conn->open_session(conn, NULL, NULL, &session)); + testutil_check(conn->open_session(conn, NULL, NULL, &session)); - testutil_check(session->verify(session, name, NULL)); + testutil_check(session->verify(session, name, NULL)); - testutil_check(session->close(session, NULL)); + testutil_check(session->close(session, NULL)); } |