Commit 8634f7e5 authored by Sergei Golubchik's avatar Sergei Golubchik

Merge branch '5.5' into 10.0

parents f16d4d4c b0fd06a6
...@@ -34,11 +34,6 @@ ENDMACRO() ...@@ -34,11 +34,6 @@ ENDMACRO()
MACRO (MYSQL_CHECK_ZLIB_WITH_COMPRESS) MACRO (MYSQL_CHECK_ZLIB_WITH_COMPRESS)
# For NDBCLUSTER: Use bundled zlib by default
IF (NOT WITH_ZLIB)
SET(WITH_ZLIB "bundled" CACHE STRING "By default use bundled zlib on this platform")
ENDIF()
IF(WITH_ZLIB STREQUAL "bundled") IF(WITH_ZLIB STREQUAL "bundled")
MYSQL_USE_BUNDLED_ZLIB() MYSQL_USE_BUNDLED_ZLIB()
ELSE() ELSE()
......
...@@ -163,11 +163,23 @@ flush privileges; ...@@ -163,11 +163,23 @@ flush privileges;
drop database mysqltest_db1; drop database mysqltest_db1;
set global read_only= @start_read_only; set global read_only= @start_read_only;
# #
# MDEV-16987 - ALTER DATABASE possible in read-only mode
#
GRANT ALTER ON test1.* TO user1@localhost;
CREATE DATABASE test1;
SET GLOBAL read_only=1;
ALTER DATABASE test1 CHARACTER SET utf8;
ERROR HY000: The MariaDB server is running with the --read-only option so it cannot execute this statement
SET GLOBAL read_only=0;
DROP DATABASE test1;
DROP USER user1@localhost;
USE test;
# End of 5.5 tests
#
# WL#5968 Implement START TRANSACTION READ (WRITE|ONLY); # WL#5968 Implement START TRANSACTION READ (WRITE|ONLY);
# #
# #
# Test interaction with read_only system variable. # Test interaction with read_only system variable.
DROP TABLE IF EXISTS t1;
CREATE TABLE t1(a INT); CREATE TABLE t1(a INT);
INSERT INTO t1 VALUES (1), (2); INSERT INTO t1 VALUES (1), (2);
CREATE USER user1; CREATE USER user1;
...@@ -199,3 +211,4 @@ COMMIT; ...@@ -199,3 +211,4 @@ COMMIT;
DROP USER user1; DROP USER user1;
SET GLOBAL read_only= 0; SET GLOBAL read_only= 0;
DROP TABLE t1; DROP TABLE t1;
# End of 10.0 tests
...@@ -307,6 +307,22 @@ flush privileges; ...@@ -307,6 +307,22 @@ flush privileges;
drop database mysqltest_db1; drop database mysqltest_db1;
set global read_only= @start_read_only; set global read_only= @start_read_only;
--echo #
--echo # MDEV-16987 - ALTER DATABASE possible in read-only mode
--echo #
GRANT ALTER ON test1.* TO user1@localhost;
CREATE DATABASE test1;
SET GLOBAL read_only=1;
change_user user1;
--error ER_OPTION_PREVENTS_STATEMENT
ALTER DATABASE test1 CHARACTER SET utf8;
change_user root;
SET GLOBAL read_only=0;
DROP DATABASE test1;
DROP USER user1@localhost;
USE test;
--echo # End of 5.5 tests
--echo # --echo #
--echo # WL#5968 Implement START TRANSACTION READ (WRITE|ONLY); --echo # WL#5968 Implement START TRANSACTION READ (WRITE|ONLY);
...@@ -315,10 +331,6 @@ set global read_only= @start_read_only; ...@@ -315,10 +331,6 @@ set global read_only= @start_read_only;
--echo # --echo #
--echo # Test interaction with read_only system variable. --echo # Test interaction with read_only system variable.
--disable_warnings
DROP TABLE IF EXISTS t1;
--enable_warnings
CREATE TABLE t1(a INT); CREATE TABLE t1(a INT);
INSERT INTO t1 VALUES (1), (2); INSERT INTO t1 VALUES (1), (2);
...@@ -369,3 +381,4 @@ DROP TABLE t1; ...@@ -369,3 +381,4 @@ DROP TABLE t1;
# Wait till all disconnects are completed # Wait till all disconnects are completed
--source include/wait_until_count_sessions.inc --source include/wait_until_count_sessions.inc
--echo # End of 10.0 tests
...@@ -1045,6 +1045,7 @@ static bool deny_updates_if_read_only_option(THD *thd, TABLE_LIST *all_tables) ...@@ -1045,6 +1045,7 @@ static bool deny_updates_if_read_only_option(THD *thd, TABLE_LIST *all_tables)
DBUG_RETURN(FALSE); DBUG_RETURN(FALSE);
if (lex->sql_command == SQLCOM_CREATE_DB || if (lex->sql_command == SQLCOM_CREATE_DB ||
lex->sql_command == SQLCOM_ALTER_DB ||
lex->sql_command == SQLCOM_DROP_DB) lex->sql_command == SQLCOM_DROP_DB)
DBUG_RETURN(TRUE); DBUG_RETURN(TRUE);
......
...@@ -48,9 +48,6 @@ pthread_handler_t test_lf_pinbox(void *arg) ...@@ -48,9 +48,6 @@ pthread_handler_t test_lf_pinbox(void *arg)
pins= lf_pinbox_get_pins(&lf_allocator.pinbox); pins= lf_pinbox_get_pins(&lf_allocator.pinbox);
} }
lf_pinbox_put_pins(pins); lf_pinbox_put_pins(pins);
pthread_mutex_lock(&mutex);
if (!--running_threads) pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex);
if (with_my_thread_init) if (with_my_thread_init)
my_thread_end(); my_thread_end();
...@@ -105,7 +102,6 @@ pthread_handler_t test_lf_alloc(void *arg) ...@@ -105,7 +102,6 @@ pthread_handler_t test_lf_alloc(void *arg)
bad|= lf_allocator.mallocs - lf_alloc_pool_count(&lf_allocator); bad|= lf_allocator.mallocs - lf_alloc_pool_count(&lf_allocator);
#endif #endif
} }
if (!--running_threads) pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex); pthread_mutex_unlock(&mutex);
if (with_my_thread_init) if (with_my_thread_init)
...@@ -159,7 +155,6 @@ pthread_handler_t test_lf_hash(void *arg) ...@@ -159,7 +155,6 @@ pthread_handler_t test_lf_hash(void *arg)
lf_hash.size, inserts); lf_hash.size, inserts);
bad|= lf_hash.count; bad|= lf_hash.count;
} }
if (!--running_threads) pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex); pthread_mutex_unlock(&mutex);
if (with_my_thread_init) if (with_my_thread_init)
my_thread_end(); my_thread_end();
......
...@@ -35,9 +35,6 @@ pthread_handler_t test_atomic_add(void *arg) ...@@ -35,9 +35,6 @@ pthread_handler_t test_atomic_add(void *arg)
my_atomic_add32(&bad, -x); my_atomic_add32(&bad, -x);
my_atomic_rwlock_wrunlock(&rwl); my_atomic_rwlock_wrunlock(&rwl);
} }
pthread_mutex_lock(&mutex);
if (!--running_threads) pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex);
return 0; return 0;
} }
...@@ -58,13 +55,6 @@ pthread_handler_t test_atomic_add64(void *arg) ...@@ -58,13 +55,6 @@ pthread_handler_t test_atomic_add64(void *arg)
my_atomic_add64(&a64, -x); my_atomic_add64(&a64, -x);
my_atomic_rwlock_wrunlock(&rwl); my_atomic_rwlock_wrunlock(&rwl);
} }
pthread_mutex_lock(&mutex);
if (!--running_threads)
{
bad= (a64 != 0);
pthread_cond_signal(&cond);
}
pthread_mutex_unlock(&mutex);
return 0; return 0;
} }
...@@ -108,9 +98,6 @@ pthread_handler_t test_atomic_fas(void *arg) ...@@ -108,9 +98,6 @@ pthread_handler_t test_atomic_fas(void *arg)
my_atomic_add32(&bad, -x); my_atomic_add32(&bad, -x);
my_atomic_rwlock_wrunlock(&rwl); my_atomic_rwlock_wrunlock(&rwl);
pthread_mutex_lock(&mutex);
if (!--running_threads) pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex);
return 0; return 0;
} }
...@@ -140,9 +127,6 @@ pthread_handler_t test_atomic_cas(void *arg) ...@@ -140,9 +127,6 @@ pthread_handler_t test_atomic_cas(void *arg)
my_atomic_rwlock_wrunlock(&rwl); my_atomic_rwlock_wrunlock(&rwl);
} while (!ok) ; } while (!ok) ;
} }
pthread_mutex_lock(&mutex);
if (!--running_threads) pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex);
return 0; return 0;
} }
...@@ -178,6 +162,7 @@ void do_tests() ...@@ -178,6 +162,7 @@ void do_tests()
} }
a64=0; a64=0;
test_concurrently("my_atomic_add64", test_atomic_add64, THREADS, CYCLES); test_concurrently("my_atomic_add64", test_atomic_add64, THREADS, CYCLES);
bad= (a64 != 0);
my_atomic_rwlock_destroy(&rwl); my_atomic_rwlock_destroy(&rwl);
} }
...@@ -20,35 +20,34 @@ ...@@ -20,35 +20,34 @@
#include <tap.h> #include <tap.h>
volatile uint32 bad; volatile uint32 bad;
pthread_attr_t thr_attr;
pthread_mutex_t mutex; pthread_mutex_t mutex;
pthread_cond_t cond;
uint running_threads;
void do_tests(); void do_tests();
void test_concurrently(const char *test, pthread_handler handler, int n, int m) void test_concurrently(const char *test, pthread_handler handler, int n, int m)
{ {
pthread_t t; pthread_t *threads= malloc(n * sizeof(pthread_t));
int i;
ulonglong now= my_interval_timer(); ulonglong now= my_interval_timer();
assert(threads);
bad= 0; bad= 0;
diag("Testing %s with %d threads, %d iterations... ", test, n, m); diag("Testing %s with %d threads, %d iterations... ", test, n, m);
for (running_threads= n ; n ; n--) for (i= n; i; i--)
{ {
if (pthread_create(&t, &thr_attr, handler, &m) != 0) if (pthread_create(&threads[i], 0, handler, &m) != 0)
{ {
diag("Could not create thread"); diag("Could not create thread");
abort(); abort();
} }
} }
pthread_mutex_lock(&mutex);
while (running_threads) for (i= n; i; i--)
pthread_cond_wait(&cond, &mutex); pthread_join(threads[i], 0);
pthread_mutex_unlock(&mutex);
now= my_interval_timer() - now; now= my_interval_timer() - now;
free(threads);
ok(!bad, "tested %s in %g secs (%d)", test, ((double)now)/1e9, bad); ok(!bad, "tested %s in %g secs (%d)", test, ((double)now)/1e9, bad);
} }
...@@ -60,9 +59,6 @@ int main(int argc __attribute__((unused)), char **argv) ...@@ -60,9 +59,6 @@ int main(int argc __attribute__((unused)), char **argv)
DBUG_SET_INITIAL(argv[1]); DBUG_SET_INITIAL(argv[1]);
pthread_mutex_init(&mutex, 0); pthread_mutex_init(&mutex, 0);
pthread_cond_init(&cond, 0);
pthread_attr_init(&thr_attr);
pthread_attr_setdetachstate(&thr_attr,PTHREAD_CREATE_DETACHED);
#ifdef MY_ATOMIC_MODE_RWLOCKS #ifdef MY_ATOMIC_MODE_RWLOCKS
#if defined(HPUX11) || defined(__POWERPC__) /* showed to be very slow (scheduler-related) */ #if defined(HPUX11) || defined(__POWERPC__) /* showed to be very slow (scheduler-related) */
...@@ -79,16 +75,7 @@ int main(int argc __attribute__((unused)), char **argv) ...@@ -79,16 +75,7 @@ int main(int argc __attribute__((unused)), char **argv)
do_tests(); do_tests();
/*
workaround until we know why it crashes randomly on some machine
(BUG#22320).
*/
#ifdef NOT_USED
sleep(2);
#endif
pthread_mutex_destroy(&mutex); pthread_mutex_destroy(&mutex);
pthread_cond_destroy(&cond);
pthread_attr_destroy(&thr_attr);
my_end(0); my_end(0);
return exit_status(); return exit_status();
} }
......
...@@ -136,10 +136,8 @@ pthread_handler_t test_wt(void *arg) ...@@ -136,10 +136,8 @@ pthread_handler_t test_wt(void *arg)
pthread_mutex_unlock(&lock); pthread_mutex_unlock(&lock);
pthread_mutex_unlock(& thds[id].lock); pthread_mutex_unlock(& thds[id].lock);
wt_thd_destroy(& thds[id].thd); wt_thd_destroy(& thds[id].thd);
if (!--running_threads) /* now, signal when everybody is done with deinit */
pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex); pthread_mutex_unlock(&mutex);
DBUG_PRINT("wt", ("exiting")); DBUG_PRINT("wt", ("exiting"));
my_thread_end(); my_thread_end();
return 0; return 0;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment