summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDon Anderson <dda@ddanderson.com>2015-11-10 10:43:48 -0500
committerDon Anderson <dda@ddanderson.com>2015-11-10 10:43:48 -0500
commit778c16f19dc1c8612974b72c1a41e43a7d83f15b (patch)
tree35b913d4ec4971f7483b848c0cb9b02fa51c925b
parent4a7f74260e83934e5d338430e8539d601aac3b2e (diff)
downloadmongo-778c16f19dc1c8612974b72c1a41e43a7d83f15b.tar.gz
WT-1315. Changed names of macros and inline functions to be more clear
and consistent.
-rw-r--r--src/cursor/cur_index.c2
-rw-r--r--src/cursor/cur_join.c83
-rw-r--r--src/cursor/cur_table.c11
-rw-r--r--src/include/api.h8
-rw-r--r--src/include/cursor.h18
-rw-r--r--src/include/cursor.i8
-rw-r--r--src/session/session_api.c14
7 files changed, 76 insertions, 68 deletions
diff --git a/src/cursor/cur_index.c b/src/cursor/cur_index.c
index 5819bb04cf2..a909eaece99 100644
--- a/src/cursor/cur_index.c
+++ b/src/cursor/cur_index.c
@@ -35,7 +35,7 @@ __curindex_get_value(WT_CURSOR *cursor, ...)
va_start(ap, cursor);
JOINABLE_CURSOR_API_CALL(cursor, session, get_value, NULL);
- WT_ERR(__wt_curindex_get_value_ap(cursor, ap));
+ WT_ERR(__wt_curindex_get_valuev(cursor, ap));
err: va_end(ap);
API_END_RET(session, ret);
diff --git a/src/cursor/cur_join.c b/src/cursor/cur_join.c
index 2e27f6b3a45..f2f482b4b3a 100644
--- a/src/cursor/cur_join.c
+++ b/src/cursor/cur_join.c
@@ -201,7 +201,7 @@ __curjoin_get_key(WT_CURSOR *cursor, ...)
va_start(ap, cursor);
CURSOR_API_CALL(cursor, session, get_key, NULL);
- if (!F_ISSET(cjoin, WT_CJ_INITIALIZED) ||
+ if (!F_ISSET(cjoin, WT_CURJOIN_INITIALIZED) ||
!__curjoin_entry_iter_ready(cjoin->iter)) {
__wt_errx(session, "join cursor must be advanced with next()");
WT_ERR(EINVAL);
@@ -231,15 +231,15 @@ __curjoin_get_value(WT_CURSOR *cursor, ...)
va_start(ap, cursor);
CURSOR_API_CALL(cursor, session, get_value, NULL);
- if (!F_ISSET(cjoin, WT_CJ_INITIALIZED) ||
+ if (!F_ISSET(cjoin, WT_CURJOIN_INITIALIZED) ||
!__curjoin_entry_iter_ready(iter)) {
__wt_errx(session, "join cursor must be advanced with next()");
WT_ERR(EINVAL);
}
if (iter->entry->index != NULL)
- WT_ERR(__wt_curindex_get_value_ap(iter->cursor, ap));
+ WT_ERR(__wt_curindex_get_valuev(iter->cursor, ap));
else
- WT_ERR(__wt_curtable_get_value_ap(iter->cursor, ap));
+ WT_ERR(__wt_curtable_get_valuev(iter->cursor, ap));
err: va_end(ap);
API_END_RET(session, ret);
@@ -304,7 +304,7 @@ __curjoin_init_bloom(WT_SESSION_IMPL *session, WT_CURSOR_JOIN *cjoin,
WT_ERR(__wt_cursor_dup_position(entry->ends[0].cursor, c));
skip_left = (entry->ends[0].cursor == NULL) ||
- entry->ends[0].flags == (WT_CJE_ENDPOINT_GT | WT_CJE_ENDPOINT_EQ);
+ entry->ends[0].flags == (WT_CURJOIN_END_GT | WT_CURJOIN_END_EQ);
collator = (entry->index == NULL) ? NULL : entry->index->collator;
while (ret == 0) {
c->get_key(c, &curkey);
@@ -327,11 +327,11 @@ __curjoin_init_bloom(WT_SESSION_IMPL *session, WT_CURSOR_JOIN *cjoin,
WT_ERR(__wt_compare(session, collator, &curkey,
&entry->ends[0].key, &cmp));
if (cmp < 0 || (cmp == 0 &&
- !F_ISSET(&entry->ends[0], WT_CJE_ENDPOINT_EQ)))
+ !F_ISSET(&entry->ends[0], WT_CURJOIN_END_EQ)))
goto advance;
if (cmp > 0) {
if (F_ISSET(&entry->ends[0],
- WT_CJE_ENDPOINT_GT))
+ WT_CURJOIN_END_GT))
skip_left = true;
else
break;
@@ -341,7 +341,7 @@ __curjoin_init_bloom(WT_SESSION_IMPL *session, WT_CURSOR_JOIN *cjoin,
WT_ERR(__wt_compare(session, collator, &curkey,
&entry->ends[1].key, &cmp));
if (cmp > 0 || (cmp == 0 &&
- !F_ISSET(&entry->ends[1], WT_CJE_ENDPOINT_EQ)))
+ !F_ISSET(&entry->ends[1], WT_CURJOIN_END_EQ)))
break;
}
if (entry->index != NULL)
@@ -387,7 +387,7 @@ __curjoin_endpoint_init_key(WT_SESSION_IMPL *session,
&cindex->child->key, &endpoint->key,
&allocbuf));
if (allocbuf != NULL)
- F_SET(endpoint, WT_CJE_ENDPOINT_OWNKEY);
+ F_SET(endpoint, WT_CURJOIN_END_OWNKEY);
} else
endpoint->key = cindex->child->key;
} else {
@@ -442,10 +442,10 @@ __curjoin_init_iter(WT_SESSION_IMPL *session, WT_CURSOR_JOIN *cjoin)
* the btree is ordered.
*/
if (je == cjoin->entries && je->ends[0].flags ==
- (WT_CJE_ENDPOINT_GT | WT_CJE_ENDPOINT_EQ))
- F_SET(cjoin, WT_CJ_SKIP_FIRST_LEFT);
+ (WT_CURJOIN_END_GT | WT_CURJOIN_END_EQ))
+ F_SET(cjoin, WT_CURJOIN_SKIP_FIRST_LEFT);
- if (F_ISSET(je, WT_CJE_BLOOM)) {
+ if (F_ISSET(je, WT_CURJOIN_ENTRY_BLOOM)) {
if (je->bloom == NULL) {
/*
* Look for compatible filters to be shared,
@@ -455,7 +455,8 @@ __curjoin_init_iter(WT_SESSION_IMPL *session, WT_CURSOR_JOIN *cjoin)
m = je->bloom_bit_count;
k = je->bloom_hash_count;
for (je2 = je + 1; je2 < jeend; je2++)
- if (F_ISSET(je2, WT_CJE_BLOOM) &&
+ if (F_ISSET(je2,
+ WT_CURJOIN_ENTRY_BLOOM) &&
je2->count == je->count) {
m = WT_MAX(
je2->bloom_bit_count, m);
@@ -466,7 +467,7 @@ __curjoin_init_iter(WT_SESSION_IMPL *session, WT_CURSOR_JOIN *cjoin)
je->bloom_hash_count = k;
WT_ERR(__wt_bloom_create(session, NULL,
NULL, je->count, m, k, &je->bloom));
- F_SET(je, WT_CJE_OWN_BLOOM);
+ F_SET(je, WT_CURJOIN_ENTRY_OWN_BLOOM);
WT_ERR(__curjoin_init_bloom(session, cjoin,
je, je->bloom));
/*
@@ -474,7 +475,8 @@ __curjoin_init_iter(WT_SESSION_IMPL *session, WT_CURSOR_JOIN *cjoin)
* config info consistent.
*/
for (je2 = je + 1; je2 < jeend; je2++)
- if (F_ISSET(je2, WT_CJE_BLOOM) &&
+ if (F_ISSET(je2,
+ WT_CURJOIN_ENTRY_BLOOM) &&
je2->count == je->count) {
WT_ASSERT(session,
je2->bloom == NULL);
@@ -499,7 +501,7 @@ __curjoin_init_iter(WT_SESSION_IMPL *session, WT_CURSOR_JOIN *cjoin)
}
}
}
- F_SET(cjoin, WT_CJ_INITIALIZED);
+ F_SET(cjoin, WT_CURJOIN_INITIALIZED);
err:
return (ret);
@@ -524,8 +526,8 @@ __curjoin_entry_in_range(WT_SESSION_IMPL *session, WT_CURSOR_JOIN_ENTRY *entry,
&entry->ends[0].key, &cmp));
if (cmp < 0 ||
(cmp == 0 &&
- !F_ISSET(&entry->ends[0], WT_CJE_ENDPOINT_EQ)) ||
- (cmp > 0 && !F_ISSET(&entry->ends[0], WT_CJE_ENDPOINT_GT)))
+ !F_ISSET(&entry->ends[0], WT_CURJOIN_END_EQ)) ||
+ (cmp > 0 && !F_ISSET(&entry->ends[0], WT_CURJOIN_END_GT)))
WT_ERR(WT_NOTFOUND);
}
if (entry->ends[1].cursor != NULL) {
@@ -533,8 +535,8 @@ __curjoin_entry_in_range(WT_SESSION_IMPL *session, WT_CURSOR_JOIN_ENTRY *entry,
&entry->ends[1].key, &cmp));
if (cmp > 0 ||
(cmp == 0 &&
- !F_ISSET(&entry->ends[1], WT_CJE_ENDPOINT_EQ)) ||
- (cmp < 0 && !F_ISSET(&entry->ends[1], WT_CJE_ENDPOINT_LT)))
+ !F_ISSET(&entry->ends[1], WT_CURJOIN_END_EQ)) ||
+ (cmp < 0 && !F_ISSET(&entry->ends[1], WT_CURJOIN_END_LT)))
WT_ERR(WT_NOTFOUND);
}
@@ -626,7 +628,7 @@ __curjoin_entry_member(WT_SESSION_IMPL *session, WT_CURSOR_JOIN *cjoin,
* in a previous entry. So the shared filter has already
* been checked and passed.
*/
- if (!F_ISSET(entry, WT_CJE_OWN_BLOOM))
+ if (!F_ISSET(entry, WT_CURJOIN_ENTRY_OWN_BLOOM))
return (0);
/*
@@ -682,11 +684,11 @@ __curjoin_next(WT_CURSOR *cursor)
CURSOR_API_CALL(cursor, session, next, NULL);
- if (F_ISSET(cjoin, WT_CJ_ERROR)) {
+ if (F_ISSET(cjoin, WT_CURJOIN_ERROR)) {
__wt_errx(session, "join cursor encountered previous error");
WT_ERR(WT_ERROR);
}
- if (!F_ISSET(cjoin, WT_CJ_INITIALIZED))
+ if (!F_ISSET(cjoin, WT_CURJOIN_INITIALIZED))
WT_ERR(__curjoin_init_iter(session, cjoin));
nextkey:
@@ -699,7 +701,7 @@ nextkey:
* 'left' case for the first entry, since we're
* using that in our iteration.
*/
- skip_left = F_ISSET(cjoin, WT_CJ_SKIP_FIRST_LEFT);
+ skip_left = F_ISSET(cjoin, WT_CURJOIN_SKIP_FIRST_LEFT);
for (count = 0; count < cjoin->entries_next; count++) {
ret = __curjoin_entry_member(session, cjoin,
&cjoin->entries[count], skip_left);
@@ -711,7 +713,7 @@ nextkey:
}
if (0) {
-err: F_SET(cjoin, WT_CJ_ERROR);
+err: F_SET(cjoin, WT_CURJOIN_ERROR);
}
API_END_RET(session, ret);
}
@@ -731,7 +733,7 @@ __curjoin_reset(WT_CURSOR *cursor)
CURSOR_API_CALL(cursor, session, reset, NULL);
- if (F_ISSET(cjoin, WT_CJ_INITIALIZED))
+ if (F_ISSET(cjoin, WT_CURJOIN_INITIALIZED))
WT_ERR(__curjoin_entry_iter_reset(cjoin->iter));
err: API_END_RET(session, ret);
@@ -771,11 +773,11 @@ __curjoin_close(WT_CURSOR *cursor)
F_CLR(entry->ends[0].cursor, WT_CURSTD_JOINED);
if (entry->ends[1].cursor != NULL)
F_CLR(entry->ends[1].cursor, WT_CURSTD_JOINED);
- if (F_ISSET(&entry->ends[0], WT_CJE_ENDPOINT_OWNKEY))
+ if (F_ISSET(&entry->ends[0], WT_CURJOIN_END_OWNKEY))
__wt_free(session, entry->ends[0].key.data);
- if (F_ISSET(&entry->ends[1], WT_CJE_ENDPOINT_OWNKEY))
+ if (F_ISSET(&entry->ends[1], WT_CURJOIN_END_OWNKEY))
__wt_free(session, entry->ends[1].key.data);
- if (F_ISSET(entry, WT_CJE_OWN_BLOOM))
+ if (F_ISSET(entry, WT_CURJOIN_ENTRY_OWN_BLOOM))
WT_TRET(__wt_bloom_close(entry->bloom));
}
@@ -899,13 +901,13 @@ __wt_curjoin_join(WT_SESSION_IMPL *session, WT_CURSOR_JOIN *cjoin,
break;
}
if (nonbloom == -1 && i > 0 &&
- !F_ISSET(&cjoin->entries[i], WT_CJE_BLOOM))
+ !F_ISSET(&cjoin->entries[i], WT_CURJOIN_ENTRY_BLOOM))
nonbloom = i;
}
if (entry == NULL) {
WT_ERR(__wt_realloc_def(session, &cjoin->entries_allocated,
cjoin->entries_next + 1, &cjoin->entries));
- if (LF_ISSET(WT_CJE_BLOOM) && nonbloom != -1) {
+ if (LF_ISSET(WT_CURJOIN_ENTRY_BLOOM) && nonbloom != -1) {
/*
* Reorder the list so that after the first entry,
* the Bloom filtered entries come next, followed by
@@ -937,19 +939,20 @@ __wt_curjoin_join(WT_SESSION_IMPL *session, WT_CURSOR_JOIN *cjoin,
count, entry->count);
WT_ERR(EINVAL);
}
- if (LF_ISSET(WT_CJE_BLOOM) != F_ISSET(entry, WT_CJE_BLOOM)) {
+ if (LF_ISSET(WT_CURJOIN_ENTRY_BLOOM) !=
+ F_ISSET(entry, WT_CURJOIN_ENTRY_BLOOM)) {
__wt_errx(session, "join has incompatible strategy "
"values for the same index");
WT_ERR(EINVAL);
}
/* Check flag combinations */
- if ((F_ISSET(&entry->ends[0], WT_CJE_ENDPOINT_GT) &&
- (range & WT_CJE_ENDPOINT_GT) != 0) ||
- (F_ISSET(&entry->ends[1], WT_CJE_ENDPOINT_LT) &&
- (range & WT_CJE_ENDPOINT_LT) != 0) ||
- ((F_ISSET(&entry->ends[0], WT_CJE_ENDPOINT_EQ) ||
- F_ISSET(&entry->ends[1], WT_CJE_ENDPOINT_EQ)) &&
- (range == WT_CJE_ENDPOINT_EQ))) {
+ if ((F_ISSET(&entry->ends[0], WT_CURJOIN_END_GT) &&
+ (range & WT_CURJOIN_END_GT) != 0) ||
+ (F_ISSET(&entry->ends[1], WT_CURJOIN_END_LT) &&
+ (range & WT_CURJOIN_END_LT) != 0) ||
+ ((F_ISSET(&entry->ends[0], WT_CURJOIN_END_EQ) ||
+ F_ISSET(&entry->ends[1], WT_CURJOIN_END_EQ)) &&
+ (range == WT_CURJOIN_END_EQ))) {
__wt_errx(session, "join has overlapping ranges");
WT_ERR(EINVAL);
}
@@ -960,7 +963,7 @@ __wt_curjoin_join(WT_SESSION_IMPL *session, WT_CURSOR_JOIN *cjoin,
entry->bloom_hash_count =
WT_MAX(entry->bloom_hash_count, bloom_hash_count);
}
- if (range & WT_CJE_ENDPOINT_LT)
+ if (range & WT_CURJOIN_END_LT)
endpoint = &entry->ends[1];
else
endpoint = &entry->ends[0];
diff --git a/src/cursor/cur_table.c b/src/cursor/cur_table.c
index d940f52c387..7d227e76c7b 100644
--- a/src/cursor/cur_table.c
+++ b/src/cursor/cur_table.c
@@ -192,7 +192,7 @@ __wt_curtable_get_value(WT_CURSOR *cursor, ...)
va_start(ap, cursor);
JOINABLE_CURSOR_API_CALL(cursor, session, get_value, NULL);
- WT_ERR(__wt_curtable_get_value_ap(cursor, ap));
+ WT_ERR(__wt_curtable_get_valuev(cursor, ap));
err: va_end(ap);
API_END_RET(session, ret);
@@ -483,8 +483,7 @@ __curtable_insert(WT_CURSOR *cursor)
u_int i;
ctable = (WT_CURSOR_TABLE *)cursor;
- CURSOR_UPDATE_API_CALL(cursor, session, insert, NULL);
- JOINABLE_CURSOR_CALL_CHECK(cursor);
+ JOINABLE_CURSOR_UPDATE_API_CALL(cursor, session, insert, NULL);
WT_ERR(__curtable_open_indices(ctable));
/*
@@ -542,8 +541,7 @@ __curtable_update(WT_CURSOR *cursor)
WT_SESSION_IMPL *session;
ctable = (WT_CURSOR_TABLE *)cursor;
- CURSOR_UPDATE_API_CALL(cursor, session, update, NULL);
- JOINABLE_CURSOR_CALL_CHECK(cursor);
+ JOINABLE_CURSOR_UPDATE_API_CALL(cursor, session, update, NULL);
WT_ERR(__curtable_open_indices(ctable));
/*
@@ -594,8 +592,7 @@ __curtable_remove(WT_CURSOR *cursor)
WT_SESSION_IMPL *session;
ctable = (WT_CURSOR_TABLE *)cursor;
- CURSOR_REMOVE_API_CALL(cursor, session, NULL);
- JOINABLE_CURSOR_CALL_CHECK(cursor);
+ JOINABLE_CURSOR_REMOVE_API_CALL(cursor, session, NULL);
WT_ERR(__curtable_open_indices(ctable));
/* Find the old record so it can be removed from indices */
diff --git a/src/include/api.h b/src/include/api.h
index 826d5f37a8c..4821b450f9e 100644
--- a/src/include/api.h
+++ b/src/include/api.h
@@ -129,6 +129,10 @@
TXN_API_CALL_NOCONF(s, WT_CURSOR, remove, cur, \
((bt) == NULL) ? NULL : ((WT_BTREE *)(bt))->dhandle);
+#define JOINABLE_CURSOR_REMOVE_API_CALL(cur, s, bt) \
+ CURSOR_REMOVE_API_CALL(cur, s, bt); \
+ JOINABLE_CURSOR_CALL_CHECK(cur)
+
#define CURSOR_UPDATE_API_CALL(cur, s, n, bt) \
(s) = (WT_SESSION_IMPL *)(cur)->session; \
TXN_API_CALL_NOCONF(s, WT_CURSOR, n, cur, \
@@ -136,6 +140,10 @@
if (F_ISSET(S2C(s), WT_CONN_IN_MEMORY) && __wt_cache_full(s)) \
WT_ERR(WT_CACHE_FULL);
+#define JOINABLE_CURSOR_UPDATE_API_CALL(cur, s, n, bt) \
+ CURSOR_UPDATE_API_CALL(cur, s, n, bt); \
+ JOINABLE_CURSOR_CALL_CHECK(cur)
+
#define CURSOR_UPDATE_API_END(s, ret) \
TXN_API_END(s, ret)
diff --git a/src/include/cursor.h b/src/include/cursor.h
index 61ee81c96ff..d0825d307c1 100644
--- a/src/include/cursor.h
+++ b/src/include/cursor.h
@@ -278,10 +278,10 @@ struct __wt_cursor_join_endpoint {
uint8_t recno_buf[10]; /* holds packed recno */
WT_CURSOR *cursor;
-#define WT_CJE_ENDPOINT_LT 0x01 /* include values < cursor */
-#define WT_CJE_ENDPOINT_EQ 0x02 /* include values == cursor */
-#define WT_CJE_ENDPOINT_GT 0x04 /* include values > cursor */
-#define WT_CJE_ENDPOINT_OWNKEY 0x08 /* must free key's data */
+#define WT_CURJOIN_END_LT 0x01 /* include values < cursor */
+#define WT_CURJOIN_END_EQ 0x02 /* include values == cursor */
+#define WT_CURJOIN_END_GT 0x04 /* include values > cursor */
+#define WT_CURJOIN_END_OWNKEY 0x08 /* must free key's data */
uint8_t flags; /* range for this endpoint */
};
@@ -293,8 +293,8 @@ struct __wt_cursor_join_entry {
uint64_t bloom_hash_count; /* hash functions in bloom */
uint64_t count; /* approx number of matches */
-#define WT_CJE_BLOOM 0x01 /* use a bloom filter */
-#define WT_CJE_OWN_BLOOM 0x02 /* this entry owns the bloom */
+#define WT_CURJOIN_ENTRY_BLOOM 0x01 /* use a bloom filter */
+#define WT_CURJOIN_ENTRY_OWN_BLOOM 0x02 /* this entry owns the bloom */
uint8_t flags;
WT_CURSOR_JOIN_ENDPOINT ends[2]; /* reference endpoints */
@@ -311,9 +311,9 @@ struct __wt_cursor_join {
size_t entries_next;
uint8_t recno_buf[10]; /* holds packed recno */
-#define WT_CJ_ERROR 0x01 /* Error during initialization */
-#define WT_CJ_INITIALIZED 0x02 /* Successful initialization */
-#define WT_CJ_SKIP_FIRST_LEFT 0x04
+#define WT_CURJOIN_ERROR 0x01 /* Error in initialization */
+#define WT_CURJOIN_INITIALIZED 0x02 /* Successful initialization */
+#define WT_CURJOIN_SKIP_FIRST_LEFT 0x04 /* First check not needed */
uint8_t flags;
};
diff --git a/src/include/cursor.i b/src/include/cursor.i
index 7f90e43ed6c..9dd280534b4 100644
--- a/src/include/cursor.i
+++ b/src/include/cursor.i
@@ -139,11 +139,11 @@ __curfile_leave(WT_CURSOR_BTREE *cbt)
}
/*
- * __wt_curindex_get_value_ap --
+ * __wt_curindex_get_valuev --
* Internal implementation of WT_CURSOR->get_value for index cursors
*/
static inline int
-__wt_curindex_get_value_ap(WT_CURSOR *cursor, va_list ap)
+__wt_curindex_get_valuev(WT_CURSOR *cursor, va_list ap)
{
WT_CURSOR_INDEX *cindex;
WT_DECL_RET;
@@ -170,11 +170,11 @@ err: return (ret);
}
/*
- * __wt_curtable_get_value_ap --
+ * __wt_curtable_get_valuev --
* Internal implementation of WT_CURSOR->get_value for table cursors.
*/
static inline int
-__wt_curtable_get_value_ap(WT_CURSOR *cursor, va_list ap)
+__wt_curtable_get_valuev(WT_CURSOR *cursor, va_list ap)
{
WT_CURSOR *primary;
WT_CURSOR_TABLE *ctable;
diff --git a/src/session/session_api.c b/src/session/session_api.c
index 4e5ee8b238c..bfa7a6d67e3 100644
--- a/src/session/session_api.c
+++ b/src/session/session_api.c
@@ -676,18 +676,18 @@ __session_join(WT_SESSION *wt_session, WT_CURSOR *join_cursor,
}
/* "ge" is the default */
- range = WT_CJE_ENDPOINT_GT | WT_CJE_ENDPOINT_EQ;
+ range = WT_CURJOIN_END_GT | WT_CURJOIN_END_EQ;
flags = 0;
WT_ERR(__wt_config_gets(session, cfg, "compare", &cval));
if (cval.len != 0) {
if (WT_STRING_MATCH("gt", cval.str, cval.len))
- range = WT_CJE_ENDPOINT_GT;
+ range = WT_CURJOIN_END_GT;
else if (WT_STRING_MATCH("lt", cval.str, cval.len))
- range = WT_CJE_ENDPOINT_LT;
+ range = WT_CURJOIN_END_LT;
else if (WT_STRING_MATCH("le", cval.str, cval.len))
- range = WT_CJE_ENDPOINT_LT | WT_CJE_ENDPOINT_EQ;
+ range = WT_CURJOIN_END_LT | WT_CURJOIN_END_EQ;
else if (WT_STRING_MATCH("eq", cval.str, cval.len))
- range = WT_CJE_ENDPOINT_EQ;
+ range = WT_CURJOIN_END_EQ;
else if (!WT_STRING_MATCH("ge", cval.str, cval.len))
WT_ERR(EINVAL);
}
@@ -698,7 +698,7 @@ __session_join(WT_SESSION *wt_session, WT_CURSOR *join_cursor,
WT_ERR(__wt_config_gets(session, cfg, "strategy", &cval));
if (cval.len != 0) {
if (WT_STRING_MATCH("bloom", cval.str, cval.len))
- LF_SET(WT_CJE_BLOOM);
+ LF_SET(WT_CURJOIN_ENTRY_BLOOM);
else if (!WT_STRING_MATCH("default", cval.str, cval.len))
WT_ERR(EINVAL);
}
@@ -706,7 +706,7 @@ __session_join(WT_SESSION *wt_session, WT_CURSOR *join_cursor,
bloom_bit_count = (uint64_t)cval.val;
WT_ERR(__wt_config_gets(session, cfg, "bloom_hash_count", &cval));
bloom_hash_count = (uint64_t)cval.val;
- if (LF_ISSET(WT_CJE_BLOOM)) {
+ if (LF_ISSET(WT_CURJOIN_ENTRY_BLOOM)) {
if (count == 0) {
__wt_errx(session, "count must be nonzero when "
"strategy=bloom");