mirror of
https://github.com/MariaDB/server.git
synced 2025-02-02 12:01:42 +01:00
c1d4665514
------------------------------------------------------------------------ r2867 | marko | 2008-10-24 10:24:17 +0300 (Fri, 24 Oct 2008) | 2 lines branches/zip: ChangeLog: Document r2763, r2794, r2683, r2799, r2809, r2866. ------------------------------------------------------------------------ r2869 | vasil | 2008-10-24 11:14:16 +0300 (Fri, 24 Oct 2008) | 4 lines branches/zip: White space cleanup in ChangeLog ------------------------------------------------------------------------ r2870 | vasil | 2008-10-24 13:36:14 +0300 (Fri, 24 Oct 2008) | 8 lines branches/zip: Remove a statement that causes the innodb-index test to fail. The change in behavior was introduced in MySQL BZR-r2738. Suggested by: Marko ------------------------------------------------------------------------ r2871 | vasil | 2008-10-24 13:48:38 +0300 (Fri, 24 Oct 2008) | 5 lines branches/zip: Adjust mysql-test/patches/innodb-index.diff after the change to mysql-test/innodb-index.(test|result) in r2870. ------------------------------------------------------------------------ r2878 | calvin | 2008-10-27 11:05:42 +0200 (Mon, 27 Oct 2008) | 8 lines branches/zip: port the fix of Bug#19424 - InnoDB: Possibly a memory overrun of the buffer being freed with 64-bit Microsoft Visual C++. The changed file: CMakeLists.txt: Removing Win64 compiler optimizations for all innodb/mem/* files. ------------------------------------------------------------------------ r2884 | vasil | 2008-10-27 11:48:46 +0200 (Mon, 27 Oct 2008) | 7 lines branches/zip: ChangeLog: Add entry for the fix of Bug#19424 InnoDB: Possibly a memory overrun of the buffer being freed (64-bit Visual C) ------------------------------------------------------------------------ r2886 | calvin | 2008-10-27 22:39:11 +0200 (Mon, 27 Oct 2008) | 8 lines branches/zip: This patch is to solve the issue that file handles can not cross DLL/EXE boundaries on Windows. In builtin InnoDB, it makes call to MySQL server for creating tmp files. innobase_mysql_tmpfile is now rewritten for the plugin. rb://5 Approved by: Marko ------------------------------------------------------------------------ r2887 | calvin | 2008-10-27 22:48:29 +0200 (Mon, 27 Oct 2008) | 44 lines branches/zip: implement the delayloading of externals for the plugin on Windows, which includes: * Load mysqld.map and insert all symbol/address pairs into hash for quick access * Resolves all external data variables. The delayloading mechanism in MSVC does not support automatic imports of data variables. A workaround is to explicitly handle the data import using the delay loader during the initialization of the plugin. * Resolves all external functions during run-time, by implementing the delayed loading helper function delayLoadHelper2, which is called by run-time as well as HrLoadAllImportsForDll. The delay loader reuses the hash implementation in InnoDB. The normal hash_create (in hash0hash.c) creates hash tables in buffer pool. But the delay loader is invoked before the engine is initialized, and buffer pools are not ready yet. Instead, the delay loader has its own implementation of hash_create() and hash_table_free(), called wdl_hash_create() and wdl_hash_table_free(). This patch should be used with other two patches in order to build a dynamically linked plugin on Windows: * patch for tmpfile functions (r2886) * patch for "build" files (to be committed) The list of file changed: handler/handler0vars.h: new file, defines a list of external data variables (no external functions). handler/win_delay_loader.cc: new file, the implementation of the delay loader for Windows plugin. handler/ha_innodb.cc: add a header file, and changes for copying the system variables. handler/handler0alter.cc: add a header file handler/i_s.cc: add a header file rb://27 Reviewed by: Sunny, Marko Approved by: Sunny ------------------------------------------------------------------------ r2888 | calvin | 2008-10-28 01:51:49 +0200 (Tue, 28 Oct 2008) | 25 lines branches/zip: for building dynamic plugin on Windows, ha_innodb.dll, when INNODB_DYNAMIC_PLUGIN is specified. The changes are: CMakeLists.txt: add project ha_innodb for dynamic plugin on Windows. ha_innodb depends on project mysqld. ha_innodb.def: a new file with standard exports for a dynamic plugin. Two new files will be added: * sql/mysqld.def: .def file for 32-bit compiler * sql/mysqld_x64.def: .def file for x64 compiler It is also required to apply a patch to the MySQL source tree. The patch is described in win-plugin/README: win-plugin/win-plugin.diff - a patch to be applied to MySQL source tree. When applied, the following files will be modified: * CMakeLists.txt: add INNODB_DYNAMIC_PLUGIN and _USE_32BIT_TIME_T * sql/CMakeLists.txt: add mysqld.def or mysqld_x64.def for mysqld * win/configure.js: add INNODB_DYNAMIC_PLUGIN * win/build-vs71.bat: provide an option to specify CMAKE_BUILD_TYPE * win/build-vs8.bat: provide an option to specify CMAKE_BUILD_TYPE * win/build-vs8_x64.bat: provide an option to specify CMAKE_BUILD_TYPE ------------------------------------------------------------------------ r2894 | marko | 2008-10-28 08:36:39 +0200 (Tue, 28 Oct 2008) | 4 lines branches/zip: dict_str_starts_with_keyword(): Removed this unused function. Spotted by Sunny. ------------------------------------------------------------------------ r2895 | vasil | 2008-10-28 08:40:45 +0200 (Tue, 28 Oct 2008) | 6 lines branches/zip: ChangeLog: add entry for the Windows plugin. ------------------------------------------------------------------------ r2917 | marko | 2008-10-28 23:53:23 +0200 (Tue, 28 Oct 2008) | 3 lines branches/zip: innodb_plugin_init(): Do not copy session variables, even when the variable is a global variable in the built-in InnoDB. ------------------------------------------------------------------------ r2918 | calvin | 2008-10-29 00:08:11 +0200 (Wed, 29 Oct 2008) | 2 lines branches/zip: fix a problem introduced in r2917 - dyn is not initialized. Move the check into for(). ------------------------------------------------------------------------ r2922 | calvin | 2008-10-29 08:29:01 +0200 (Wed, 29 Oct 2008) | 16 lines branches/zip: fix issue #102 - Windows plugin: resolve dbug functions during run-time. Implement wrapper functions in the plugin. The plugin will get the function entries from mysqld.exe during the init, and invoke the corresponding functions (in mysqld.exe). The list of functions are: _db_pargs_ _db_doprnt_ _db_enter_ _db_return_ _db_dump_ rb://38 Approved by: Marko ------------------------------------------------------------------------ r2923 | marko | 2008-10-29 09:52:30 +0200 (Wed, 29 Oct 2008) | 1 line branches/zip: ChangeLog: Mention Bug #27276. ------------------------------------------------------------------------ r2925 | calvin | 2008-10-29 10:09:41 +0200 (Wed, 29 Oct 2008) | 16 lines branches/zip: change function names in sql/mysqld.def in order to work with 5.1.29-rc. In 5.1.29, the following function names are changed: _hash_init hash_free hash_search hash_delete changed to _my_hash_init my_hash_free my_hash_search my_hash_delete Approved by: Marko (on IM) ------------------------------------------------------------------------ r2927 | marko | 2008-10-29 11:43:23 +0200 (Wed, 29 Oct 2008) | 4 lines branches/zip: ha_innodb.cc: Make some functions static, so that they will not be compiled as weak global symbols. These functions must not be redirected to the built-in InnoDB. ------------------------------------------------------------------------ r2928 | michael | 2008-10-29 19:20:10 +0200 (Wed, 29 Oct 2008) | 4 lines Remove unnecessary assert Approved by: Heikki, over IM ------------------------------------------------------------------------ r2930 | marko | 2008-10-29 21:39:24 +0200 (Wed, 29 Oct 2008) | 33 lines branches/zip: Merge revisions 2854:2929 from branches/5.1, except r2924, which was merged from branches/zip r2866 to branches/5.1 and except r2879 which was merged separately by Calvin: ------------------------------------------------------------------------ r2902 | vasil | 2008-10-28 12:10:25 +0200 (Tue, 28 Oct 2008) | 10 lines branches/5.1: Fix Bug#38189 innodb_stats_on_metadata missing Make the variable innodb_stats_on_metadata visible to the users and also settable at runtime. Previously it was only "visible" as a command line startup option to mysqld. Approved by: Marko (https://svn.innodb.com/rb/r/36) ------------------------------------------------------------------------ r2929 | marko | 2008-10-29 21:26:14 +0200 (Wed, 29 Oct 2008) | 13 lines branches/5.1: dtype_get_sql_null_size(): return the correct storage size of a SQL NULL column. (Bug #40369) When MySQL Bug #20877 was fixed in r834, this function was accidentally modified to return 0 or 1. Apparently, the only impact of this bug is that fixed-length columns cannot be updated in-place from or to SQL NULL, even in ROW_FORMAT=REDUNDANT. After this fix, fixed-length columns in ROW_FORMAT=REDUNDANT will have a constant storage size as they should, no matter if NULL or non-NULL. The bug caused fixed-length NULL columns to occupy 1 byte. rb://37 approved by Heikki over IM. ------------------------------------------------------------------------ ------------------------------------------------------------------------ r2931 | vasil | 2008-10-29 22:10:40 +0200 (Wed, 29 Oct 2008) | 4 lines branches/zip: Add 2 ChangeLog entries for the 2 bugfixes that were merged from branches/5.1. ------------------------------------------------------------------------ r2935 | vasil | 2008-10-30 12:17:23 +0200 (Thu, 30 Oct 2008) | 17 lines branches/zip: Fix "Bug#40360 Binlog related errors with binlog off" in InnoDB code in order to have a Bug#40360-free InnoDB Plugin 1.0.2. The fix does check whether binary logging is enabled in MySQL by accessing the opt_bin_log global variable that is defined in sql/mysqld.cc. In case MySQL does develop another solution to this via Bug#40360 then we can revert this patch (except the mysql-tests). The windows-plugin part of this fix will be committed as a separate commit to ease eventual merge into branches/5.1 [note from the future: the separate commit went into r2936]. Approved by: Marko (https://svn.innodb.com/rb/r/39) ------------------------------------------------------------------------ r2936 | vasil | 2008-10-30 12:24:09 +0200 (Thu, 30 Oct 2008) | 7 lines branches/zip: Followup to r2935: add the Windows Delay Loader stuff for the MySQL variable that we are accessing. If someday we have another solution for Bug#40360 Binlog related errors with binlog off then this should also be reverted. ------------------------------------------------------------------------ r2937 | vasil | 2008-10-30 12:28:47 +0200 (Thu, 30 Oct 2008) | 4 lines branches/zip: Add ChangeLog entry for Bug#40360 Binlog related errors with binlog off ------------------------------------------------------------------------ r2938 | vasil | 2008-10-30 12:33:28 +0200 (Thu, 30 Oct 2008) | 5 lines branches/zip: Non-functional change: convert handler/handler0vars.h and handler/win_delay_loader.cc from \r\n (dos) to \n (unix) line terminators. ------------------------------------------------------------------------ r2939 | marko | 2008-10-30 12:38:18 +0200 (Thu, 30 Oct 2008) | 2 lines branches/zip: Set svn:eol-style native on some recently added text files. ------------------------------------------------------------------------ r2940 | marko | 2008-10-30 12:46:21 +0200 (Thu, 30 Oct 2008) | 1 line branches/zip: ChangeLog, ha_innodb.def: Set svn:eol-style native ------------------------------------------------------------------------ r2941 | vasil | 2008-10-30 19:34:27 +0200 (Thu, 30 Oct 2008) | 4 lines branches/zip: Increment the InnoDB Plugin version from 1.0.1 to 1.0.2. ------------------------------------------------------------------------ r2943 | sunny | 2008-10-31 09:40:29 +0200 (Fri, 31 Oct 2008) | 15 lines branches/zip: 1. We add a vector of locks to trx_t. This array contains the autoinc locks granted to a transaction. There is one per table. 2. We enforce releasing of these locks in the reverse order from the one in which they are acquired. The assumption is that since the AUTOINC locks are statement level locks. Nested statements introduced by triggers are stacked it should hold. There was some cleanup done to the vector code too by adding const and some new functions. Rename dict_table_t::auto_inc_lock to autoinc_lock. Fix Bug#26316 Triggers create duplicate entries on auto-increment columns rb://22 ------------------------------------------------------------------------ r2944 | vasil | 2008-10-31 09:44:16 +0200 (Fri, 31 Oct 2008) | 12 lines branches/zip: Revert our temporary fix for "Bug#40360 Binlog related errors with binlog off" (r2935, r2936) and deploy MySQL's one, but put the function mysql_bin_log_is_engaged() inside mysql_addons.cc instead of in mysql's log.cc and use a different name for it so there is no collision when MySQL adds this function in log.cc. [note from the future: the windows part of this patch went into r2947] Approved by: Marko (https://svn.innodb.com/rb/r/41/) ------------------------------------------------------------------------ r2945 | sunny | 2008-10-31 09:44:45 +0200 (Fri, 31 Oct 2008) | 2 lines branches/zip: Update ChangeLog with r2943 info. ------------------------------------------------------------------------ r2946 | marko | 2008-10-31 10:18:47 +0200 (Fri, 31 Oct 2008) | 2 lines branches/zip: Revert the unintended change to univ.i that was made in r2943. ------------------------------------------------------------------------ r2947 | calvin | 2008-10-31 10:38:26 +0200 (Fri, 31 Oct 2008) | 6 lines branches/zip: Windows plugin part of r2944 r2944 has reference to mysql_bin_log.is_open(), which is new in InnoDB. Add two new entries and remove one duplicate in mysqld.def & mysqld_x64.def. ------------------------------------------------------------------------ r2948 | vasil | 2008-10-31 11:39:07 +0200 (Fri, 31 Oct 2008) | 9 lines branches/zip: Fix Mantis issue#106 plugin init error:InnoDB: stats_on_metadata in static InnoDB (flags=0x2401) differs from stats_on_metadata in dynamic InnoDB (fl Ignore the NOSYSVAR flag in addition to ignoring the READONLY flag. Approved by: Marko (https://svn.innodb.com/rb/r/42/) ------------------------------------------------------------------------ r2949 | vasil | 2008-10-31 11:47:56 +0200 (Fri, 31 Oct 2008) | 4 lines branches/zip: White-space cleanup in ChangeLog. ------------------------------------------------------------------------ r2951 | marko | 2008-10-31 14:21:43 +0200 (Fri, 31 Oct 2008) | 4 lines branches/zip: scripts/install_innodb_plugins_win.sql: New script, for installing the InnoDB plugins in Windows. Copied from scripts/install_innodb_plugins.sql. ------------------------------------------------------------------------ r2954 | calvin | 2008-11-04 09:15:26 +0200 (Tue, 04 Nov 2008) | 8 lines branches/zip: ignore the failure when builtin_innobase_plugin is not available. External variable builtin_innobase_plugin is not available when mysqld does not have a builtin InnoDB. The init of the Windows plugin should not fail in this case. Approved by: Marko (on IM) ------------------------------------------------------------------------ r2955 | calvin | 2008-11-04 12:43:14 +0200 (Tue, 04 Nov 2008) | 11 lines branches/zip: windows plugin - fix references to array variables. This problem surfaced when running new test innodb_bug40360.test. Both tx_isolation_names and binlog_format_names are name arrays, and should be defined as wdl_tx_isolation_names and wdl_binlog_format_names, not *wdl_tx_isolation_names and *wdl_binlog_format_names. Another array variable is all_charsets, which is already correctly defined. Approved by: Marko (on IM) ------------------------------------------------------------------------ r2986 | marko | 2008-11-11 09:28:37 +0200 (Tue, 11 Nov 2008) | 11 lines branches/zip: ha_innobase::create(): Remove the dependences on DICT_TF_ZSSIZE_MAX, so that the code can be compiled with a different uncompressed page size by redefining UNIV_PAGE_SIZE_SHIFT in univ.i. Currently, the allowed values are 12, 13, or 14 (4k, 8k, 16k). Make the default compressed page size half the uncompressed page size. The previous default was 8 kilobytes, which is the same when compiling with the default 16k uncompressed page size. rb://50 approved by Pekka Lampio and Sunny Bains. ------------------------------------------------------------------------
1560 lines
41 KiB
C++
1560 lines
41 KiB
C++
/******************************************************
|
|
InnoDB INFORMATION SCHEMA tables interface to MySQL.
|
|
|
|
(c) 2007 Innobase Oy
|
|
|
|
Created July 18, 2007 Vasil Dimov
|
|
*******************************************************/
|
|
|
|
#include <mysql_priv.h>
|
|
#include <mysqld_error.h>
|
|
|
|
#include <m_ctype.h>
|
|
#include <hash.h>
|
|
#include <myisampack.h>
|
|
#include <mysys_err.h>
|
|
#include <my_sys.h>
|
|
#include "i_s.h"
|
|
#include <mysql/plugin.h>
|
|
|
|
extern "C" {
|
|
#include "trx0i_s.h"
|
|
#include "trx0trx.h" /* for TRX_QUE_STATE_STR_MAX_LEN */
|
|
#include "buf0buddy.h" /* for i_s_cmpmem */
|
|
#include "buf0buf.h" /* for buf_pool and PAGE_ZIP_MIN_SIZE */
|
|
#include "ha_prototypes.h" /* for innobase_convert_name() */
|
|
#include "srv0start.h" /* for srv_was_started */
|
|
}
|
|
#include "handler0vars.h"
|
|
|
|
static const char plugin_author[] = "Innobase Oy";
|
|
|
|
#define OK(expr) \
|
|
if ((expr) != 0) { \
|
|
DBUG_RETURN(1); \
|
|
}
|
|
|
|
#define RETURN_IF_INNODB_NOT_STARTED(plugin_name) \
|
|
do { \
|
|
if (!srv_was_started) { \
|
|
push_warning_printf(thd, MYSQL_ERROR::WARN_LEVEL_WARN, \
|
|
ER_CANT_FIND_SYSTEM_REC, \
|
|
"InnoDB: SELECTing from " \
|
|
"INFORMATION_SCHEMA.%s but " \
|
|
"the InnoDB storage engine " \
|
|
"is not installed", plugin_name); \
|
|
DBUG_RETURN(0); \
|
|
} \
|
|
} while (0)
|
|
|
|
#if !defined __STRICT_ANSI__ && defined __GNUC__ && (__GNUC__) > 2 && !defined __INTEL_COMPILER
|
|
#define STRUCT_FLD(name, value) name: value
|
|
#else
|
|
#define STRUCT_FLD(name, value) value
|
|
#endif
|
|
|
|
static const ST_FIELD_INFO END_OF_ST_FIELD_INFO =
|
|
{STRUCT_FLD(field_name, NULL),
|
|
STRUCT_FLD(field_length, 0),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_NULL),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)};
|
|
|
|
/*
|
|
Use the following types mapping:
|
|
|
|
C type ST_FIELD_INFO::field_type
|
|
---------------------------------
|
|
long MYSQL_TYPE_LONGLONG
|
|
(field_length=MY_INT64_NUM_DECIMAL_DIGITS)
|
|
|
|
long unsigned MYSQL_TYPE_LONGLONG
|
|
(field_length=MY_INT64_NUM_DECIMAL_DIGITS, field_flags=MY_I_S_UNSIGNED)
|
|
|
|
char* MYSQL_TYPE_STRING
|
|
(field_length=n)
|
|
|
|
float MYSQL_TYPE_FLOAT
|
|
(field_length=0 is ignored)
|
|
|
|
void* MYSQL_TYPE_LONGLONG
|
|
(field_length=MY_INT64_NUM_DECIMAL_DIGITS, field_flags=MY_I_S_UNSIGNED)
|
|
|
|
boolean (if else) MYSQL_TYPE_LONG
|
|
(field_length=1)
|
|
|
|
time_t MYSQL_TYPE_DATETIME
|
|
(field_length=0 ignored)
|
|
---------------------------------
|
|
*/
|
|
|
|
/* XXX these are defined in mysql_priv.h inside #ifdef MYSQL_SERVER */
|
|
bool schema_table_store_record(THD *thd, TABLE *table);
|
|
void localtime_to_TIME(MYSQL_TIME *to, struct tm *from);
|
|
bool check_global_access(THD *thd, ulong want_access);
|
|
|
|
/***********************************************************************
|
|
Common function to fill any of the dynamic tables:
|
|
INFORMATION_SCHEMA.innodb_trx
|
|
INFORMATION_SCHEMA.innodb_locks
|
|
INFORMATION_SCHEMA.innodb_lock_waits */
|
|
static
|
|
int
|
|
trx_i_s_common_fill_table(
|
|
/*======================*/
|
|
/* out: 0 on success */
|
|
THD* thd, /* in: thread */
|
|
TABLE_LIST* tables, /* in/out: tables to fill */
|
|
COND* cond); /* in: condition (not used) */
|
|
|
|
/***********************************************************************
|
|
Unbind a dynamic INFORMATION_SCHEMA table. */
|
|
static
|
|
int
|
|
i_s_common_deinit(
|
|
/*==============*/
|
|
/* out: 0 on success */
|
|
void* p); /* in/out: table schema object */
|
|
|
|
/***********************************************************************
|
|
Auxiliary function to store time_t value in MYSQL_TYPE_DATETIME
|
|
field. */
|
|
static
|
|
int
|
|
field_store_time_t(
|
|
/*===============*/
|
|
/* out: 0 on success */
|
|
Field* field, /* in/out: target field for storage */
|
|
time_t time) /* in: value to store */
|
|
{
|
|
MYSQL_TIME my_time;
|
|
struct tm tm_time;
|
|
|
|
#if 0
|
|
/* use this if you are sure that `variables' and `time_zone'
|
|
are always initialized */
|
|
thd->variables.time_zone->gmt_sec_to_TIME(
|
|
&my_time, (my_time_t) time);
|
|
#else
|
|
localtime_r(&time, &tm_time);
|
|
localtime_to_TIME(&my_time, &tm_time);
|
|
my_time.time_type = MYSQL_TIMESTAMP_DATETIME;
|
|
#endif
|
|
|
|
return(field->store_time(&my_time, MYSQL_TIMESTAMP_DATETIME));
|
|
}
|
|
|
|
/***********************************************************************
|
|
Auxiliary function to store char* value in MYSQL_TYPE_STRING field. */
|
|
static
|
|
int
|
|
field_store_string(
|
|
/*===============*/
|
|
/* out: 0 on success */
|
|
Field* field, /* in/out: target field for storage */
|
|
const char* str) /* in: NUL-terminated utf-8 string,
|
|
or NULL */
|
|
{
|
|
int ret;
|
|
|
|
if (str != NULL) {
|
|
|
|
ret = field->store(str, strlen(str),
|
|
system_charset_info);
|
|
field->set_notnull();
|
|
} else {
|
|
|
|
ret = 0; /* success */
|
|
field->set_null();
|
|
}
|
|
|
|
return(ret);
|
|
}
|
|
|
|
/***********************************************************************
|
|
Auxiliary function to store ulint value in MYSQL_TYPE_LONGLONG field.
|
|
If the value is ULINT_UNDEFINED then the field it set to NULL. */
|
|
static
|
|
int
|
|
field_store_ulint(
|
|
/*==============*/
|
|
/* out: 0 on success */
|
|
Field* field, /* in/out: target field for storage */
|
|
ulint n) /* in: value to store */
|
|
{
|
|
int ret;
|
|
|
|
if (n != ULINT_UNDEFINED) {
|
|
|
|
ret = field->store(n);
|
|
field->set_notnull();
|
|
} else {
|
|
|
|
ret = 0; /* success */
|
|
field->set_null();
|
|
}
|
|
|
|
return(ret);
|
|
}
|
|
|
|
/* Fields of the dynamic table INFORMATION_SCHEMA.innodb_trx */
|
|
static ST_FIELD_INFO innodb_trx_fields_info[] =
|
|
{
|
|
#define IDX_TRX_ID 0
|
|
{STRUCT_FLD(field_name, "trx_id"),
|
|
STRUCT_FLD(field_length, TRX_ID_MAX_LEN + 1),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_TRX_STATE 1
|
|
{STRUCT_FLD(field_name, "trx_state"),
|
|
STRUCT_FLD(field_length, TRX_QUE_STATE_STR_MAX_LEN + 1),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_TRX_STARTED 2
|
|
{STRUCT_FLD(field_name, "trx_started"),
|
|
STRUCT_FLD(field_length, 0),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_DATETIME),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_TRX_REQUESTED_LOCK_ID 3
|
|
{STRUCT_FLD(field_name, "trx_requested_lock_id"),
|
|
STRUCT_FLD(field_length, TRX_I_S_LOCK_ID_MAX_LEN + 1),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_TRX_WAIT_STARTED 4
|
|
{STRUCT_FLD(field_name, "trx_wait_started"),
|
|
STRUCT_FLD(field_length, 0),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_DATETIME),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_TRX_WEIGHT 5
|
|
{STRUCT_FLD(field_name, "trx_weight"),
|
|
STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, MY_I_S_UNSIGNED),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_TRX_MYSQL_THREAD_ID 6
|
|
{STRUCT_FLD(field_name, "trx_mysql_thread_id"),
|
|
STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, MY_I_S_UNSIGNED),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_TRX_QUERY 7
|
|
{STRUCT_FLD(field_name, "trx_query"),
|
|
STRUCT_FLD(field_length, TRX_I_S_TRX_QUERY_MAX_LEN),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
END_OF_ST_FIELD_INFO
|
|
};
|
|
|
|
/***********************************************************************
|
|
Read data from cache buffer and fill the INFORMATION_SCHEMA.innodb_trx
|
|
table with it. */
|
|
static
|
|
int
|
|
fill_innodb_trx_from_cache(
|
|
/*=======================*/
|
|
/* out: 0 on success */
|
|
trx_i_s_cache_t* cache, /* in: cache to read from */
|
|
THD* thd, /* in: used to call
|
|
schema_table_store_record() */
|
|
TABLE* table) /* in/out: fill this table */
|
|
{
|
|
Field** fields;
|
|
ulint rows_num;
|
|
char lock_id[TRX_I_S_LOCK_ID_MAX_LEN + 1];
|
|
ulint i;
|
|
|
|
DBUG_ENTER("fill_innodb_trx_from_cache");
|
|
|
|
fields = table->field;
|
|
|
|
rows_num = trx_i_s_cache_get_rows_used(cache,
|
|
I_S_INNODB_TRX);
|
|
|
|
for (i = 0; i < rows_num; i++) {
|
|
|
|
i_s_trx_row_t* row;
|
|
char trx_id[TRX_ID_MAX_LEN + 1];
|
|
|
|
row = (i_s_trx_row_t*)
|
|
trx_i_s_cache_get_nth_row(
|
|
cache, I_S_INNODB_TRX, i);
|
|
|
|
/* trx_id */
|
|
ut_snprintf(trx_id, sizeof(trx_id), TRX_ID_FMT, row->trx_id);
|
|
OK(field_store_string(fields[IDX_TRX_ID], trx_id));
|
|
|
|
/* trx_state */
|
|
OK(field_store_string(fields[IDX_TRX_STATE],
|
|
row->trx_state));
|
|
|
|
/* trx_started */
|
|
OK(field_store_time_t(fields[IDX_TRX_STARTED],
|
|
(time_t) row->trx_started));
|
|
|
|
/* trx_requested_lock_id */
|
|
/* trx_wait_started */
|
|
if (row->trx_wait_started != 0) {
|
|
|
|
OK(field_store_string(
|
|
fields[IDX_TRX_REQUESTED_LOCK_ID],
|
|
trx_i_s_create_lock_id(
|
|
row->requested_lock_row,
|
|
lock_id, sizeof(lock_id))));
|
|
/* field_store_string() sets it no notnull */
|
|
|
|
OK(field_store_time_t(
|
|
fields[IDX_TRX_WAIT_STARTED],
|
|
(time_t) row->trx_wait_started));
|
|
fields[IDX_TRX_WAIT_STARTED]->set_notnull();
|
|
} else {
|
|
|
|
fields[IDX_TRX_REQUESTED_LOCK_ID]->set_null();
|
|
fields[IDX_TRX_WAIT_STARTED]->set_null();
|
|
}
|
|
|
|
/* trx_weight */
|
|
OK(fields[IDX_TRX_WEIGHT]->store((longlong) row->trx_weight,
|
|
true));
|
|
|
|
/* trx_mysql_thread_id */
|
|
OK(fields[IDX_TRX_MYSQL_THREAD_ID]->store(
|
|
row->trx_mysql_thread_id));
|
|
|
|
/* trx_query */
|
|
OK(field_store_string(fields[IDX_TRX_QUERY],
|
|
row->trx_query));
|
|
|
|
OK(schema_table_store_record(thd, table));
|
|
}
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
/***********************************************************************
|
|
Bind the dynamic table INFORMATION_SCHEMA.innodb_trx */
|
|
static
|
|
int
|
|
innodb_trx_init(
|
|
/*============*/
|
|
/* out: 0 on success */
|
|
void* p) /* in/out: table schema object */
|
|
{
|
|
ST_SCHEMA_TABLE* schema;
|
|
|
|
DBUG_ENTER("innodb_trx_init");
|
|
|
|
schema = (ST_SCHEMA_TABLE*) p;
|
|
|
|
schema->fields_info = innodb_trx_fields_info;
|
|
schema->fill_table = trx_i_s_common_fill_table;
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
static struct st_mysql_information_schema i_s_info =
|
|
{
|
|
MYSQL_INFORMATION_SCHEMA_INTERFACE_VERSION
|
|
};
|
|
|
|
UNIV_INTERN struct st_mysql_plugin i_s_innodb_trx =
|
|
{
|
|
/* the plugin type (a MYSQL_XXX_PLUGIN value) */
|
|
/* int */
|
|
STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN),
|
|
|
|
/* pointer to type-specific plugin descriptor */
|
|
/* void* */
|
|
STRUCT_FLD(info, &i_s_info),
|
|
|
|
/* plugin name */
|
|
/* const char* */
|
|
STRUCT_FLD(name, "INNODB_TRX"),
|
|
|
|
/* plugin author (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(author, plugin_author),
|
|
|
|
/* general descriptive text (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(descr, "InnoDB transactions"),
|
|
|
|
/* the plugin license (PLUGIN_LICENSE_XXX) */
|
|
/* int */
|
|
STRUCT_FLD(license, PLUGIN_LICENSE_GPL),
|
|
|
|
/* the function to invoke when plugin is loaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(init, innodb_trx_init),
|
|
|
|
/* the function to invoke when plugin is unloaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(deinit, i_s_common_deinit),
|
|
|
|
/* plugin version (for SHOW PLUGINS) */
|
|
/* unsigned int */
|
|
STRUCT_FLD(version, INNODB_VERSION_SHORT),
|
|
|
|
/* struct st_mysql_show_var* */
|
|
STRUCT_FLD(status_vars, NULL),
|
|
|
|
/* struct st_mysql_sys_var** */
|
|
STRUCT_FLD(system_vars, NULL),
|
|
|
|
/* reserved for dependency checking */
|
|
/* void* */
|
|
STRUCT_FLD(__reserved1, NULL)
|
|
};
|
|
|
|
/* Fields of the dynamic table INFORMATION_SCHEMA.innodb_locks */
|
|
static ST_FIELD_INFO innodb_locks_fields_info[] =
|
|
{
|
|
#define IDX_LOCK_ID 0
|
|
{STRUCT_FLD(field_name, "lock_id"),
|
|
STRUCT_FLD(field_length, TRX_I_S_LOCK_ID_MAX_LEN + 1),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_LOCK_TRX_ID 1
|
|
{STRUCT_FLD(field_name, "lock_trx_id"),
|
|
STRUCT_FLD(field_length, TRX_ID_MAX_LEN + 1),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_LOCK_MODE 2
|
|
{STRUCT_FLD(field_name, "lock_mode"),
|
|
/* S[,GAP] X[,GAP] IS[,GAP] IX[,GAP] AUTO_INC UNKNOWN */
|
|
STRUCT_FLD(field_length, 32),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_LOCK_TYPE 3
|
|
{STRUCT_FLD(field_name, "lock_type"),
|
|
STRUCT_FLD(field_length, 32 /* RECORD|TABLE|UNKNOWN */),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_LOCK_TABLE 4
|
|
{STRUCT_FLD(field_name, "lock_table"),
|
|
STRUCT_FLD(field_length, 1024),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_LOCK_INDEX 5
|
|
{STRUCT_FLD(field_name, "lock_index"),
|
|
STRUCT_FLD(field_length, 1024),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_LOCK_SPACE 6
|
|
{STRUCT_FLD(field_name, "lock_space"),
|
|
STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, MY_I_S_UNSIGNED | MY_I_S_MAYBE_NULL),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_LOCK_PAGE 7
|
|
{STRUCT_FLD(field_name, "lock_page"),
|
|
STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, MY_I_S_UNSIGNED | MY_I_S_MAYBE_NULL),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_LOCK_REC 8
|
|
{STRUCT_FLD(field_name, "lock_rec"),
|
|
STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, MY_I_S_UNSIGNED | MY_I_S_MAYBE_NULL),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_LOCK_DATA 9
|
|
{STRUCT_FLD(field_name, "lock_data"),
|
|
STRUCT_FLD(field_length, TRX_I_S_LOCK_DATA_MAX_LEN),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
END_OF_ST_FIELD_INFO
|
|
};
|
|
|
|
/***********************************************************************
|
|
Read data from cache buffer and fill the INFORMATION_SCHEMA.innodb_locks
|
|
table with it. */
|
|
static
|
|
int
|
|
fill_innodb_locks_from_cache(
|
|
/*=========================*/
|
|
/* out: 0 on success */
|
|
trx_i_s_cache_t* cache, /* in: cache to read from */
|
|
THD* thd, /* in: MySQL client connection */
|
|
TABLE* table) /* in/out: fill this table */
|
|
{
|
|
Field** fields;
|
|
ulint rows_num;
|
|
char lock_id[TRX_I_S_LOCK_ID_MAX_LEN + 1];
|
|
ulint i;
|
|
|
|
DBUG_ENTER("fill_innodb_locks_from_cache");
|
|
|
|
fields = table->field;
|
|
|
|
rows_num = trx_i_s_cache_get_rows_used(cache,
|
|
I_S_INNODB_LOCKS);
|
|
|
|
for (i = 0; i < rows_num; i++) {
|
|
|
|
i_s_locks_row_t* row;
|
|
|
|
/* note that the decoded database or table name is
|
|
never expected to be longer than NAME_LEN;
|
|
NAME_LEN for database name
|
|
2 for surrounding quotes around database name
|
|
NAME_LEN for table name
|
|
2 for surrounding quotes around table name
|
|
1 for the separating dot (.)
|
|
9 for the #mysql50# prefix */
|
|
char buf[2 * NAME_LEN + 14];
|
|
const char* bufend;
|
|
|
|
char lock_trx_id[TRX_ID_MAX_LEN + 1];
|
|
|
|
row = (i_s_locks_row_t*)
|
|
trx_i_s_cache_get_nth_row(
|
|
cache, I_S_INNODB_LOCKS, i);
|
|
|
|
/* lock_id */
|
|
trx_i_s_create_lock_id(row, lock_id, sizeof(lock_id));
|
|
OK(field_store_string(fields[IDX_LOCK_ID],
|
|
lock_id));
|
|
|
|
/* lock_trx_id */
|
|
ut_snprintf(lock_trx_id, sizeof(lock_trx_id),
|
|
TRX_ID_FMT, row->lock_trx_id);
|
|
OK(field_store_string(fields[IDX_LOCK_TRX_ID], lock_trx_id));
|
|
|
|
/* lock_mode */
|
|
OK(field_store_string(fields[IDX_LOCK_MODE],
|
|
row->lock_mode));
|
|
|
|
/* lock_type */
|
|
OK(field_store_string(fields[IDX_LOCK_TYPE],
|
|
row->lock_type));
|
|
|
|
/* lock_table */
|
|
bufend = innobase_convert_name(buf, sizeof(buf),
|
|
row->lock_table,
|
|
strlen(row->lock_table),
|
|
thd, TRUE);
|
|
OK(fields[IDX_LOCK_TABLE]->store(buf, bufend - buf,
|
|
system_charset_info));
|
|
|
|
/* lock_index */
|
|
if (row->lock_index != NULL) {
|
|
|
|
bufend = innobase_convert_name(buf, sizeof(buf),
|
|
row->lock_index,
|
|
strlen(row->lock_index),
|
|
thd, FALSE);
|
|
OK(fields[IDX_LOCK_INDEX]->store(buf, bufend - buf,
|
|
system_charset_info));
|
|
fields[IDX_LOCK_INDEX]->set_notnull();
|
|
} else {
|
|
|
|
fields[IDX_LOCK_INDEX]->set_null();
|
|
}
|
|
|
|
/* lock_space */
|
|
OK(field_store_ulint(fields[IDX_LOCK_SPACE],
|
|
row->lock_space));
|
|
|
|
/* lock_page */
|
|
OK(field_store_ulint(fields[IDX_LOCK_PAGE],
|
|
row->lock_page));
|
|
|
|
/* lock_rec */
|
|
OK(field_store_ulint(fields[IDX_LOCK_REC],
|
|
row->lock_rec));
|
|
|
|
/* lock_data */
|
|
OK(field_store_string(fields[IDX_LOCK_DATA],
|
|
row->lock_data));
|
|
|
|
OK(schema_table_store_record(thd, table));
|
|
}
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
/***********************************************************************
|
|
Bind the dynamic table INFORMATION_SCHEMA.innodb_locks */
|
|
static
|
|
int
|
|
innodb_locks_init(
|
|
/*==============*/
|
|
/* out: 0 on success */
|
|
void* p) /* in/out: table schema object */
|
|
{
|
|
ST_SCHEMA_TABLE* schema;
|
|
|
|
DBUG_ENTER("innodb_locks_init");
|
|
|
|
schema = (ST_SCHEMA_TABLE*) p;
|
|
|
|
schema->fields_info = innodb_locks_fields_info;
|
|
schema->fill_table = trx_i_s_common_fill_table;
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
UNIV_INTERN struct st_mysql_plugin i_s_innodb_locks =
|
|
{
|
|
/* the plugin type (a MYSQL_XXX_PLUGIN value) */
|
|
/* int */
|
|
STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN),
|
|
|
|
/* pointer to type-specific plugin descriptor */
|
|
/* void* */
|
|
STRUCT_FLD(info, &i_s_info),
|
|
|
|
/* plugin name */
|
|
/* const char* */
|
|
STRUCT_FLD(name, "INNODB_LOCKS"),
|
|
|
|
/* plugin author (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(author, plugin_author),
|
|
|
|
/* general descriptive text (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(descr, "InnoDB conflicting locks"),
|
|
|
|
/* the plugin license (PLUGIN_LICENSE_XXX) */
|
|
/* int */
|
|
STRUCT_FLD(license, PLUGIN_LICENSE_GPL),
|
|
|
|
/* the function to invoke when plugin is loaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(init, innodb_locks_init),
|
|
|
|
/* the function to invoke when plugin is unloaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(deinit, i_s_common_deinit),
|
|
|
|
/* plugin version (for SHOW PLUGINS) */
|
|
/* unsigned int */
|
|
STRUCT_FLD(version, INNODB_VERSION_SHORT),
|
|
|
|
/* struct st_mysql_show_var* */
|
|
STRUCT_FLD(status_vars, NULL),
|
|
|
|
/* struct st_mysql_sys_var** */
|
|
STRUCT_FLD(system_vars, NULL),
|
|
|
|
/* reserved for dependency checking */
|
|
/* void* */
|
|
STRUCT_FLD(__reserved1, NULL)
|
|
};
|
|
|
|
/* Fields of the dynamic table INFORMATION_SCHEMA.innodb_lock_waits */
|
|
static ST_FIELD_INFO innodb_lock_waits_fields_info[] =
|
|
{
|
|
#define IDX_REQUESTING_TRX_ID 0
|
|
{STRUCT_FLD(field_name, "requesting_trx_id"),
|
|
STRUCT_FLD(field_length, TRX_ID_MAX_LEN + 1),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_REQUESTED_LOCK_ID 1
|
|
{STRUCT_FLD(field_name, "requested_lock_id"),
|
|
STRUCT_FLD(field_length, TRX_I_S_LOCK_ID_MAX_LEN + 1),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_BLOCKING_TRX_ID 2
|
|
{STRUCT_FLD(field_name, "blocking_trx_id"),
|
|
STRUCT_FLD(field_length, TRX_ID_MAX_LEN + 1),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
#define IDX_BLOCKING_LOCK_ID 3
|
|
{STRUCT_FLD(field_name, "blocking_lock_id"),
|
|
STRUCT_FLD(field_length, TRX_I_S_LOCK_ID_MAX_LEN + 1),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_STRING),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, ""),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
END_OF_ST_FIELD_INFO
|
|
};
|
|
|
|
/***********************************************************************
|
|
Read data from cache buffer and fill the
|
|
INFORMATION_SCHEMA.innodb_lock_waits table with it. */
|
|
static
|
|
int
|
|
fill_innodb_lock_waits_from_cache(
|
|
/*==============================*/
|
|
/* out: 0 on success */
|
|
trx_i_s_cache_t* cache, /* in: cache to read from */
|
|
THD* thd, /* in: used to call
|
|
schema_table_store_record() */
|
|
TABLE* table) /* in/out: fill this table */
|
|
{
|
|
Field** fields;
|
|
ulint rows_num;
|
|
char requested_lock_id[TRX_I_S_LOCK_ID_MAX_LEN + 1];
|
|
char blocking_lock_id[TRX_I_S_LOCK_ID_MAX_LEN + 1];
|
|
ulint i;
|
|
|
|
DBUG_ENTER("fill_innodb_lock_waits_from_cache");
|
|
|
|
fields = table->field;
|
|
|
|
rows_num = trx_i_s_cache_get_rows_used(cache,
|
|
I_S_INNODB_LOCK_WAITS);
|
|
|
|
for (i = 0; i < rows_num; i++) {
|
|
|
|
i_s_lock_waits_row_t* row;
|
|
|
|
char requesting_trx_id[TRX_ID_MAX_LEN + 1];
|
|
char blocking_trx_id[TRX_ID_MAX_LEN + 1];
|
|
|
|
row = (i_s_lock_waits_row_t*)
|
|
trx_i_s_cache_get_nth_row(
|
|
cache, I_S_INNODB_LOCK_WAITS, i);
|
|
|
|
/* requesting_trx_id */
|
|
ut_snprintf(requesting_trx_id, sizeof(requesting_trx_id),
|
|
TRX_ID_FMT, row->requested_lock_row->lock_trx_id);
|
|
OK(field_store_string(fields[IDX_REQUESTING_TRX_ID],
|
|
requesting_trx_id));
|
|
|
|
/* requested_lock_id */
|
|
OK(field_store_string(
|
|
fields[IDX_REQUESTED_LOCK_ID],
|
|
trx_i_s_create_lock_id(
|
|
row->requested_lock_row,
|
|
requested_lock_id,
|
|
sizeof(requested_lock_id))));
|
|
|
|
/* blocking_trx_id */
|
|
ut_snprintf(blocking_trx_id, sizeof(blocking_trx_id),
|
|
TRX_ID_FMT, row->blocking_lock_row->lock_trx_id);
|
|
OK(field_store_string(fields[IDX_BLOCKING_TRX_ID],
|
|
blocking_trx_id));
|
|
|
|
/* blocking_lock_id */
|
|
OK(field_store_string(
|
|
fields[IDX_BLOCKING_LOCK_ID],
|
|
trx_i_s_create_lock_id(
|
|
row->blocking_lock_row,
|
|
blocking_lock_id,
|
|
sizeof(blocking_lock_id))));
|
|
|
|
OK(schema_table_store_record(thd, table));
|
|
}
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
/***********************************************************************
|
|
Bind the dynamic table INFORMATION_SCHEMA.innodb_lock_waits */
|
|
static
|
|
int
|
|
innodb_lock_waits_init(
|
|
/*===================*/
|
|
/* out: 0 on success */
|
|
void* p) /* in/out: table schema object */
|
|
{
|
|
ST_SCHEMA_TABLE* schema;
|
|
|
|
DBUG_ENTER("innodb_lock_waits_init");
|
|
|
|
schema = (ST_SCHEMA_TABLE*) p;
|
|
|
|
schema->fields_info = innodb_lock_waits_fields_info;
|
|
schema->fill_table = trx_i_s_common_fill_table;
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
UNIV_INTERN struct st_mysql_plugin i_s_innodb_lock_waits =
|
|
{
|
|
/* the plugin type (a MYSQL_XXX_PLUGIN value) */
|
|
/* int */
|
|
STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN),
|
|
|
|
/* pointer to type-specific plugin descriptor */
|
|
/* void* */
|
|
STRUCT_FLD(info, &i_s_info),
|
|
|
|
/* plugin name */
|
|
/* const char* */
|
|
STRUCT_FLD(name, "INNODB_LOCK_WAITS"),
|
|
|
|
/* plugin author (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(author, "Innobase Oy"),
|
|
|
|
/* general descriptive text (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(descr, "InnoDB which lock is blocking which"),
|
|
|
|
/* the plugin license (PLUGIN_LICENSE_XXX) */
|
|
/* int */
|
|
STRUCT_FLD(license, PLUGIN_LICENSE_GPL),
|
|
|
|
/* the function to invoke when plugin is loaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(init, innodb_lock_waits_init),
|
|
|
|
/* the function to invoke when plugin is unloaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(deinit, i_s_common_deinit),
|
|
|
|
/* plugin version (for SHOW PLUGINS) */
|
|
/* unsigned int */
|
|
STRUCT_FLD(version, INNODB_VERSION_SHORT),
|
|
|
|
/* struct st_mysql_show_var* */
|
|
STRUCT_FLD(status_vars, NULL),
|
|
|
|
/* struct st_mysql_sys_var** */
|
|
STRUCT_FLD(system_vars, NULL),
|
|
|
|
/* reserved for dependency checking */
|
|
/* void* */
|
|
STRUCT_FLD(__reserved1, NULL)
|
|
};
|
|
|
|
/***********************************************************************
|
|
Common function to fill any of the dynamic tables:
|
|
INFORMATION_SCHEMA.innodb_trx
|
|
INFORMATION_SCHEMA.innodb_locks
|
|
INFORMATION_SCHEMA.innodb_lock_waits */
|
|
static
|
|
int
|
|
trx_i_s_common_fill_table(
|
|
/*======================*/
|
|
/* out: 0 on success */
|
|
THD* thd, /* in: thread */
|
|
TABLE_LIST* tables, /* in/out: tables to fill */
|
|
COND* cond) /* in: condition (not used) */
|
|
{
|
|
const char* table_name;
|
|
int ret;
|
|
trx_i_s_cache_t* cache;
|
|
|
|
DBUG_ENTER("trx_i_s_common_fill_table");
|
|
|
|
/* deny access to non-superusers */
|
|
if (check_global_access(thd, PROCESS_ACL)) {
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
/* minimize the number of places where global variables are
|
|
referenced */
|
|
cache = trx_i_s_cache;
|
|
|
|
/* which table we have to fill? */
|
|
table_name = tables->schema_table_name;
|
|
/* or table_name = tables->schema_table->table_name; */
|
|
|
|
RETURN_IF_INNODB_NOT_STARTED(table_name);
|
|
|
|
/* update the cache */
|
|
trx_i_s_cache_start_write(cache);
|
|
trx_i_s_possibly_fetch_data_into_cache(cache);
|
|
trx_i_s_cache_end_write(cache);
|
|
|
|
if (trx_i_s_cache_is_truncated(cache)) {
|
|
|
|
/* XXX show warning to user if possible */
|
|
fprintf(stderr, "Warning: data in %s truncated due to "
|
|
"memory limit of %d bytes\n", table_name,
|
|
TRX_I_S_MEM_LIMIT);
|
|
}
|
|
|
|
ret = 0;
|
|
|
|
trx_i_s_cache_start_read(cache);
|
|
|
|
if (innobase_strcasecmp(table_name, "innodb_trx") == 0) {
|
|
|
|
if (fill_innodb_trx_from_cache(
|
|
cache, thd, tables->table) != 0) {
|
|
|
|
ret = 1;
|
|
}
|
|
|
|
} else if (innobase_strcasecmp(table_name, "innodb_locks") == 0) {
|
|
|
|
if (fill_innodb_locks_from_cache(
|
|
cache, thd, tables->table) != 0) {
|
|
|
|
ret = 1;
|
|
}
|
|
|
|
} else if (innobase_strcasecmp(table_name, "innodb_lock_waits") == 0) {
|
|
|
|
if (fill_innodb_lock_waits_from_cache(
|
|
cache, thd, tables->table) != 0) {
|
|
|
|
ret = 1;
|
|
}
|
|
|
|
} else {
|
|
|
|
/* huh! what happened!? */
|
|
fprintf(stderr,
|
|
"InnoDB: trx_i_s_common_fill_table() was "
|
|
"called to fill unknown table: %s.\n"
|
|
"This function only knows how to fill "
|
|
"innodb_trx, innodb_locks and "
|
|
"innodb_lock_waits tables.\n", table_name);
|
|
|
|
ret = 1;
|
|
}
|
|
|
|
trx_i_s_cache_end_read(cache);
|
|
|
|
#if 0
|
|
DBUG_RETURN(ret);
|
|
#else
|
|
/* if this function returns something else than 0 then a
|
|
deadlock occurs between the mysqld server and mysql client,
|
|
see http://bugs.mysql.com/29900 ; when that bug is resolved
|
|
we can enable the DBUG_RETURN(ret) above */
|
|
DBUG_RETURN(0);
|
|
#endif
|
|
}
|
|
|
|
/* Fields of the dynamic table information_schema.innodb_cmp. */
|
|
static ST_FIELD_INFO i_s_cmp_fields_info[] =
|
|
{
|
|
{STRUCT_FLD(field_name, "page_size"),
|
|
STRUCT_FLD(field_length, 5),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, "Compressed Page Size"),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
{STRUCT_FLD(field_name, "compress_ops"),
|
|
STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, "Total Number of Compressions"),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
{STRUCT_FLD(field_name, "compress_ops_ok"),
|
|
STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, "Total Number of"
|
|
" Successful Compressions"),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
{STRUCT_FLD(field_name, "compress_time"),
|
|
STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, "Total Duration of Compressions,"
|
|
" in Seconds"),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
{STRUCT_FLD(field_name, "uncompress_ops"),
|
|
STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, "Total Number of Decompressions"),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
{STRUCT_FLD(field_name, "uncompress_time"),
|
|
STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, "Total Duration of Decompressions,"
|
|
" in Seconds"),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
END_OF_ST_FIELD_INFO
|
|
};
|
|
|
|
|
|
/***********************************************************************
|
|
Fill the dynamic table information_schema.innodb_cmp or
|
|
innodb_cmp_reset. */
|
|
static
|
|
int
|
|
i_s_cmp_fill_low(
|
|
/*=============*/
|
|
/* out: 0 on success, 1 on failure */
|
|
THD* thd, /* in: thread */
|
|
TABLE_LIST* tables, /* in/out: tables to fill */
|
|
COND* cond, /* in: condition (ignored) */
|
|
ibool reset) /* in: TRUE=reset cumulated counts */
|
|
{
|
|
TABLE* table = (TABLE *) tables->table;
|
|
int status = 0;
|
|
|
|
DBUG_ENTER("i_s_cmp_fill_low");
|
|
|
|
/* deny access to non-superusers */
|
|
if (check_global_access(thd, PROCESS_ACL)) {
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
RETURN_IF_INNODB_NOT_STARTED(tables->schema_table_name);
|
|
|
|
for (uint i = 0; i < PAGE_ZIP_NUM_SSIZE - 1; i++) {
|
|
page_zip_stat_t* zip_stat = &page_zip_stat[i];
|
|
|
|
table->field[0]->store(PAGE_ZIP_MIN_SIZE << i);
|
|
|
|
/* The cumulated counts are not protected by any
|
|
mutex. Thus, some operation in page0zip.c could
|
|
increment a counter between the time we read it and
|
|
clear it. We could introduce mutex protection, but it
|
|
could cause a measureable performance hit in
|
|
page0zip.c. */
|
|
table->field[1]->store(zip_stat->compressed);
|
|
table->field[2]->store(zip_stat->compressed_ok);
|
|
table->field[3]->store(
|
|
(ulong) (zip_stat->compressed_usec / 1000000));
|
|
table->field[4]->store(zip_stat->decompressed);
|
|
table->field[5]->store(
|
|
(ulong) (zip_stat->decompressed_usec / 1000000));
|
|
|
|
if (reset) {
|
|
memset(zip_stat, 0, sizeof *zip_stat);
|
|
}
|
|
|
|
if (schema_table_store_record(thd, table)) {
|
|
status = 1;
|
|
break;
|
|
}
|
|
}
|
|
|
|
DBUG_RETURN(status);
|
|
}
|
|
|
|
/***********************************************************************
|
|
Fill the dynamic table information_schema.innodb_cmp. */
|
|
static
|
|
int
|
|
i_s_cmp_fill(
|
|
/*=========*/
|
|
/* out: 0 on success, 1 on failure */
|
|
THD* thd, /* in: thread */
|
|
TABLE_LIST* tables, /* in/out: tables to fill */
|
|
COND* cond) /* in: condition (ignored) */
|
|
{
|
|
return(i_s_cmp_fill_low(thd, tables, cond, FALSE));
|
|
}
|
|
|
|
/***********************************************************************
|
|
Fill the dynamic table information_schema.innodb_cmp_reset. */
|
|
static
|
|
int
|
|
i_s_cmp_reset_fill(
|
|
/*===============*/
|
|
/* out: 0 on success, 1 on failure */
|
|
THD* thd, /* in: thread */
|
|
TABLE_LIST* tables, /* in/out: tables to fill */
|
|
COND* cond) /* in: condition (ignored) */
|
|
{
|
|
return(i_s_cmp_fill_low(thd, tables, cond, TRUE));
|
|
}
|
|
|
|
/***********************************************************************
|
|
Bind the dynamic table information_schema.innodb_cmp. */
|
|
static
|
|
int
|
|
i_s_cmp_init(
|
|
/*=========*/
|
|
/* out: 0 on success */
|
|
void* p) /* in/out: table schema object */
|
|
{
|
|
DBUG_ENTER("i_s_cmp_init");
|
|
ST_SCHEMA_TABLE* schema = (ST_SCHEMA_TABLE*) p;
|
|
|
|
schema->fields_info = i_s_cmp_fields_info;
|
|
schema->fill_table = i_s_cmp_fill;
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
/***********************************************************************
|
|
Bind the dynamic table information_schema.innodb_cmp_reset. */
|
|
static
|
|
int
|
|
i_s_cmp_reset_init(
|
|
/*===============*/
|
|
/* out: 0 on success */
|
|
void* p) /* in/out: table schema object */
|
|
{
|
|
DBUG_ENTER("i_s_cmp_reset_init");
|
|
ST_SCHEMA_TABLE* schema = (ST_SCHEMA_TABLE*) p;
|
|
|
|
schema->fields_info = i_s_cmp_fields_info;
|
|
schema->fill_table = i_s_cmp_reset_fill;
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
UNIV_INTERN struct st_mysql_plugin i_s_innodb_cmp =
|
|
{
|
|
/* the plugin type (a MYSQL_XXX_PLUGIN value) */
|
|
/* int */
|
|
STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN),
|
|
|
|
/* pointer to type-specific plugin descriptor */
|
|
/* void* */
|
|
STRUCT_FLD(info, &i_s_info),
|
|
|
|
/* plugin name */
|
|
/* const char* */
|
|
STRUCT_FLD(name, "INNODB_CMP"),
|
|
|
|
/* plugin author (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(author, plugin_author),
|
|
|
|
/* general descriptive text (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(descr, "Statistics for the InnoDB compression"),
|
|
|
|
/* the plugin license (PLUGIN_LICENSE_XXX) */
|
|
/* int */
|
|
STRUCT_FLD(license, PLUGIN_LICENSE_GPL),
|
|
|
|
/* the function to invoke when plugin is loaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(init, i_s_cmp_init),
|
|
|
|
/* the function to invoke when plugin is unloaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(deinit, i_s_common_deinit),
|
|
|
|
/* plugin version (for SHOW PLUGINS) */
|
|
/* unsigned int */
|
|
STRUCT_FLD(version, INNODB_VERSION_SHORT),
|
|
|
|
/* struct st_mysql_show_var* */
|
|
STRUCT_FLD(status_vars, NULL),
|
|
|
|
/* struct st_mysql_sys_var** */
|
|
STRUCT_FLD(system_vars, NULL),
|
|
|
|
/* reserved for dependency checking */
|
|
/* void* */
|
|
STRUCT_FLD(__reserved1, NULL)
|
|
};
|
|
|
|
UNIV_INTERN struct st_mysql_plugin i_s_innodb_cmp_reset =
|
|
{
|
|
/* the plugin type (a MYSQL_XXX_PLUGIN value) */
|
|
/* int */
|
|
STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN),
|
|
|
|
/* pointer to type-specific plugin descriptor */
|
|
/* void* */
|
|
STRUCT_FLD(info, &i_s_info),
|
|
|
|
/* plugin name */
|
|
/* const char* */
|
|
STRUCT_FLD(name, "INNODB_CMP_RESET"),
|
|
|
|
/* plugin author (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(author, plugin_author),
|
|
|
|
/* general descriptive text (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(descr, "Statistics for the InnoDB compression;"
|
|
" reset cumulated counts"),
|
|
|
|
/* the plugin license (PLUGIN_LICENSE_XXX) */
|
|
/* int */
|
|
STRUCT_FLD(license, PLUGIN_LICENSE_GPL),
|
|
|
|
/* the function to invoke when plugin is loaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(init, i_s_cmp_reset_init),
|
|
|
|
/* the function to invoke when plugin is unloaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(deinit, i_s_common_deinit),
|
|
|
|
/* plugin version (for SHOW PLUGINS) */
|
|
/* unsigned int */
|
|
STRUCT_FLD(version, INNODB_VERSION_SHORT),
|
|
|
|
/* struct st_mysql_show_var* */
|
|
STRUCT_FLD(status_vars, NULL),
|
|
|
|
/* struct st_mysql_sys_var** */
|
|
STRUCT_FLD(system_vars, NULL),
|
|
|
|
/* reserved for dependency checking */
|
|
/* void* */
|
|
STRUCT_FLD(__reserved1, NULL)
|
|
};
|
|
|
|
/* Fields of the dynamic table information_schema.innodb_cmpmem. */
|
|
static ST_FIELD_INFO i_s_cmpmem_fields_info[] =
|
|
{
|
|
{STRUCT_FLD(field_name, "page_size"),
|
|
STRUCT_FLD(field_length, 5),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, "Buddy Block Size"),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
{STRUCT_FLD(field_name, "pages_used"),
|
|
STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, "Currently in Use"),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
{STRUCT_FLD(field_name, "pages_free"),
|
|
STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, "Currently Available"),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
{STRUCT_FLD(field_name, "relocation_ops"),
|
|
STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, "Total Number of Relocations"),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
{STRUCT_FLD(field_name, "relocation_time"),
|
|
STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS),
|
|
STRUCT_FLD(field_type, MYSQL_TYPE_LONG),
|
|
STRUCT_FLD(value, 0),
|
|
STRUCT_FLD(field_flags, 0),
|
|
STRUCT_FLD(old_name, "Total Duration of Relocations,"
|
|
" in Seconds"),
|
|
STRUCT_FLD(open_method, SKIP_OPEN_TABLE)},
|
|
|
|
END_OF_ST_FIELD_INFO
|
|
};
|
|
|
|
/***********************************************************************
|
|
Fill the dynamic table information_schema.innodb_cmpmem or
|
|
innodb_cmpmem_reset. */
|
|
static
|
|
int
|
|
i_s_cmpmem_fill_low(
|
|
/*================*/
|
|
/* out: 0 on success, 1 on failure */
|
|
THD* thd, /* in: thread */
|
|
TABLE_LIST* tables, /* in/out: tables to fill */
|
|
COND* cond, /* in: condition (ignored) */
|
|
ibool reset) /* in: TRUE=reset cumulated counts */
|
|
{
|
|
TABLE* table = (TABLE *) tables->table;
|
|
int status = 0;
|
|
|
|
DBUG_ENTER("i_s_cmpmem_fill_low");
|
|
|
|
/* deny access to non-superusers */
|
|
if (check_global_access(thd, PROCESS_ACL)) {
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
RETURN_IF_INNODB_NOT_STARTED(tables->schema_table_name);
|
|
|
|
buf_pool_mutex_enter();
|
|
|
|
for (uint x = 0; x <= BUF_BUDDY_SIZES; x++) {
|
|
buf_buddy_stat_t* buddy_stat = &buf_buddy_stat[x];
|
|
|
|
table->field[0]->store(BUF_BUDDY_LOW << x);
|
|
table->field[1]->store(buddy_stat->used);
|
|
table->field[2]->store(UNIV_LIKELY(x < BUF_BUDDY_SIZES)
|
|
? UT_LIST_GET_LEN(buf_pool->zip_free[x])
|
|
: 0);
|
|
table->field[3]->store((longlong) buddy_stat->relocated, true);
|
|
table->field[4]->store(
|
|
(ulong) (buddy_stat->relocated_usec / 1000000));
|
|
|
|
if (reset) {
|
|
/* This is protected by buf_pool_mutex. */
|
|
buddy_stat->relocated = 0;
|
|
buddy_stat->relocated_usec = 0;
|
|
}
|
|
|
|
if (schema_table_store_record(thd, table)) {
|
|
status = 1;
|
|
break;
|
|
}
|
|
}
|
|
|
|
buf_pool_mutex_exit();
|
|
DBUG_RETURN(status);
|
|
}
|
|
|
|
/***********************************************************************
|
|
Fill the dynamic table information_schema.innodb_cmpmem. */
|
|
static
|
|
int
|
|
i_s_cmpmem_fill(
|
|
/*============*/
|
|
/* out: 0 on success, 1 on failure */
|
|
THD* thd, /* in: thread */
|
|
TABLE_LIST* tables, /* in/out: tables to fill */
|
|
COND* cond) /* in: condition (ignored) */
|
|
{
|
|
return(i_s_cmpmem_fill_low(thd, tables, cond, FALSE));
|
|
}
|
|
|
|
/***********************************************************************
|
|
Fill the dynamic table information_schema.innodb_cmpmem_reset. */
|
|
static
|
|
int
|
|
i_s_cmpmem_reset_fill(
|
|
/*==================*/
|
|
/* out: 0 on success, 1 on failure */
|
|
THD* thd, /* in: thread */
|
|
TABLE_LIST* tables, /* in/out: tables to fill */
|
|
COND* cond) /* in: condition (ignored) */
|
|
{
|
|
return(i_s_cmpmem_fill_low(thd, tables, cond, TRUE));
|
|
}
|
|
|
|
/***********************************************************************
|
|
Bind the dynamic table information_schema.innodb_cmpmem. */
|
|
static
|
|
int
|
|
i_s_cmpmem_init(
|
|
/*============*/
|
|
/* out: 0 on success */
|
|
void* p) /* in/out: table schema object */
|
|
{
|
|
DBUG_ENTER("i_s_cmpmem_init");
|
|
ST_SCHEMA_TABLE* schema = (ST_SCHEMA_TABLE*) p;
|
|
|
|
schema->fields_info = i_s_cmpmem_fields_info;
|
|
schema->fill_table = i_s_cmpmem_fill;
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
/***********************************************************************
|
|
Bind the dynamic table information_schema.innodb_cmpmem_reset. */
|
|
static
|
|
int
|
|
i_s_cmpmem_reset_init(
|
|
/*==================*/
|
|
/* out: 0 on success */
|
|
void* p) /* in/out: table schema object */
|
|
{
|
|
DBUG_ENTER("i_s_cmpmem_reset_init");
|
|
ST_SCHEMA_TABLE* schema = (ST_SCHEMA_TABLE*) p;
|
|
|
|
schema->fields_info = i_s_cmpmem_fields_info;
|
|
schema->fill_table = i_s_cmpmem_reset_fill;
|
|
|
|
DBUG_RETURN(0);
|
|
}
|
|
|
|
UNIV_INTERN struct st_mysql_plugin i_s_innodb_cmpmem =
|
|
{
|
|
/* the plugin type (a MYSQL_XXX_PLUGIN value) */
|
|
/* int */
|
|
STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN),
|
|
|
|
/* pointer to type-specific plugin descriptor */
|
|
/* void* */
|
|
STRUCT_FLD(info, &i_s_info),
|
|
|
|
/* plugin name */
|
|
/* const char* */
|
|
STRUCT_FLD(name, "INNODB_CMPMEM"),
|
|
|
|
/* plugin author (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(author, plugin_author),
|
|
|
|
/* general descriptive text (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(descr, "Statistics for the InnoDB compressed buffer pool"),
|
|
|
|
/* the plugin license (PLUGIN_LICENSE_XXX) */
|
|
/* int */
|
|
STRUCT_FLD(license, PLUGIN_LICENSE_GPL),
|
|
|
|
/* the function to invoke when plugin is loaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(init, i_s_cmpmem_init),
|
|
|
|
/* the function to invoke when plugin is unloaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(deinit, i_s_common_deinit),
|
|
|
|
/* plugin version (for SHOW PLUGINS) */
|
|
/* unsigned int */
|
|
STRUCT_FLD(version, INNODB_VERSION_SHORT),
|
|
|
|
/* struct st_mysql_show_var* */
|
|
STRUCT_FLD(status_vars, NULL),
|
|
|
|
/* struct st_mysql_sys_var** */
|
|
STRUCT_FLD(system_vars, NULL),
|
|
|
|
/* reserved for dependency checking */
|
|
/* void* */
|
|
STRUCT_FLD(__reserved1, NULL)
|
|
};
|
|
|
|
UNIV_INTERN struct st_mysql_plugin i_s_innodb_cmpmem_reset =
|
|
{
|
|
/* the plugin type (a MYSQL_XXX_PLUGIN value) */
|
|
/* int */
|
|
STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN),
|
|
|
|
/* pointer to type-specific plugin descriptor */
|
|
/* void* */
|
|
STRUCT_FLD(info, &i_s_info),
|
|
|
|
/* plugin name */
|
|
/* const char* */
|
|
STRUCT_FLD(name, "INNODB_CMPMEM_RESET"),
|
|
|
|
/* plugin author (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(author, plugin_author),
|
|
|
|
/* general descriptive text (for SHOW PLUGINS) */
|
|
/* const char* */
|
|
STRUCT_FLD(descr, "Statistics for the InnoDB compressed buffer pool;"
|
|
" reset cumulated counts"),
|
|
|
|
/* the plugin license (PLUGIN_LICENSE_XXX) */
|
|
/* int */
|
|
STRUCT_FLD(license, PLUGIN_LICENSE_GPL),
|
|
|
|
/* the function to invoke when plugin is loaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(init, i_s_cmpmem_reset_init),
|
|
|
|
/* the function to invoke when plugin is unloaded */
|
|
/* int (*)(void*); */
|
|
STRUCT_FLD(deinit, i_s_common_deinit),
|
|
|
|
/* plugin version (for SHOW PLUGINS) */
|
|
/* unsigned int */
|
|
STRUCT_FLD(version, INNODB_VERSION_SHORT),
|
|
|
|
/* struct st_mysql_show_var* */
|
|
STRUCT_FLD(status_vars, NULL),
|
|
|
|
/* struct st_mysql_sys_var** */
|
|
STRUCT_FLD(system_vars, NULL),
|
|
|
|
/* reserved for dependency checking */
|
|
/* void* */
|
|
STRUCT_FLD(__reserved1, NULL)
|
|
};
|
|
|
|
/***********************************************************************
|
|
Unbind a dynamic INFORMATION_SCHEMA table. */
|
|
static
|
|
int
|
|
i_s_common_deinit(
|
|
/*==============*/
|
|
/* out: 0 on success */
|
|
void* p) /* in/out: table schema object */
|
|
{
|
|
DBUG_ENTER("i_s_common_deinit");
|
|
|
|
/* Do nothing */
|
|
|
|
DBUG_RETURN(0);
|
|
}
|