+SET(TOKUDB_VERSION 5.6.30-76.3)

+ set(CMAKE_CXX_FLAGS "-std=c++11 -Wno-deprecated-declarations ${CMAKE_CXX_FLAGS}")

+ -Wno-error=maybe-uninitialized

+ -Wno-pointer-bool-conversion

+ if (APPLE)

+ set(FLTO_OPTS "-fwhole-program")

+ else ()

+ set(FLTO_OPTS "-fuse-linker-plugin")

+ endif()

+ set(CMAKE_C_FLAGS_RELWITHDEBINFO "-flto ${FLTO_OPTS} ${CMAKE_C_FLAGS_RELWITHDEBINFO} -g -O3 -UNDEBUG")

+ set(CMAKE_CXX_FLAGS_RELWITHDEBINFO "-flto ${FLTO_OPTS} ${CMAKE_CXX_FLAGS_RELWITHDEBINFO} -g -O3 -UNDEBUG")

+ set(CMAKE_C_FLAGS_RELEASE "-g -O3 -flto ${FLTO_OPTS} ${CMAKE_C_FLAGS_RELEASE} -UNDEBUG")

+ set(CMAKE_CXX_FLAGS_RELEASE "-g -O3 -flto ${FLTO_OPTS} ${CMAKE_CXX_FLAGS_RELEASE} -UNDEBUG")

+ set(CMAKE_EXE_LINKER_FLAGS "-g ${FLTO_OPTS} ${CMAKE_EXE_LINKER_FLAGS}")

+ set(CMAKE_SHARED_LINKER_FLAGS "-g ${FLTO_OPTS} ${CMAKE_SHARED_LINKER_FLAGS}")

+ if (version_of_logs_on_disk >= TOKU_LOG_VERSION_25 &&

+ version_of_logs_on_disk <= TOKU_LOG_VERSION_29 &&

+// don't need to run recovery.

+ file(GLOB upgrade_tests "${CMAKE_CURRENT_SOURCE_DIR}/upgrade.data/upgrade-recovery-logs-??-clean")

+ file(GLOB upgrade_tests "${CMAKE_CURRENT_SOURCE_DIR}/upgrade.data/upgrade-recovery-logs-??-dirty")

+ // don't forget to dirty the node

+ // don't forget to dirty the node

+ CKERR2(r, TOKUDB_UPGRADE_FAILURE); // we don't support dirty upgrade from versions <= 24

+ // don't forget to dirty the node

+ // don't forget to dirty the node

+ // don't forget to dirty the node

+ // don't forget to dirty the node

+ // don't forget to dirty the node

+ // don't forget to dirty the node

+ // don't forget to dirty the node

+static void (* test_txn_sync_callback) (pthread_t, void *) = NULL;

+void set_test_txn_sync_callback(void (*cb) (pthread_t, void *), void *extra) {

+void set_test_txn_sync_callback(void (*) (pthread_t, void*), void*);

+find_library(JEMALLOC_STATIC_LIBRARY libjemalloc.a)

+

+ if (with_jemalloc AND JEMALLOC_STATIC_LIBRARY)

+ if (with_jemalloc AND JEMALLOC_STATIC_LIBRARY)

+ target_link_libraries(${_testname} -Wl,-force_load ${JEMALLOC_STATIC_LIBRARY})

+ target_link_libraries(${_testname} -Wl,--whole-archive ${JEMALLOC_STATIC_LIBRARY} -Wl,--no-whole-archive)

+ # m = MIMEText(body)

+ # fromaddr = 'dev-private@percona.com'

+ # m['From'] = fromaddr

+ # m['To'] = ', '.join(toaddrs)

+ # m['Subject'] = subject

+ # s = SMTP('192.168.1.114')

+ # s.sendmail(fromaddr, toaddrs, str(m))

+ # s.quit()

+ info(subject);

+ info(body);

+ send_mail(['dev-private@percona.com'], 'Stress tests on %s failed to build.' % gethostname(), '')

+ send_mail(['dev-private@percona.com'], 'Stress tests on %s failed to build.' % gethostname(), '')

+ send_mail(['dev-private@percona.com'], 'Stress tests caught unhandled exception in main, on %s' % gethostname(), format_exc())

+ opts.email.append('dev-private@percona.com')

+ // If the outermost is not live, then the inner state must be retired. That's the way that the txn API works.

+ memset(str,'a', sizeof str);

+ DBT val = { .data = str, .size = sizeof str };

+ snprintf(key, 100, "%08" PRIu64, j);

+ snprintf(key, 100, "%08" PRIu64, j);

+ printf("%s : before commit %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+ printf("%s : after commit %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+ printf("%s : before delete %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+ printf("%s : after delete %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+ printf("%s : after commit %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+ "%s : before insert commit %" PRIu64 " rows\n",

+ "%s : after insert commit %" PRIu64 " rows\n",

+ printf("%s : after delete %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+ "%s : after delete commit %" PRIu64 " rows\n",

+ printf("%s : before rollback %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+ printf("%s : after rollback %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+ "%s : after rollback optimize %" PRIu64 " rows\n",

+ printf("%s : before delete %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+ printf("%s : after delete %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+ printf("%s : after commit %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+ "%s : before insert commit %" PRIu64 " rows\n",

+ "%s : after insert commit %" PRIu64 " rows\n",

+ printf("%s : after delete %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+ "%s : after delete rollback %" PRIu64 " rows\n",

+ "%s : after delete rollback optimize %" PRIu64 " rows\n",

+ "%s : count[%" PRIu64 "] deleted[%" PRIu64 "]\n",

+ "%s : before commit %" PRIu64 " rows\n",

+ printf("%s : after commit %" PRIu64 " rows\n", __FUNCTION__, stats.bt_ndata);

+static void test_callback(pthread_t self_tid, void * extra) {

+ assert(pthread_equal(self_tid, tid_2));

+ printf("%s: the thread[%" PRIu64 "] is going to wait...\n", __func__, reinterpret_cast<uint64_t>(tid_1));

+ printf("%s: the thread[%" PRIu64 "] is resuming...\n", __func__, reinterpret_cast<uint64_t>(tid_1));

+ printf("start %s [thread %" PRIu64 "]\n", __func__, reinterpret_cast<uint64_t>(pthread_self()));

+ printf("%s done[thread %" PRIu64 "]\n", __func__, reinterpret_cast<uint64_t>(pthread_self()));

+ printf("start %s: [thread %" PRIu64 "]\n", __func__, reinterpret_cast<uint64_t>(pthread_self()));

+ printf("%s: txn began by [thread %" PRIu64 "], will wait\n", __func__, reinterpret_cast<uint64_t>(pthread_self()));

+ printf("%s: [thread %" PRIu64 "] resumed\n", __func__, reinterpret_cast<uint64_t>(pthread_self()));

+ printf("%s: done[thread %" PRIu64 "]\n", __func__, reinterpret_cast<uint64_t>(pthread_self()));

+void toku_set_test_txn_sync_callback(void (* cb) (pthread_t, void *), void * extra) {

+extern "C" void toku_set_test_txn_sync_callback(void (* ) (pthread_t, void *), void * extra) __attribute__((__visibility__("default")));

+ if (opt_eligible &&

+ (is_replace_into(thd) || is_insert_ignore(thd)) &&

+ tokudb::sysvars::pk_insert_mode(thd) == 1 &&

+ !table->triggers &&

+ !(mysql_bin_log.is_open() &&

+ thd->variables.binlog_format != BINLOG_FORMAT_STMT)) {

+ do_opt = true;

+ HA_KEYREAD_ONLY | HA_READ_RANGE | HA_DO_INDEX_COND_PUSHDOWN);

+int ha_tokudb::index_next_same(uchar* buf, const uchar* key, uint keylen) {

+ create_dbt_key_from_table(

+ &found_key,

+ tokudb_active_index,

+ key_buff3,buf,

+ &has_null);

+ cmp =

+ tokudb_prefix_cmp_dbt_key(

+ share->key_file[tokudb_active_index],

+ &curr_key,

+ &found_key);

+static int smart_dbt_bf_callback(

+ DBT const* key,

+ DBT const* row,

+ void* context) {

+ return

+ info->ha->fill_range_query_buf(

+ info->need_val,

+ key,

+ row,

+ info->direction,

+ info->thd,

+ info->buf,

+ info->key_to_compare);

+enum icp_result ha_tokudb::toku_handler_index_cond_check(

+ Item* pushed_idx_cond) {

+

+ if (end_range) {

+ }

+ DBT const* key,

+ DBT const* row,

+ DBT* key_to_compare) {

+

+ uint32_t size_remaining =

+ size_range_query_buff - bytes_used_in_range_query_buff;

+ key);

+ if (toku_pushed_idx_cond &&

+ (tokudb_active_index == toku_pushed_idx_cond_keyno)) {

+ enum icp_result result =

+ toku_handler_index_cond_check(toku_pushed_idx_cond);

+

+ // otherwise, if we simply see that the current key is no match,

+ // we tell the cursor to continue and don't store

+ // the key locally

+ DEBUG_SYNC(ha_thd(), "tokudb_icp_asc_scan_out_of_range");

+ } else if (result == ICP_NO_MATCH) {

+ // if we are performing a DESC ICP scan and have no end_range

+ // to compare to stop using ICP filtering as there isn't much more

+ // that we can do without going through contortions with remembering

+ // and comparing key parts.

+ if (!end_range &&

+ direction < 0) {

+

+ cancel_pushed_idx_cond();

+ DEBUG_SYNC(ha_thd(), "tokudb_icp_desc_scan_invalidate");

+ }

+

+ } else {

+ size_needed =

+ // size of key length

+ sizeof(uint32_t) +

+ // key and row

+ key->size + row->size +

+ // lengths of varchars stored

+ num_var_cols_for_query * (sizeof(uint32_t)) +

+ // length of blobs

+ sizeof(uint32_t);

+ } else {

+ range_query_buff =

+ static_cast<uchar*>(tokudb::memory::realloc(

+ static_cast<void*>(range_query_buff),

+ bytes_used_in_range_query_buff + size_needed,

+ MYF(MY_WME)));

+ size_range_query_buff = bytes_used_in_range_query_buff + size_needed;

+ *reinterpret_cast<uint32_t*>(curr_pos) = key->size;

+ *reinterpret_cast<uint32_t*>(curr_pos) = row->size;

+ } else {

+ const uchar* fixed_field_ptr = static_cast<const uchar*>(row->data);

+ var_field_offset_ptr =

+ fixed_field_ptr +

+ share->kc_info.mcp_info[tokudb_active_index].fixed_field_size;

+ var_field_data_ptr =

+ var_field_offset_ptr +

+ share->kc_info.mcp_info[tokudb_active_index].len_of_offsets;

+ share->kc_info.field_lengths[field_index]);

+ uint32_t var_field_index =

+ share->kc_info.cp_info[tokudb_active_index][field_index].col_pack_val;

+ share->kc_info.num_offset_bytes);

+ memcpy(

+ curr_pos,

+ var_field_data_ptr + data_start_offset,

+ field_len);

+ share->kc_info.num_offset_bytes);

+ data_size =

+ row->size -

+ blob_offset -

+ static_cast<uint32_t>((var_field_data_ptr -

+ static_cast<const uchar*>(row->data)));

+ if (bytes_used_in_range_query_buff +

+ table_share->rec_buff_length >

+ user_defined_size) {

+ &right_range);

+ } else {

+ &left_range);

+int ha_tokudb::get_next(

+ uchar* buf,

+ int direction,

+ DBT* key_to_compare,

+ bool do_key_read) {

+

+ bool need_val =

+ (do_key_read == 0) &&

+ (tokudb_active_index == primary_key ||

+ key_is_clustering(&table->key_info[tokudb_active_index]));

+ if ((bytes_used_in_range_query_buff -

+ curr_range_query_buff_offset) > 0) {

+ } else if (icp_went_out_of_range) {

+ } else {

+ while (bytes_used_in_range_query_buff == 0 &&

+ !icp_went_out_of_range && error == 0) {

+ error =

+ cursor->c_getf_next(

+ cursor,

+ flags,

+ smart_dbt_bf_callback,

+ &bf_info);

+ error =

+ cursor->c_getf_prev(

+ cursor,

+ flags,

+ smart_dbt_bf_callback,

+ &bf_info);

+ if (bytes_used_in_range_query_buff == 0 &&

+ icp_went_out_of_range) {

+ error =

+ handle_cursor_error(

+ error,

+ HA_ERR_END_OF_FILE,

+ tokudb_active_index);

+ if (error) {

+ goto cleanup;

+ }

+ error =

+ read_data_from_range_query_buff(buf, need_val, do_key_read);

+ } else {

+ error =

+ cursor->c_getf_next(

+ cursor,

+ flags,

+ SMART_DBT_CALLBACK(do_key_read),

+ &info);

+ error =

+ cursor->c_getf_prev(

+ cursor,

+ flags,

+ SMART_DBT_CALLBACK(do_key_read),

+ &info);

+ error =

+ handle_cursor_error(

+ error,

+ HA_ERR_END_OF_FILE,

+ tokudb_active_index);

+ if (!error &&

+ !do_key_read &&

+ (tokudb_active_index != primary_key) &&

+ !key_is_clustering(&table->key_info[tokudb_active_index])) {

+ tokudb_trx_data* trx =

+ static_cast<tokudb_trx_data*>(thd_get_ha_data(thd, tokudb_hton));

+void ha_tokudb::cancel_pushed_idx_cond() {

+ invalidate_icp();

+ handler::cancel_pushed_idx_cond();

+}

+

+ void cancel_pushed_idx_cond();

+ DBT const* key,

+ DBT const* row,

+ DBT* key_to_compare);

+

+ memset(&key, 0, sizeof(DBT));

+ memset(&prev_key, 0, sizeof(DBT));

+ // when not auto analyze or if this is an alter

+ if ((txn &&

+ thd_sql_command(thd) != SQLCOM_ANALYZE &&

+ thd_sql_command(thd) != SQLCOM_ALTER_TABLE) ||

+ thd_sql_command(thd) == SQLCOM_ALTER_TABLE) {

+ // Handle deprecated options

+ if (tokudb::sysvars::pk_insert_mode(NULL) != 1) {

+ TOKUDB_TRACE("Using tokudb_pk_insert_mode is deprecated and the "

+ "parameter may be removed in future releases. "

+ "tokudb_pk_insert_mode=0 is now forbidden. "

+ "See documentation and release notes for details");

+ if (tokudb::sysvars::pk_insert_mode(NULL) < 1)

+ tokudb::sysvars::set_pk_insert_mode(NULL, 1);

+ }

+

+set tokudb_lock_timeout=600000;

+set tokudb_lock_timeout=600000;

+set tokudb_lock_timeout=600000;

+set tokudb_lock_timeout=600000;

+set tokudb_prelock_empty=OFF;

+set tokudb_lock_timeout=60000;

+replace into t values (1);

+select locks_dname,locks_key_left,locks_key_right,locks_table_schema,locks_table_name,locks_table_dictionary_name from information_schema.tokudb_locks where locks_table_schema='test' and locks_table_name='t' and locks_table_dictionary_name='main' order by locks_key_left, locks_key_right;

+locks_dname locks_key_left locks_key_right locks_table_schema locks_table_name locks_table_dictionary_name

+select locks_dname,locks_key_left,locks_key_right,locks_table_schema,locks_table_name,locks_table_dictionary_name from information_schema.tokudb_locks where locks_table_schema='test' and locks_table_name='t' and locks_table_dictionary_name='main' order by locks_key_left, locks_key_right;

+locks_dname locks_key_left locks_key_right locks_table_schema locks_table_name locks_table_dictionary_name

+./test/t-main 0001000000 0001000000 test t main

+./test/t-main 0002000000 0002000000 test t main

+./test/t-main 0003000000 0003000000 test t main

+./test/t-main 0004000000 0004000000 test t main

+./test/t-main 0005000000 0005000000 test t main

+./test/t-main 0006000000 0006000000 test t main

+select locks_dname,locks_key_left,locks_key_right,locks_table_schema,locks_table_name,locks_table_dictionary_name from information_schema.tokudb_locks where locks_table_schema='test' and locks_table_name='t' and locks_table_dictionary_name='main' order by locks_key_left, locks_key_right;

+locks_dname locks_key_left locks_key_right locks_table_schema locks_table_name locks_table_dictionary_name

+set tokudb_prelock_empty=OFF;

+set tokudb_lock_timeout=600000;

+select trx_id,trx_mysql_thread_id from information_schema.tokudb_trx where trx_mysql_thread_id in(connection_id());

+select count(trx_mysql_thread_id) from information_schema.tokudb_trx where trx_mysql_thread_id in(connection_id());

+count(trx_mysql_thread_id)

+1

+select trx_id,trx_mysql_thread_id from information_schema.tokudb_trx where trx_mysql_thread_id in(connection_id());

+select count(trx_mysql_thread_id) from information_schema.tokudb_trx where trx_mysql_thread_id in(connection_id());

+count(trx_mysql_thread_id)

+1

+select count(trx_mysql_thread_id) from information_schema.tokudb_trx where trx_mysql_thread_id in(connection_id());

+count(trx_mysql_thread_id)

+0

+select trx_id,trx_mysql_thread_id from information_schema.tokudb_trx where trx_mysql_thread_id in(connection_id());

+fast_update_binlog_mixed : https://tokutek.atlassian.net/browse/DB-871

+fast_update_binlog_row : https://tokutek.atlassian.net/browse/DB-871

+fast_update_binlog_statement : https://tokutek.atlassian.net/browse/DB-871

+fast_update_blobs : https://tokutek.atlassian.net/browse/DB-871

+fast_update_decr_floor : https://tokutek.atlassian.net/browse/DB-871

+fast_update_error : https://tokutek.atlassian.net/browse/DB-871

+fast_update_int_bounds : https://tokutek.atlassian.net/browse/DB-871

+fast_update_int : https://tokutek.atlassian.net/browse/DB-871

+fast_update_uint_bounds : https://tokutek.atlassian.net/browse/DB-871

+fast_update_varchar : https://tokutek.atlassian.net/browse/DB-871

+fast_upsert_char : https://tokutek.atlassian.net/browse/DB-871

+fast_upsert_int : https://tokutek.atlassian.net/browse/DB-871

+set tokudb_lock_timeout=600000; # set lock wait timeout to 10 minutes

+set tokudb_lock_timeout=600000; # set lock wait timeout to 10 minutes

+set tokudb_lock_timeout=600000; # set lock wait timeout to 10 minutes

+set tokudb_lock_timeout=600000; # set lock wait timeout to 10 minutes

+set tokudb_prelock_empty=OFF;

+set tokudb_lock_timeout=60000; # set lock wait timeout to 1 minute

+

+send replace into t values (1);

+let $wait_condition= select count(*)=1 from information_schema.processlist where info='replace into t values (1)' and state='update';

+real_sleep 45; # sleep till we get close to timeout since wait_condidion will timeout @ 30 seconds

+let $wait_condition= select count(*)=0 from information_schema.processlist where info='replace into t values (1)' and state='update';

+source include/wait_condition.inc;

+select locks_dname,locks_key_left,locks_key_right,locks_table_schema,locks_table_name,locks_table_dictionary_name from information_schema.tokudb_locks where locks_table_schema='test' and locks_table_name='t' and locks_table_dictionary_name='main' order by locks_key_left, locks_key_right;

+eval select locks_dname,locks_key_left,locks_key_right,locks_table_schema,locks_table_name,locks_table_dictionary_name from information_schema.tokudb_locks where locks_table_schema='test' and locks_table_name='t' and locks_table_dictionary_name='main' order by locks_key_left, locks_key_right;

+select locks_dname,locks_key_left,locks_key_right,locks_table_schema,locks_table_name,locks_table_dictionary_name from information_schema.tokudb_locks where locks_table_schema='test' and locks_table_name='t' and locks_table_dictionary_name='main' order by locks_key_left, locks_key_right;

+drop table t;

+set tokudb_prelock_empty=OFF;

+set tokudb_lock_timeout=600000; # set lock wait timeout to 10 minutes

+select trx_id,trx_mysql_thread_id from information_schema.tokudb_trx where trx_mysql_thread_id in(connection_id());

+select count(trx_mysql_thread_id) from information_schema.tokudb_trx where trx_mysql_thread_id in(connection_id());

+select trx_id,trx_mysql_thread_id from information_schema.tokudb_trx where trx_mysql_thread_id in(connection_id());

+select count(trx_mysql_thread_id) from information_schema.tokudb_trx where trx_mysql_thread_id in(connection_id());

+select count(trx_mysql_thread_id) from information_schema.tokudb_trx where trx_mysql_thread_id in(connection_id());

+select trx_id,trx_mysql_thread_id from information_schema.tokudb_trx where trx_mysql_thread_id in(connection_id());

+drop table t;

+SET SESSION tokudb_auto_analyze = 0;

+SET SESSION tokudb_analyze_in_background = 0;

+CREATE TABLE t1(

+`id` int(10) unsigned NOT NULL,

+`k` int(10) unsigned NOT NULL DEFAULT '0',

+`c` char(120) NOT NULL DEFAULT '',

+`pad` char(60) NOT NULL DEFAULT '',

+KEY `xid` (`id`),

+KEY `k` (`k`)

+) ENGINE=TokuDB DEFAULT CHARSET=latin1;

+INSERT INTO t1 VALUES(1, 1, '1', '1'), (2, 2, '2', '2'), (3, 3, '3', '3'), (4, 4, '4', '4'),

+(5, 5, '5', '5'), (6, 6, '6', '6'), (6, 6, '6', '6'), (7, 7, '7', '7'),

+(8, 8, '8', '8'), (9, 9, '9', '9'), (10, 10, '10', '10'), (11, 11, '11', '11');

+ANALYZE TABLE t1;

+Table Op Msg_type Msg_text

+test.t1 analyze status OK

+set DEBUG_SYNC = 'tokudb_icp_desc_scan_invalidate SIGNAL hit1 WAIT_FOR done1';

+SELECT c FROM t1 WHERE id BETWEEN 5 AND 8 ORDER BY id DESC;

+set DEBUG_SYNC = 'now WAIT_FOR hit1';

+set DEBUG_SYNC = 'now SIGNAL done1';

+c

+8

+7

+6

+6

+5

+set DEBUG_SYNC = 'tokudb_icp_asc_scan_out_of_range SIGNAL hit2 WAIT_FOR done2';

+SELECT c FROM t1 WHERE id BETWEEN 5 AND 8 ORDER BY id ASC;

+set DEBUG_SYNC = 'now WAIT_FOR hit2';

+set DEBUG_SYNC = 'now SIGNAL done2';

+c

+5

+6

+6

+7

+8

+drop table t1;

+select locks_dname,locks_key_left,locks_key_right from information_schema.tokudb_locks order by locks_dname,locks_key_left,locks_key_right;

+./test/t1-main ff01000000 0101000000

+./test/t1_audit-main 0200000000000000 0200000000000000

+select locks_dname,locks_key_left,locks_key_right from information_schema.tokudb_locks order by locks_dname,locks_key_left,locks_key_right;

+./test/t1-main ff02000000 0102000000

+./test/t1_audit-main 0300000000000000 0300000000000000

+select locks_dname,locks_key_left,locks_key_right from information_schema.tokudb_locks order by locks_dname,locks_key_left,locks_key_right;

+./test/t1_audit-main 0200000000000000 0200000000000000

+select locks_dname,locks_key_left,locks_key_right from information_schema.tokudb_locks order by locks_dname,locks_key_left,locks_key_right;

+./test/t1_audit-main 0300000000000000 0300000000000000

+select locks_dname,locks_key_left,locks_key_right from information_schema.tokudb_locks order by locks_dname,locks_key_left,locks_key_right;

+./test/t1-main ff01000000 0101000000

+./test/t1_audit-main 0200000000000000 0200000000000000

+select locks_dname,locks_key_left,locks_key_right from information_schema.tokudb_locks order by locks_dname,locks_key_left,locks_key_right;

+./test/t1-main ff02000000 0102000000

+./test/t1_audit-main 0300000000000000 0300000000000000

+Warnings:

+Warning 131 Using tokudb_pk_insert_mode is deprecated and the parameter may be removed in future releases.

+t 1 x 1 x A 5 NULL NULL YES BTREE

+t 1 x 1 x A 5 NULL NULL YES BTREE

+t 1 x 1 x A 9 NULL NULL YES BTREE

+t 1 y 1 y A 9 NULL NULL YES BTREE

+set default_storage_engine='tokudb';

+drop table if exists t1;

+set session tokudb_auto_analyze = 1;

+set session tokudb_analyze_in_background = true;

+set session tokudb_analyze_mode = TOKUDB_ANALYZE_STANDARD;

+set session tokudb_analyze_throttle = 0;

+set session tokudb_analyze_time = 0;

+create table t1(a int, b text(1), c text(1), filler text(1), primary key(a, b(1)), unique key (a, c(1)));

+lock tables t1 write, t1 as a read, t1 as b read;

+insert into t1(a) values(1);

+alter table t1 drop key a;

+unlock tables;

+Handler_read_prev 799

+Handler_read_prev 399

+# This test for DB-233 tests that icp descending range scans stop properly once

+# it fails to find a key match instead of continuing to scan all the way to the

+# beginning of the index.

+

+-- source include/have_tokudb.inc

+-- source include/have_debug.inc

+-- source include/have_debug_sync.inc

+

+-- enable_query_log

+

+SET SESSION tokudb_auto_analyze = 0;

+SET SESSION tokudb_analyze_in_background = 0;

+

+CREATE TABLE t1(

+ `id` int(10) unsigned NOT NULL,

+ `k` int(10) unsigned NOT NULL DEFAULT '0',

+ `c` char(120) NOT NULL DEFAULT '',

+ `pad` char(60) NOT NULL DEFAULT '',

+ KEY `xid` (`id`),

+ KEY `k` (`k`)

+) ENGINE=TokuDB DEFAULT CHARSET=latin1;

+

+INSERT INTO t1 VALUES(1, 1, '1', '1'), (2, 2, '2', '2'), (3, 3, '3', '3'), (4, 4, '4', '4'),

+(5, 5, '5', '5'), (6, 6, '6', '6'), (6, 6, '6', '6'), (7, 7, '7', '7'),

+(8, 8, '8', '8'), (9, 9, '9', '9'), (10, 10, '10', '10'), (11, 11, '11', '11');

+

+ANALYZE TABLE t1;

+

+# lets flip to another connection

+connect(conn1, localhost, root);

+

+# set up the DEBUG_SYNC point

+set DEBUG_SYNC = 'tokudb_icp_desc_scan_invalidate SIGNAL hit1 WAIT_FOR done1';

+

+# send the query

+send SELECT c FROM t1 WHERE id BETWEEN 5 AND 8 ORDER BY id DESC;

+

+# back to default connection

+connection default;

+

+# wait for the ICP reverse scan to invalidate

+set DEBUG_SYNC = 'now WAIT_FOR hit1';

+

+# lets release and clean up

+set DEBUG_SYNC = 'now SIGNAL done1';

+

+connection conn1;

+reap;

+

+# set up the DEBUG_SYNC point again, but for the out of range

+set DEBUG_SYNC = 'tokudb_icp_asc_scan_out_of_range SIGNAL hit2 WAIT_FOR done2';

+

+# send the query

+send SELECT c FROM t1 WHERE id BETWEEN 5 AND 8 ORDER BY id ASC;

+

+# back to default connection

+connection default;

+

+# wait for the ICP reverse scan to invalidate

+set DEBUG_SYNC = 'now WAIT_FOR hit2';

+

+# lets release and clean up

+set DEBUG_SYNC = 'now SIGNAL done2';

+

+connection conn1;

+reap;

+

+connection default;

+disconnect conn1;

+drop table t1;

+select locks_dname,locks_key_left,locks_key_right from information_schema.tokudb_locks order by locks_dname,locks_key_left,locks_key_right;

+select locks_dname,locks_key_left,locks_key_right from information_schema.tokudb_locks order by locks_dname,locks_key_left,locks_key_right;

+drop table t1_audit;

+select locks_dname,locks_key_left,locks_key_right from information_schema.tokudb_locks order by locks_dname,locks_key_left,locks_key_right;

+select locks_dname,locks_key_left,locks_key_right from information_schema.tokudb_locks order by locks_dname,locks_key_left,locks_key_right;

+drop table t1_audit;

+select locks_dname,locks_key_left,locks_key_right from information_schema.tokudb_locks order by locks_dname,locks_key_left,locks_key_right;

+select locks_dname,locks_key_left,locks_key_right from information_schema.tokudb_locks order by locks_dname,locks_key_left,locks_key_right;

+source include/have_tokudb.inc;

+set default_storage_engine='tokudb';

+disable_warnings;

+drop table if exists t1;

+enable_warnings;

+

+set session tokudb_auto_analyze = 1;

+set session tokudb_analyze_in_background = true;

+set session tokudb_analyze_mode = TOKUDB_ANALYZE_STANDARD;

+set session tokudb_analyze_throttle = 0;

+set session tokudb_analyze_time = 0;

+

+create table t1(a int, b text(1), c text(1), filler text(1), primary key(a, b(1)), unique key (a, c(1)));

+lock tables t1 write, t1 as a read, t1 as b read;

+insert into t1(a) values(1);

+alter table t1 drop key a;

+unlock tables;

+

+# wait for the bjm queue to empty

+-- disable_query_log

+let $wait_condition=select count(*)=0 from information_schema.tokudb_background_job_status;

+-- source include/wait_condition.inc

+

+drop table t1;

+include/master-slave.inc

+Warnings:

+Note #### Sending passwords in plain text without SSL/TLS is extremely insecure.

+Note #### Storing MySQL user name or password information in the master info repository is not secure and is therefore not recommended. Please consider using the USER and PASSWORD connection options for START SLAVE; see the 'START SLAVE Syntax' in the MySQL Manual for more information.

+[connection master]

+call mtr.add_suppression("read free replication is disabled for tokudb table");

+CREATE TABLE t (a int(11), b char(20)) ENGINE = TokuDB;

+INSERT INTO t (a, b) VALUES (1, 'a'), (2, 'b'), (3, 'c'), (4, 'd'), (5, 'e');

+SELECT * FROM t;

+a b

+1 a

+2 b

+3 c

+4 d

+5 e

+UPDATE t SET a = a + 10 WHERE b = 'b';

+SELECT * FROM t;

+a b

+1 a

+12 b

+3 c

+4 d

+5 e

+SELECT * FROM t;

+a b

+1 a

+12 b

+3 c

+4 d

+5 e

+UPDATE t SET a = a + 10 WHERE b = 'b';

+SELECT * FROM t;

+a b

+1 a

+22 b

+3 c

+4 d

+5 e

+SELECT * FROM t;

+a b

+1 a

+22 b

+3 c

+4 d

+5 e

+DROP TABLE t;

+include/rpl_end.inc

+Warnings:

+Warning 131 Using tokudb_pk_insert_mode is deprecated and the parameter may be removed in future releases.

+--read-only=true --tokudb-rpl-unique-checks=false --tokudb-rpl-lookup-rows=false

+# Test case for bug#1536663

+#

+# When read-free-replication is enabled for tokudb and there is no explicit

+# pk for replicated table there can be dublicated records in the table on

+# update operation.

+#

+# Consider this update operation:

+# UPDATE t SET a = a + 10 WHERE b = 'b';

+# The master does rows lookup and updates the rows which values correspond to

+# the condition. The update events are written to binary log with

+# rows values from the master. As rows lookup is forbidden for slave

+# the new rows are added instead of updating corresponding rows.

+#

+# Without the fix there will be several rows with b = 'b' in the table on slave

+# instead of one updated row.

+#

+

+--source include/have_tokudb.inc

+--source include/have_binlog_format_row.inc

+--source include/master-slave.inc

+

+call mtr.add_suppression("read free replication is disabled for tokudb table");

+

+--connection master

+CREATE TABLE t (a int(11), b char(20)) ENGINE = TokuDB;

+INSERT INTO t (a, b) VALUES (1, 'a'), (2, 'b'), (3, 'c'), (4, 'd'), (5, 'e');

+

+--sync_slave_with_master

+--sorted_result

+SELECT * FROM t;

+

+--let $i = 2

+--while($i) {

+ --dec $i

+ --connection master

+ UPDATE t SET a = a + 10 WHERE b = 'b';

+ --sorted_result

+ SELECT * FROM t;

+ --sync_slave_with_master

+ --sorted_result

+ SELECT * FROM t;

+}

+

+--connection master

+DROP TABLE t;

+--sync_slave_with_master

+

+--source include/rpl_end.inc

+SET @orig_global = @@global.tokudb_pk_insert_mode;

+SELECT @orig_global;

+@orig_global

+1

+SET @orig_session = @@session.tokudb_pk_insert_mode;

+SELECT @orig_session;

+@orig_session

+1

+SET GLOBAL tokudb_pk_insert_mode = 10;

+Warnings:

+Warning 1292 Truncated incorrect tokudb_pk_insert_mode value: '10'

+Warning 131 Using tokudb_pk_insert_mode is deprecated and the parameter may be removed in future releases.

+SELECT @@global.tokudb_pk_insert_mode;

+@@global.tokudb_pk_insert_mode

+2

+SET GLOBAL tokudb_pk_insert_mode = 0;

+Warnings:

+Warning 131 Using tokudb_pk_insert_mode=0 is deprecated and the parameter may be removed in future releases. Only tokudb_pk_insert_mode=1|2 is allowed.Resettig the value to 1.

+SELECT @@global.tokudb_pk_insert_mode;

+@@global.tokudb_pk_insert_mode

+1

+SET GLOBAL tokudb_pk_insert_mode = DEFAULT;

+Warnings:

+Warning 131 Using tokudb_pk_insert_mode is deprecated and the parameter may be removed in future releases.

+SELECT @@global.tokudb_pk_insert_mode;

+@@global.tokudb_pk_insert_mode

+1

+SET GLOBAL tokudb_pk_insert_mode = 'foobar';

+ERROR 42000: Incorrect argument type to variable 'tokudb_pk_insert_mode'

+SELECT @@global.tokudb_pk_insert_mode;

+@@global.tokudb_pk_insert_mode

+1

+SET SESSION tokudb_pk_insert_mode = 10;

+Warnings:

+Warning 1292 Truncated incorrect tokudb_pk_insert_mode value: '10'

+Warning 131 Using tokudb_pk_insert_mode is deprecated and the parameter may be removed in future releases.

+SELECT @@session.tokudb_pk_insert_mode;

+@@session.tokudb_pk_insert_mode

+2

+SET SESSION tokudb_pk_insert_mode = 0;

+Warnings:

+Warning 131 Using tokudb_pk_insert_mode=0 is deprecated and the parameter may be removed in future releases. Only tokudb_pk_insert_mode=1|2 is allowed.Resettig the value to 1.

+SELECT @@session.tokudb_pk_insert_mode;

+@@session.tokudb_pk_insert_mode

+1

+SET SESSION tokudb_pk_insert_mode = DEFAULT;

+Warnings:

+Warning 131 Using tokudb_pk_insert_mode is deprecated and the parameter may be removed in future releases.

+SELECT @@session.tokudb_pk_insert_mode;

+@@session.tokudb_pk_insert_mode

+1

+SET SESSION tokudb_pk_insert_mode = 'foobar';

+ERROR 42000: Incorrect argument type to variable 'tokudb_pk_insert_mode'

+SELECT @@session.tokudb_pk_insert_mode;

+@@session.tokudb_pk_insert_mode

+1

+SET GLOBAL tokudb_pk_insert_mode = 12;

+Warnings:

+Warning 1292 Truncated incorrect tokudb_pk_insert_mode value: '12'

+Warning 131 Using tokudb_pk_insert_mode is deprecated and the parameter may be removed in future releases.

+SET SESSION tokudb_pk_insert_mode = 13;

+Warnings:

+Warning 1292 Truncated incorrect tokudb_pk_insert_mode value: '13'

+Warning 131 Using tokudb_pk_insert_mode is deprecated and the parameter may be removed in future releases.

+SELECT @@global.tokudb_pk_insert_mode;

+@@global.tokudb_pk_insert_mode

+2

+SELECT @@session.tokudb_pk_insert_mode;

+@@session.tokudb_pk_insert_mode

+2

+SHOW VARIABLES LIKE 'tokudb_pk_insert_mode';

+Variable_name Value

+tokudb_pk_insert_mode 2

+SET SESSION tokudb_pk_insert_mode = @orig_session;

+Warnings:

+Warning 131 Using tokudb_pk_insert_mode is deprecated and the parameter may be removed in future releases.

+SELECT @@session.tokudb_pk_insert_mode;

+@@session.tokudb_pk_insert_mode

+1

+SET GLOBAL tokudb_pk_insert_mode = @orig_global;

+Warnings:

+Warning 131 Using tokudb_pk_insert_mode is deprecated and the parameter may be removed in future releases.

+SELECT @@global.tokudb_pk_insert_mode;

+@@global.tokudb_pk_insert_mode

+1

+--source include/have_tokudb.inc

+--enable_warnings

+

+# Check the default value

+SET @orig_global = @@global.tokudb_pk_insert_mode;

+SELECT @orig_global;

+

+SET @orig_session = @@session.tokudb_pk_insert_mode;

+SELECT @orig_session;

+

+# Test global

+SET GLOBAL tokudb_pk_insert_mode = 10;

+SELECT @@global.tokudb_pk_insert_mode;

+

+SET GLOBAL tokudb_pk_insert_mode = 0;

+SELECT @@global.tokudb_pk_insert_mode;

+

+SET GLOBAL tokudb_pk_insert_mode = DEFAULT;

+SELECT @@global.tokudb_pk_insert_mode;

+

+-- error ER_WRONG_TYPE_FOR_VAR

+SET GLOBAL tokudb_pk_insert_mode = 'foobar';

+SELECT @@global.tokudb_pk_insert_mode;

+

+# Test session

+SET SESSION tokudb_pk_insert_mode = 10;

+SELECT @@session.tokudb_pk_insert_mode;

+

+SET SESSION tokudb_pk_insert_mode = 0;

+SELECT @@session.tokudb_pk_insert_mode;

+

+SET SESSION tokudb_pk_insert_mode = DEFAULT;

+SELECT @@session.tokudb_pk_insert_mode;

+

+-- error ER_WRONG_TYPE_FOR_VAR

+SET SESSION tokudb_pk_insert_mode = 'foobar';

+SELECT @@session.tokudb_pk_insert_mode;

+

+# both

+SET GLOBAL tokudb_pk_insert_mode = 12;

+SET SESSION tokudb_pk_insert_mode = 13;

+SELECT @@global.tokudb_pk_insert_mode;

+SELECT @@session.tokudb_pk_insert_mode;

+SHOW VARIABLES LIKE 'tokudb_pk_insert_mode';

+

+# Clean up

+SET SESSION tokudb_pk_insert_mode = @orig_session;

+SELECT @@session.tokudb_pk_insert_mode;

+

+SET GLOBAL tokudb_pk_insert_mode = @orig_global;

+SELECT @@global.tokudb_pk_insert_mode;

+static const char* deprecated_tokudb_pk_insert_mode =

+ "Using tokudb_pk_insert_mode is deprecated and the "

+ "parameter may be removed in future releases.";

+static const char* deprecated_tokudb_pk_insert_mode_zero =

+ "Using tokudb_pk_insert_mode=0 is deprecated and the "

+ "parameter may be removed in future releases. "

+ "Only tokudb_pk_insert_mode=1|2 is allowed."

+ "Resettig the value to 1.";

+

+static void pk_insert_mode_update(

+ THD* thd,

+ st_mysql_sys_var* var,

+ void* var_ptr,

+ const void* save) {

+ const uint* new_pk_insert_mode = static_cast<const uint*>(save);

+ uint* pk_insert_mode = static_cast<uint*>(var_ptr);

+ if (*new_pk_insert_mode == 0) {

+ push_warning(

+ thd,

+ Sql_condition::WARN_LEVEL_WARN,

+ HA_ERR_WRONG_COMMAND,

+ deprecated_tokudb_pk_insert_mode_zero);

+ *pk_insert_mode = 1;

+ } else {

+ push_warning(

+ thd,

+ Sql_condition::WARN_LEVEL_WARN,

+ HA_ERR_WRONG_COMMAND,

+ deprecated_tokudb_pk_insert_mode);

+ *pk_insert_mode = *new_pk_insert_mode;

+ }

+}

+

+ pk_insert_mode_update,

+void set_pk_insert_mode(THD* thd, uint mode) {

+ THDVAR(thd, pk_insert_mode) = mode;

+}

+void set_pk_insert_mode(THD* thd, uint mode);

+#if (defined(__MACH__) || defined(__APPLE__)) && _POSIX_TIMERS <= 0

+

+#define _x_min(a, b) ((a) < (b) ? (a) : (b))

+

+#define timed_lock_define(timed_func_name, lock_type_name, lock_func_name) \

+inline int timed_func_name(lock_type_name *mutex, \

+ const struct timespec *abs_timeout) { \

+ int pthread_rc; \

+ struct timespec remaining, slept, ts; \

+ static const int sleep_step = 1000000; \

+ \

+ remaining = *abs_timeout; \

+ while ((pthread_rc = lock_func_name(mutex)) == EBUSY) { \

+ ts.tv_sec = 0; \

+ ts.tv_nsec = (remaining.tv_sec > 0 ? \

+ sleep_step : \

+ _x_min(remaining.tv_nsec,sleep_step)); \

+ nanosleep(&ts, &slept); \

+ ts.tv_nsec -= slept.tv_nsec; \

+ if (ts.tv_nsec <= remaining.tv_nsec) { \

+ remaining.tv_nsec -= ts.tv_nsec; \

+ } else { \

+ remaining.tv_sec--; \

+ remaining.tv_nsec = \

+ (sleep_step - (ts.tv_nsec - remaining.tv_nsec)); \

+ } \

+ if (remaining.tv_sec < 0 || \

+ (!remaining.tv_sec && remaining.tv_nsec <= 0)) { \

+ return ETIMEDOUT; \

+ } \

+ } \

+ \

+ return pthread_rc; \

+}

+

+timed_lock_define(pthread_mutex_timedlock,

+ pthread_mutex_t,

+ pthread_mutex_trylock);

+

+timed_lock_define(pthread_rwlock_timedrdlock,

+ pthread_rwlock_t,

+ pthread_rwlock_tryrdlock);

+

+timed_lock_define(pthread_rwlock_timedwrlock,

+ pthread_rwlock_t,

+ pthread_rwlock_trywrlock);

+

+#endif //(defined(__MACH__) || defined(__APPLE__)) && _POSIX_TIMERS <= 0

+