diff options
author | Luke Chen <luke.chen@mongodb.com> | 2023-02-16 17:37:17 +1100 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2023-02-16 07:35:18 +0000 |
commit | 5e4ec1d24431fcdd28b579a024c5c801b8cde4e2 (patch) | |
tree | f957f9046012900c405f84ac092f43a0d94b46f9 | |
parent | d15d5583531a456aa9157b4fd7df587e805d98dd (diff) | |
download | mongo-5e4ec1d24431fcdd28b579a024c5c801b8cde4e2.tar.gz |
Import wiredtiger: 64e230b1a60c9f63022c1683d006c7d19ec39439 from branch mongodb-4.2r4.2.24-rc2r4.2.24
ref: 2392add87a..64e230b1a6
for: 4.2.24
WT-10584 Add missing read barriers in __cursor_skip_prev
-rw-r--r-- | src/third_party/wiredtiger/import.data | 2 | ||||
-rw-r--r-- | src/third_party/wiredtiger/src/btree/bt_curprev.c | 31 |
2 files changed, 27 insertions, 6 deletions
diff --git a/src/third_party/wiredtiger/import.data b/src/third_party/wiredtiger/import.data index 4068dc6111d..d6ccf445dc9 100644 --- a/src/third_party/wiredtiger/import.data +++ b/src/third_party/wiredtiger/import.data @@ -2,5 +2,5 @@ "vendor": "wiredtiger", "github": "wiredtiger/wiredtiger.git", "branch": "mongodb-4.2", - "commit": "2392add87a1a13d528fa0aea4d0a349dfff3d78b" + "commit": "64e230b1a60c9f63022c1683d006c7d19ec39439" } diff --git a/src/third_party/wiredtiger/src/btree/bt_curprev.c b/src/third_party/wiredtiger/src/btree/bt_curprev.c index 86356c3ce5e..3e6ada2b1ce 100644 --- a/src/third_party/wiredtiger/src/btree/bt_curprev.c +++ b/src/third_party/wiredtiger/src/btree/bt_curprev.c @@ -34,7 +34,7 @@ static inline int __cursor_skip_prev(WT_CURSOR_BTREE *cbt) { - WT_INSERT *current, *ins; + WT_INSERT *current, *ins, *next_ins; WT_ITEM key; WT_SESSION_IMPL *session; uint64_t recno; @@ -82,7 +82,13 @@ restart: for (; i >= 0; i--) { cbt->ins_stack[i] = NULL; cbt->next_stack[i] = NULL; - ins = cbt->ins_head->head[i]; + /* + * Compiler may replace the usage of the variable with another read in the following + * code. + * + * Place a read barrier to avoid this issue. + */ + WT_ORDERED_READ(ins, cbt->ins_head->head[i]); if (ins != NULL && ins != current) break; } @@ -98,11 +104,26 @@ restart: cbt->next_stack[0] = NULL; goto restart; } - if (ins->next[i] != current) /* Stay at this level */ - ins = ins->next[i]; + /* + * CPU may reorder the read and return a stale value. This can lead us to wrongly skip a + * value in the lower levels of the skip list. + * + * For example, if we have A -> C initially for both level 0 and level 1 and we concurrently + * insert B into both level 0 and level 1. If B is visible on level 1 to this thread, it + * must also be visible on level 0. Otherwise, we would record an inconsistent stack. + * + * Place a read barrier to avoid this issue. + */ + WT_ORDERED_READ(next_ins, ins->next[i]); + if (next_ins != current) /* Stay at this level */ + ins = next_ins; else { /* Drop down a level */ + /* + * It is possible that we read an old value that is inconsistent to the higher levels of + * the skip list due to CPU read reordering. Add a read barrier to avoid this issue. + */ + WT_ORDERED_READ(cbt->next_stack[i], ins->next[i]); cbt->ins_stack[i] = &ins->next[i]; - cbt->next_stack[i] = ins->next[i]; --i; } } |