mirror of
https://github.com/MariaDB/server.git
synced 2025-02-21 21:03:09 +01:00
221 lines
8.8 KiB
C++
221 lines
8.8 KiB
C++
#include "tap.h"
|
|
|
|
#define SUX_LOCK_GENERIC
|
|
#define NO_ELISION
|
|
#define thd_kill_level(thd) 0
|
|
#define srv0mon_h
|
|
#define MONITOR_INC(x)
|
|
#define MONITOR_INC_VALUE(x,y)
|
|
#include "../btr/btr0sea.cc"
|
|
const size_t alloc_max_retries= 0;
|
|
const byte zero[16384]= { '\0', };
|
|
const byte *field_ref_zero= zero;
|
|
ulint srv_buf_pool_curr_size, srv_buf_pool_old_size, srv_buf_pool_size;
|
|
uint32_t srv_page_size_shift= 14;
|
|
ulong srv_page_size= 1 << 14;
|
|
dict_sys_t dict_sys;
|
|
buf_pool_t buf_pool;
|
|
buf_pool_t::chunk_t::map *buf_pool_t::chunk_t::map_reg;
|
|
buf_pool_t::chunk_t::map *buf_pool_t::chunk_t::map_ref;
|
|
|
|
void buf_pool_t::free_block(buf_block_t*) noexcept {}
|
|
void dict_mem_table_free(dict_table_t*) {}
|
|
void dict_mem_index_free(dict_index_t*) {}
|
|
buf_block_t *buf_LRU_get_free_block(buf_LRU_get) { return nullptr; }
|
|
ibool dtuple_check_typed(const dtuple_t*) { return true; }
|
|
bool btr_cur_t::check_mismatch(const dtuple_t&,bool,ulint) noexcept
|
|
{ return false; }
|
|
buf_block_t *buf_page_get_gen(const page_id_t, ulint, rw_lock_type_t,
|
|
buf_block_t*,ulint,mtr_t*,dberr_t*) noexcept
|
|
{ return nullptr; }
|
|
bool buf_page_make_young_if_needed(buf_page_t*) { return false; }
|
|
|
|
mtr_t::mtr_t()= default;
|
|
mtr_t::~mtr_t()= default;
|
|
void mtr_t::start() {}
|
|
void mtr_t::commit() {}
|
|
void mtr_t::rollback_to_savepoint(ulint, ulint) {}
|
|
void small_vector_base::grow_by_1(void *, size_t) noexcept {}
|
|
|
|
void sql_print_error(const char*, ...) {}
|
|
ulint ut_find_prime(ulint n) { return n; }
|
|
void mem_heap_block_free(mem_block_info_t*, mem_block_info_t*){}
|
|
namespace ib { error::~error() {} fatal_or_error::~fatal_or_error() {} }
|
|
std::ostream &operator<<(std::ostream &out, const page_id_t) { return out; }
|
|
|
|
#ifdef UNIV_DEBUG
|
|
byte data_error;
|
|
bool srw_lock_debug::have_wr() const noexcept { return false; }
|
|
void srw_lock_debug::rd_unlock() noexcept {}
|
|
void srw_lock_debug::rd_lock(SRW_LOCK_ARGS(const char*,unsigned)) noexcept {}
|
|
#endif
|
|
|
|
void page_hash_latch::read_lock_wait() noexcept {}
|
|
# ifndef PTHREAD_ADAPTIVE_MUTEX_INITIALIZER_NP
|
|
template<> void pthread_mutex_wrapper<true>::wr_wait() noexcept {}
|
|
# endif
|
|
template<> void srw_lock_<true>::rd_wait() noexcept {}
|
|
template<> void srw_lock_<true>::wr_wait() noexcept {}
|
|
template<bool spin> void ssux_lock_impl<spin>::wake() noexcept {}
|
|
template<bool spin> void srw_mutex_impl<spin>::wake() noexcept {}
|
|
|
|
#ifdef UNIV_PFS_MEMORY
|
|
PSI_memory_key ut_new_get_key_by_file(uint32_t){ return PSI_NOT_INSTRUMENTED; }
|
|
PSI_memory_key mem_key_other, mem_key_std;
|
|
#endif
|
|
|
|
#ifdef UNIV_PFS_RWLOCK
|
|
template<bool spin>
|
|
void srw_lock_impl<spin>::psi_wr_lock(const char*, unsigned) noexcept {}
|
|
template<bool spin>
|
|
void srw_lock_impl<spin>::psi_rd_lock(const char*, unsigned) noexcept {}
|
|
|
|
void dict_sys_t::unlock() noexcept {}
|
|
void dict_sys_t::freeze(const char *, unsigned) noexcept {}
|
|
void dict_sys_t::unfreeze() noexcept {}
|
|
#endif /* UNIV_PFS_RWLOCK */
|
|
|
|
void ut_dbg_assertion_failed(const char *e, const char *file, unsigned line)
|
|
{
|
|
fprintf(stderr, "%s:%u: Assertion %s failed\n", file, line, e ? e : "");
|
|
abort();
|
|
}
|
|
|
|
int main(int, char **argv)
|
|
{
|
|
MY_INIT(*argv);
|
|
plan(42);
|
|
|
|
btr_search.create();
|
|
btr_search.free();
|
|
|
|
dfield_t fields[2]= {{nullptr,0,0,UNIV_SQL_NULL,{0,DATA_VARCHAR,3,1,1}},
|
|
{(char*)"42",0,0,2,{0,DATA_CHAR,2,1,1}}};
|
|
dtuple_t tuple2{0,2,2,0,fields,nullptr, ut_d(DATA_TUPLE_MAGIC_N) };
|
|
dict_col_t cols[]={{}, {}, {DATA_NOT_NULL,DATA_CHAR,2,1,1,1,0,0,{nullptr,0}}};
|
|
dict_field_t ifields[3]= {{}, {}, {}};
|
|
dict_table_t table{};
|
|
dict_index_t index{};
|
|
index.table= &table;
|
|
index.n_uniq= 3;
|
|
index.n_nullable= 3;
|
|
index.n_fields= 3;
|
|
index.n_core_fields= 3;
|
|
index.n_core_null_bytes= 1;
|
|
index.fields= ifields;
|
|
|
|
ifields[0].col= &cols[0];
|
|
ifields[1].col= &cols[2];
|
|
ifields[2].col= &cols[2];
|
|
ifields[1].fixed_len= 2;
|
|
ifields[2].fixed_len= 2;
|
|
|
|
constexpr uint32_t crc42= 0x2e7d3dcb, crc3z42= 0x9a6e3c2c,
|
|
crc2z= 0xf16177d2, crc3z= 0x6064a37a;
|
|
|
|
{
|
|
btr_cur_t cursor;
|
|
cursor.page_cur.index= &index;
|
|
cursor.n_bytes_fields= 2;
|
|
|
|
ok(dtuple_fold(&tuple2, &cursor) == crc42, "dtuple_fold(NULL,'42')");
|
|
table.flags= DICT_TF_COMPACT;
|
|
ok(dtuple_fold(&tuple2, &cursor) == crc42, "dtuple_fold(NULL,'42')");
|
|
fields[0].type.mtype= DATA_CHAR;
|
|
ok(dtuple_fold(&tuple2, &cursor) == crc42, "dtuple_fold(NULL,'42')");
|
|
table.flags= 0;
|
|
ok(dtuple_fold(&tuple2, &cursor) == crc3z42, "dtuple_fold('\\0\\0\\0','42')");
|
|
fields[0].type.mtype= DATA_VARCHAR;
|
|
|
|
cursor.n_bytes_fields= 1;
|
|
ok(dtuple_fold(&tuple2, &cursor) == 0, "dtuple_fold(NULL)");
|
|
table.flags= DICT_TF_COMPACT;
|
|
ok(dtuple_fold(&tuple2, &cursor) == 0, "dtuple_fold(NULL)");
|
|
fields[0].type.mtype= DATA_CHAR;
|
|
ok(dtuple_fold(&tuple2, &cursor) == 0, "dtuple_fold(NULL)");
|
|
table.flags= 0;
|
|
ok(dtuple_fold(&tuple2, &cursor) == crc3z, "dtuple_fold('\\0\\0\\0')");
|
|
fields[0].type.mtype= DATA_VARCHAR;
|
|
|
|
cursor.n_bytes_fields= 2 << 16;
|
|
ok(dtuple_fold(&tuple2, &cursor) == 0, "dtuple_fold(NULL)");
|
|
table.flags= DICT_TF_COMPACT;
|
|
ok(dtuple_fold(&tuple2, &cursor) == 0, "dtuple_fold(NULL)");
|
|
fields[0].type.mtype= DATA_CHAR;
|
|
ok(dtuple_fold(&tuple2, &cursor) == 0, "dtuple_fold(NULL)");
|
|
table.flags= 0;
|
|
ok(dtuple_fold(&tuple2, &cursor) == crc2z, "dtuple_fold('\\0\\0')");
|
|
fields[0].type.mtype= DATA_VARCHAR;
|
|
}
|
|
|
|
byte *page= static_cast<byte*>(aligned_malloc(16384, 16384));
|
|
memset_aligned<16384>(page, 0, 16384);
|
|
byte *rec= &page[256];
|
|
page[PAGE_HEADER + PAGE_HEAP_TOP]= 1;
|
|
page[PAGE_HEADER + PAGE_HEAP_TOP + 1]= 4 + 2;
|
|
const byte r1_varchar[]= {2,0x80,0,0,0,2<<1|1,0,0, '4','2'};
|
|
const byte r2_varchar[]= {0,2,0x80,0,0,0,0,2<<1,0,0, '4','2'};
|
|
const byte r1_var3[]= {2,0x80,0x80,0,0,0,3<<1|1,0,0, '4','2'};
|
|
const byte r2_var3[]= {0,2,0x80,0,0x80,0,0,0,0,3<<1,0,0, '4','2'};
|
|
const byte r1_char[]={2+3,0x83,0,0,0,2<<1|1,0,0, 0,0,0,'4','2'};
|
|
const byte r2_char[]= {0,2+3,0x80,3,0,0,0,2<<1,0,0, 0,0,0,'4','2'};
|
|
const byte c[]= { 0,1,0,0,0,0,0, '4','2'};
|
|
const byte c3[]= { 0,3,0,0,0,0,0, '4','2'};
|
|
|
|
memcpy(rec - sizeof r1_varchar + 2, r1_varchar, sizeof r1_varchar);
|
|
ok(rec_fold(rec, index, 2, false) == crc42, "rec_fold(NULL, '42')");
|
|
ok(rec_fold(rec, index, 1, false) == 0, "rec_fold(NULL)");
|
|
ok(rec_fold(rec, index, 2 << 16, false) == 0, "rec_fold(NULL)");
|
|
memcpy(rec - sizeof r2_varchar + 2, r2_varchar, sizeof r2_varchar);
|
|
ok(rec_fold(rec, index, 2, false) == crc42, "rec_fold(NULL, '42')");
|
|
ok(rec_fold(rec, index, 1, false) == 0, "rec_fold(NULL)");
|
|
ok(rec_fold(rec, index, 2 << 16, false) == 0, "rec_fold(NULL)");
|
|
|
|
memcpy(rec - sizeof r1_var3 + 2, r1_var3, sizeof r1_var3);
|
|
ok(rec_fold(rec, index, 3, false) == crc42, "rec_fold(NULL, NULL, '42')");
|
|
ok(rec_fold(rec, index, 2, false) == 0, "rec_fold(NULL,NULL)");
|
|
ok(rec_fold(rec, index, 1 | 2 << 16, false) == 0, "rec_fold(NULL,NULL)");
|
|
memcpy(rec - sizeof r2_var3 + 2, r2_var3, sizeof r2_var3);
|
|
ok(rec_fold(rec, index, 3, false) == crc42, "rec_fold(NULL, NULL, '42')");
|
|
ok(rec_fold(rec, index, 2, false) == 0, "rec_fold(NULL,NULL)");
|
|
ok(rec_fold(rec, index, 1 | 2 << 16, false) == 0, "rec_fold(NULL,NULL)");
|
|
|
|
fields[0].type.mtype= DATA_CHAR;
|
|
memcpy(rec - sizeof r1_char + 3 + 2, r1_char, sizeof r1_char);
|
|
ok(rec_fold(rec, index, 2, false) == crc3z42, "rec_fold('\\0\\0\\0', '42')");
|
|
ok(rec_fold(rec, index, 1, false) == crc3z, "rec_fold('\\0\\0\\0')");
|
|
ok(rec_fold(rec, index, 2 << 16, false) == crc2z, "rec_fold('\\0\\0')");
|
|
memcpy(rec - sizeof r2_char + 3 + 2, r2_char, sizeof r2_char);
|
|
ok(rec_fold(rec, index, 2, false) == crc3z42, "rec_fold('\\0\\0\\0', '42')");
|
|
ok(rec_fold(rec, index, 1, false) == crc3z, "rec_fold('\\0\\0\\0')");
|
|
ok(rec_fold(rec, index, 2 << 16, false) == crc2z, "rec_fold('\\0\\0')");
|
|
|
|
page[PAGE_HEADER + PAGE_N_HEAP]= 0x80;
|
|
table.flags= DICT_TF_COMPACT;
|
|
memcpy(rec - sizeof c + 2, c, sizeof c);
|
|
ok(rec_fold(rec, index, 2, true) == crc42, "rec_fold(NULL, '42')");
|
|
ok(rec_fold(rec, index, 1, true) == 0, "rec_fold(NULL)");
|
|
ok(rec_fold(rec, index, 2 << 16, true) == 0, "rec_fold(NULL)");
|
|
fields[0].type.mtype= DATA_VARCHAR;
|
|
ok(rec_fold(rec, index, 2, true) == crc42, "rec_fold(NULL, '42')");
|
|
ok(rec_fold(rec, index, 1, true) == 0, "rec_fold(NULL)");
|
|
ok(rec_fold(rec, index, 2 << 16, true) == 0, "rec_fold(NULL)");
|
|
|
|
memcpy(rec - sizeof c3 + 2, c3, sizeof c3);
|
|
fields[0].type.mtype= DATA_CHAR;
|
|
|
|
ifields[1].col= &cols[1];
|
|
ifields[1].fixed_len= 0;
|
|
|
|
ok(rec_fold(rec, index, 3, true) == crc42, "rec_fold(NULL, NULL, '42')");
|
|
ok(rec_fold(rec, index, 2, true) == 0, "rec_fold(NULL, NULL)");
|
|
ok(rec_fold(rec, index, 1 | 2 << 16, true) == 0, "rec_fold(NULL, NULL)");
|
|
fields[0].type.mtype= DATA_VARCHAR;
|
|
ok(rec_fold(rec, index, 3, true) == crc42, "rec_fold(NULL, NULL, '42')");
|
|
ok(rec_fold(rec, index, 2, true) == 0, "rec_fold(NULL, NULL)");
|
|
ok(rec_fold(rec, index, 1 | 2 << 16, true) == 0, "rec_fold(NULL, NULL)");
|
|
aligned_free(page);
|
|
|
|
my_end(MY_CHECK_ERROR);
|
|
return exit_status();
|
|
}
|