diff --git a/db/db_kv_checksum_test.cc b/db/db_kv_checksum_test.cc index d3108e73529..3b85ef50ebc 100644 --- a/db/db_kv_checksum_test.cc +++ b/db/db_kv_checksum_test.cc @@ -732,7 +732,7 @@ TEST_P(DbMemtableKVChecksumTest, GetWithCorruptAfterMemtableInsert) { }); SyncPoint::GetInstance()->SetCallBack( - "Memtable::SaveValue:Begin:entry", [&](void* entry) { + "Memtable::SaveValue:Found:entry", [&](void* entry) { char* buf = *static_cast(entry); buf[corrupt_byte_offset_] += corrupt_byte_addend_; ++corrupt_byte_offset_; @@ -769,7 +769,7 @@ TEST_P(DbMemtableKVChecksumTest, }); SyncPoint::GetInstance()->SetCallBack( - "Memtable::SaveValue:Begin:entry", [&](void* entry) { + "Memtable::SaveValue:Found:entry", [&](void* entry) { char* buf = *static_cast(entry); buf[corrupt_byte_offset_] += corrupt_byte_addend_; ++corrupt_byte_offset_; diff --git a/db/memtable.cc b/db/memtable.cc index 393e228a6ee..5eb933db8b6 100644 --- a/db/memtable.cc +++ b/db/memtable.cc @@ -928,7 +928,6 @@ struct Saver { } // anonymous namespace static bool SaveValue(void* arg, const char* entry) { - TEST_SYNC_POINT_CALLBACK("Memtable::SaveValue:Begin:entry", &entry); Saver* s = static_cast(arg); assert(s != nullptr); assert(!s->value || !s->columns); @@ -955,6 +954,7 @@ static bool SaveValue(void* arg, const char* entry) { if (user_comparator->EqualWithoutTimestamp(user_key_slice, s->key->user_key())) { // Correct user key + TEST_SYNC_POINT_CALLBACK("Memtable::SaveValue:Found:entry", &entry); std::unique_ptr read_lock; if (s->inplace_update_support) { read_lock.reset(new ReadLock(s->mem->GetLock(s->key->user_key())));