Commit 6120fbac authored by unknown's avatar unknown

Aria unit tests fixed to have correct pagecache shutdown.

The Aria multithread test unlocked.

storage/maria/unittest/ma_pagecache_consist.c:
  Fixed pagecache shutdown.
storage/maria/unittest/ma_pagecache_rwconsist.c:
  Fixed pagecache shutdown.
storage/maria/unittest/ma_test_loghandler_multithread-t.c:
  The Aria multithread test unlocked.
storage/maria/unittest/ma_test_loghandler_pagecache-t.c:
  Fixed pagecache shutdown.
parent 6a557078
...@@ -476,6 +476,7 @@ int main(int argc __attribute__((unused)), ...@@ -476,6 +476,7 @@ int main(int argc __attribute__((unused)),
pthread_mutex_unlock(&LOCK_thread_count); pthread_mutex_unlock(&LOCK_thread_count);
DBUG_PRINT("info", ("thread ended")); DBUG_PRINT("info", ("thread ended"));
flush_pagecache_blocks(&pagecache, &file1, FLUSH_IGNORE_CHANGED);
end_pagecache(&pagecache, 1); end_pagecache(&pagecache, 1);
DBUG_PRINT("info", ("Page cache ended")); DBUG_PRINT("info", ("Page cache ended"));
......
...@@ -341,6 +341,7 @@ int main(int argc __attribute__((unused)), ...@@ -341,6 +341,7 @@ int main(int argc __attribute__((unused)),
pthread_mutex_unlock(&LOCK_thread_count); pthread_mutex_unlock(&LOCK_thread_count);
DBUG_PRINT("info", ("thread ended")); DBUG_PRINT("info", ("thread ended"));
flush_pagecache_blocks(&pagecache, &file1, FLUSH_IGNORE_CHANGED);
end_pagecache(&pagecache, 1); end_pagecache(&pagecache, 1);
DBUG_PRINT("info", ("Page cache ended")); DBUG_PRINT("info", ("Page cache ended"));
......
...@@ -269,11 +269,6 @@ int main(int argc __attribute__((unused)), ...@@ -269,11 +269,6 @@ int main(int argc __attribute__((unused)),
int *param, error; int *param, error;
int rc; int rc;
/* Disabled until Sanja tests */
plan(1);
ok(1, "disabled");
exit(0);
plan(WRITERS + FLUSHERS + plan(WRITERS + FLUSHERS +
ITERATIONS * WRITERS * 3 + FLUSH_ITERATIONS * FLUSHERS ); ITERATIONS * WRITERS * 3 + FLUSH_ITERATIONS * FLUSHERS );
......
...@@ -168,7 +168,7 @@ int main(int argc __attribute__((unused)), char *argv[]) ...@@ -168,7 +168,7 @@ int main(int argc __attribute__((unused)), char *argv[])
PAGECACHE_PIN_LEFT_UNPINNED, PAGECACHE_PIN_LEFT_UNPINNED,
PAGECACHE_WRITE_DELAY, PAGECACHE_WRITE_DELAY,
0, LSN_IMPOSSIBLE); 0, LSN_IMPOSSIBLE);
flush_pagecache_blocks(&pagecache, &file1, FLUSH_FORCE_WRITE); flush_pagecache_blocks(&pagecache, &file1, FLUSH_RELEASE);
} }
my_close(file1.file, MYF(MY_WME)); my_close(file1.file, MYF(MY_WME));
if ((file1.file= my_open(first_translog_file, O_RDONLY, MYF(MY_WME))) < 0) if ((file1.file= my_open(first_translog_file, O_RDONLY, MYF(MY_WME))) < 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