Merge pchardin@bk-internal.mysql.com:/home/bk/mysql-5.1-new
into mysql.com:/home/cps/mysql/devel/5.1-repair-csv
This commit is contained in:
commit
36e06f6372
@ -21,7 +21,6 @@ sub run_stress_test ()
|
|||||||
{
|
{
|
||||||
|
|
||||||
my $args;
|
my $args;
|
||||||
my $stress_basedir;
|
|
||||||
my $stress_suitedir;
|
my $stress_suitedir;
|
||||||
|
|
||||||
mtr_report("Starting stress testing\n");
|
mtr_report("Starting stress testing\n");
|
||||||
|
@ -166,7 +166,6 @@ our $path_my_basedir;
|
|||||||
our $opt_vardir; # A path but set directly on cmd line
|
our $opt_vardir; # A path but set directly on cmd line
|
||||||
our $opt_vardir_trace; # unix formatted opt_vardir for trace files
|
our $opt_vardir_trace; # unix formatted opt_vardir for trace files
|
||||||
our $opt_tmpdir; # A path but set directly on cmd line
|
our $opt_tmpdir; # A path but set directly on cmd line
|
||||||
our $opt_restart_cleanup; # Source a file with SQL drop statements
|
|
||||||
|
|
||||||
our $opt_usage;
|
our $opt_usage;
|
||||||
our $opt_suite;
|
our $opt_suite;
|
||||||
@ -588,16 +587,18 @@ sub command_line_setup () {
|
|||||||
'with-ndbcluster-only' => \$opt_with_ndbcluster_only,
|
'with-ndbcluster-only' => \$opt_with_ndbcluster_only,
|
||||||
'ndb-extra-test' => \$opt_ndb_extra_test,
|
'ndb-extra-test' => \$opt_ndb_extra_test,
|
||||||
'do-test=s' => \$opt_do_test,
|
'do-test=s' => \$opt_do_test,
|
||||||
|
'start-from=s' => \$opt_start_from,
|
||||||
'suite=s' => \$opt_suite,
|
'suite=s' => \$opt_suite,
|
||||||
'skip-rpl' => \$opt_skip_rpl,
|
'skip-rpl' => \$opt_skip_rpl,
|
||||||
'skip-im' => \$opt_skip_im,
|
'skip-im' => \$opt_skip_im,
|
||||||
'skip-test=s' => \$opt_skip_test,
|
'skip-test=s' => \$opt_skip_test,
|
||||||
|
'big-test' => \$opt_big_test,
|
||||||
|
|
||||||
# Specify ports
|
# Specify ports
|
||||||
'master_port=i' => \$opt_master_myport,
|
'master_port=i' => \$opt_master_myport,
|
||||||
'slave_port=i' => \$opt_slave_myport,
|
'slave_port=i' => \$opt_slave_myport,
|
||||||
'ndbcluster_port=i' => \$opt_ndbcluster_port,
|
'ndbcluster-port=i' => \$opt_ndbcluster_port,
|
||||||
'ndbcluster_port_slave=i' => \$opt_ndbcluster_port_slave,
|
'ndbcluster-port-slave=i' => \$opt_ndbcluster_port_slave,
|
||||||
'manager-port=i' => \$opt_manager_port, # Currently not used
|
'manager-port=i' => \$opt_manager_port, # Currently not used
|
||||||
'im-port=i' => \$im_port, # Instance Manager port.
|
'im-port=i' => \$im_port, # Instance Manager port.
|
||||||
'im-mysqld1-port=i' => \$im_mysqld1_port, # Port of mysqld, controlled by IM
|
'im-mysqld1-port=i' => \$im_mysqld1_port, # Port of mysqld, controlled by IM
|
||||||
@ -607,13 +608,13 @@ sub command_line_setup () {
|
|||||||
'record' => \$opt_record,
|
'record' => \$opt_record,
|
||||||
'check-testcases' => \$opt_check_testcases,
|
'check-testcases' => \$opt_check_testcases,
|
||||||
|
|
||||||
# ???
|
# Extra options used when starting mysqld
|
||||||
'mysqld=s' => \@opt_extra_mysqld_opt,
|
'mysqld=s' => \@opt_extra_mysqld_opt,
|
||||||
|
|
||||||
# Run test on running server
|
# Run test on running server
|
||||||
'extern' => \$opt_extern,
|
'extern' => \$opt_extern,
|
||||||
'ndbconnectstring=s' => \$opt_ndbconnectstring,
|
'ndb-connectstring=s' => \$opt_ndbconnectstring,
|
||||||
'ndbconnectstring-slave=s' => \$opt_ndbconnectstring_slave,
|
'ndb-connectstring-slave=s' => \$opt_ndbconnectstring_slave,
|
||||||
|
|
||||||
# Debugging
|
# Debugging
|
||||||
'gdb' => \$opt_gdb,
|
'gdb' => \$opt_gdb,
|
||||||
@ -652,7 +653,6 @@ sub command_line_setup () {
|
|||||||
'vardir=s' => \$opt_vardir,
|
'vardir=s' => \$opt_vardir,
|
||||||
|
|
||||||
# Misc
|
# Misc
|
||||||
'big-test' => \$opt_big_test,
|
|
||||||
'comment=s' => \$opt_comment,
|
'comment=s' => \$opt_comment,
|
||||||
'debug' => \$opt_debug,
|
'debug' => \$opt_debug,
|
||||||
'fast' => \$opt_fast,
|
'fast' => \$opt_fast,
|
||||||
@ -661,13 +661,11 @@ sub command_line_setup () {
|
|||||||
'netware' => \$opt_netware,
|
'netware' => \$opt_netware,
|
||||||
'old-master' => \$opt_old_master,
|
'old-master' => \$opt_old_master,
|
||||||
'reorder' => \$opt_reorder,
|
'reorder' => \$opt_reorder,
|
||||||
'restart-cleanup' => \$opt_restart_cleanup,
|
|
||||||
'script-debug' => \$opt_script_debug,
|
'script-debug' => \$opt_script_debug,
|
||||||
'sleep=i' => \$opt_sleep,
|
'sleep=i' => \$opt_sleep,
|
||||||
'socket=s' => \$opt_socket,
|
'socket=s' => \$opt_socket,
|
||||||
'start-dirty' => \$opt_start_dirty,
|
'start-dirty' => \$opt_start_dirty,
|
||||||
'start-and-exit' => \$opt_start_and_exit,
|
'start-and-exit' => \$opt_start_and_exit,
|
||||||
'start-from=s' => \$opt_start_from,
|
|
||||||
'timer' => \$opt_timer,
|
'timer' => \$opt_timer,
|
||||||
'unified-diff|udiff' => \$opt_udiff,
|
'unified-diff|udiff' => \$opt_udiff,
|
||||||
'user-test=s' => \$opt_user_test,
|
'user-test=s' => \$opt_user_test,
|
||||||
@ -3260,12 +3258,6 @@ sub run_mysqltest ($) {
|
|||||||
mtr_add_arg($args, "--sleep=%d", $opt_sleep);
|
mtr_add_arg($args, "--sleep=%d", $opt_sleep);
|
||||||
}
|
}
|
||||||
|
|
||||||
if ( $opt_restart_cleanup and $glob_mysqld_restart )
|
|
||||||
{
|
|
||||||
mtr_add_arg($args, "--include=%s", "include/drop-on-restart.inc");
|
|
||||||
$glob_mysqld_restart= 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
if ( $opt_debug )
|
if ( $opt_debug )
|
||||||
{
|
{
|
||||||
mtr_add_arg($args, "--debug=d:t:A,%s/log/mysqltest.trace", $opt_vardir_trace);
|
mtr_add_arg($args, "--debug=d:t:A,%s/log/mysqltest.trace", $opt_vardir_trace);
|
||||||
@ -3561,12 +3553,15 @@ Options to control what test suites or cases to run
|
|||||||
skip-rpl Skip the replication test cases.
|
skip-rpl Skip the replication test cases.
|
||||||
skip-im Don't start IM, and skip the IM test cases
|
skip-im Don't start IM, and skip the IM test cases
|
||||||
skip-test=PREFIX Skip test cases which name are prefixed with PREFIX
|
skip-test=PREFIX Skip test cases which name are prefixed with PREFIX
|
||||||
|
big-test Pass "--big-test" to mysqltest which will set the environment
|
||||||
|
variable BIG_TEST, which can be checked from test cases.
|
||||||
|
|
||||||
Options that specify ports
|
Options that specify ports
|
||||||
|
|
||||||
master_port=PORT Specify the port number used by the first master
|
master_port=PORT Specify the port number used by the first master
|
||||||
slave_port=PORT Specify the port number used by the first slave
|
slave_port=PORT Specify the port number used by the first slave
|
||||||
ndbcluster_port=PORT Specify the port number used by cluster
|
ndbcluster-port=PORT Specify the port number used by cluster
|
||||||
|
ndbcluster-port-slave=PORT Specify the port number used by slave cluster
|
||||||
|
|
||||||
Options for test case authoring
|
Options for test case authoring
|
||||||
|
|
||||||
@ -3620,16 +3615,14 @@ Misc options
|
|||||||
help Get this help text
|
help Get this help text
|
||||||
unified-diff | udiff When presenting differences, use unified diff
|
unified-diff | udiff When presenting differences, use unified diff
|
||||||
|
|
||||||
testcase-timeout=MINUTES Max test case run time (default 5)
|
testcase-timeout=MINUTES Max test case run time (default $default_testcase_timeout)
|
||||||
suite-timeout=MINUTES Max test suite run time (default 120)
|
suite-timeout=MINUTES Max test suite run time (default $default_suite_timeout)
|
||||||
|
|
||||||
Deprecated options
|
Deprecated options
|
||||||
with-openssl Deprecated option for ssl
|
with-openssl Deprecated option for ssl
|
||||||
|
|
||||||
|
|
||||||
Options not yet described, or that I want to look into more
|
Options not yet described, or that I want to look into more
|
||||||
|
|
||||||
big-test
|
|
||||||
debug
|
debug
|
||||||
local
|
local
|
||||||
local-master
|
local-master
|
||||||
|
@ -524,7 +524,6 @@ THR_LOCK_DATA **ha_heap::store_lock(THD *thd,
|
|||||||
|
|
||||||
int ha_heap::delete_table(const char *name)
|
int ha_heap::delete_table(const char *name)
|
||||||
{
|
{
|
||||||
char buff[FN_REFLEN];
|
|
||||||
int error= heap_delete_table(name);
|
int error= heap_delete_table(name);
|
||||||
return error == ENOENT ? 0 : error;
|
return error == ENOENT ? 0 : error;
|
||||||
}
|
}
|
||||||
|
@ -3397,6 +3397,7 @@ int ha_ndbcluster::rnd_pos(byte *buf, byte *pos)
|
|||||||
The partition id has been fetched from ndb
|
The partition id has been fetched from ndb
|
||||||
and has been stored directly after the hidden key
|
and has been stored directly after the hidden key
|
||||||
*/
|
*/
|
||||||
|
DBUG_DUMP("key+part", (char *)pos, key_length);
|
||||||
key_length= ref_length - sizeof(m_part_id);
|
key_length= ref_length - sizeof(m_part_id);
|
||||||
part_spec.start_part= part_spec.end_part= *(pos + key_length);
|
part_spec.start_part= part_spec.end_part= *(pos + key_length);
|
||||||
}
|
}
|
||||||
@ -3413,6 +3414,7 @@ int ha_ndbcluster::rnd_pos(byte *buf, byte *pos)
|
|||||||
}
|
}
|
||||||
DBUG_PRINT("info", ("partition id %u", part_spec.start_part));
|
DBUG_PRINT("info", ("partition id %u", part_spec.start_part));
|
||||||
}
|
}
|
||||||
|
DBUG_DUMP("key", (char *)pos, key_length);
|
||||||
DBUG_RETURN(pk_read(pos, key_length, buf, part_spec.start_part));
|
DBUG_RETURN(pk_read(pos, key_length, buf, part_spec.start_part));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -3498,7 +3500,10 @@ void ha_ndbcluster::position(const byte *record)
|
|||||||
#endif
|
#endif
|
||||||
memcpy(ref, m_ref, key_length);
|
memcpy(ref, m_ref, key_length);
|
||||||
}
|
}
|
||||||
|
#ifndef DBUG_OFF
|
||||||
|
if (table_share->primary_key == MAX_KEY && m_use_partition_function)
|
||||||
|
DBUG_DUMP("key+part", (char*)ref, key_length+sizeof(m_part_id));
|
||||||
|
#endif
|
||||||
DBUG_DUMP("ref", (char*)ref, key_length);
|
DBUG_DUMP("ref", (char*)ref, key_length);
|
||||||
DBUG_VOID_RETURN;
|
DBUG_VOID_RETURN;
|
||||||
}
|
}
|
||||||
|
@ -445,8 +445,6 @@ static my_bool init_handlerton(THD *unused1, st_plugin_int *plugin,
|
|||||||
int ha_init()
|
int ha_init()
|
||||||
{
|
{
|
||||||
int error= 0;
|
int error= 0;
|
||||||
handlerton **types;
|
|
||||||
show_table_alias_st *table_alias;
|
|
||||||
total_ha= savepoint_alloc_size= 0;
|
total_ha= savepoint_alloc_size= 0;
|
||||||
|
|
||||||
if (ha_init_errors())
|
if (ha_init_errors())
|
||||||
|
@ -2028,7 +2028,6 @@ void Item_date_add_interval::fix_length_and_dec()
|
|||||||
|
|
||||||
bool Item_date_add_interval::get_date(TIME *ltime, uint fuzzy_date)
|
bool Item_date_add_interval::get_date(TIME *ltime, uint fuzzy_date)
|
||||||
{
|
{
|
||||||
long period,sign;
|
|
||||||
INTERVAL interval;
|
INTERVAL interval;
|
||||||
|
|
||||||
if (args[0]->get_date(ltime, TIME_NO_ZERO_DATE) ||
|
if (args[0]->get_date(ltime, TIME_NO_ZERO_DATE) ||
|
||||||
|
@ -468,7 +468,6 @@ int key_rec_cmp(void *key, byte *first_rec, byte *second_rec)
|
|||||||
do
|
do
|
||||||
{
|
{
|
||||||
Field *field= key_part->field;
|
Field *field= key_part->field;
|
||||||
uint length;
|
|
||||||
|
|
||||||
if (key_part->null_bit)
|
if (key_part->null_bit)
|
||||||
{
|
{
|
||||||
|
@ -717,8 +717,6 @@ bool LOGGER::slow_log_print(THD *thd, const char *query, uint query_length,
|
|||||||
bool error= FALSE;
|
bool error= FALSE;
|
||||||
Log_event_handler **current_handler= slow_log_handler_list;
|
Log_event_handler **current_handler= slow_log_handler_list;
|
||||||
bool is_command= FALSE;
|
bool is_command= FALSE;
|
||||||
|
|
||||||
char message_buff[MAX_LOG_BUFFER_SIZE];
|
|
||||||
char user_host_buff[MAX_USER_HOST_SIZE];
|
char user_host_buff[MAX_USER_HOST_SIZE];
|
||||||
|
|
||||||
my_time_t current_time;
|
my_time_t current_time;
|
||||||
|
@ -8183,6 +8183,7 @@ ulong srv_thread_sleep_delay;
|
|||||||
ulong srv_thread_concurrency;
|
ulong srv_thread_concurrency;
|
||||||
ulong srv_commit_concurrency;
|
ulong srv_commit_concurrency;
|
||||||
}
|
}
|
||||||
|
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#ifndef WITH_NDBCLUSTER_STORAGE_ENGINE
|
#ifndef WITH_NDBCLUSTER_STORAGE_ENGINE
|
||||||
|
@ -668,7 +668,6 @@ db_update_routine(THD *thd, int type, sp_name *name, st_sp_chistics *chistics)
|
|||||||
{
|
{
|
||||||
TABLE *table;
|
TABLE *table;
|
||||||
int ret;
|
int ret;
|
||||||
bool opened;
|
|
||||||
DBUG_ENTER("db_update_routine");
|
DBUG_ENTER("db_update_routine");
|
||||||
DBUG_PRINT("enter", ("type: %d name: %.*s",
|
DBUG_PRINT("enter", ("type: %d name: %.*s",
|
||||||
type, name->m_name.length, name->m_name.str));
|
type, name->m_name.length, name->m_name.str));
|
||||||
|
@ -124,7 +124,6 @@ void sp_cache_clear(sp_cache **cp)
|
|||||||
void sp_cache_insert(sp_cache **cp, sp_head *sp)
|
void sp_cache_insert(sp_cache **cp, sp_head *sp)
|
||||||
{
|
{
|
||||||
sp_cache *c;
|
sp_cache *c;
|
||||||
ulong v;
|
|
||||||
|
|
||||||
if (!(c= *cp))
|
if (!(c= *cp))
|
||||||
{
|
{
|
||||||
|
@ -1408,10 +1408,7 @@ void update_non_unique_table_error(TABLE_LIST *update,
|
|||||||
|
|
||||||
TABLE *find_temporary_table(THD *thd, const char *db, const char *table_name)
|
TABLE *find_temporary_table(THD *thd, const char *db, const char *table_name)
|
||||||
{
|
{
|
||||||
char key[MAX_DBKEY_LENGTH];
|
|
||||||
uint key_length;
|
|
||||||
TABLE_LIST table_list;
|
TABLE_LIST table_list;
|
||||||
TABLE *table;
|
|
||||||
|
|
||||||
table_list.db= (char*) db;
|
table_list.db= (char*) db;
|
||||||
table_list.table_name= (char*) table_name;
|
table_list.table_name= (char*) table_name;
|
||||||
@ -1939,7 +1936,6 @@ TABLE *open_table(THD *thd, TABLE_LIST *table_list, MEM_ROOT *mem_root,
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
TABLE_SHARE *share;
|
|
||||||
/* Free cache if too big */
|
/* Free cache if too big */
|
||||||
while (open_cache.records > table_cache_size && unused_tables)
|
while (open_cache.records > table_cache_size && unused_tables)
|
||||||
VOID(hash_delete(&open_cache,(byte*) unused_tables)); /* purecov: tested */
|
VOID(hash_delete(&open_cache,(byte*) unused_tables)); /* purecov: tested */
|
||||||
|
Loading…
x
Reference in New Issue
Block a user