cleanup: extract transaction-related part of handlerton

into a separate transaction_participant structure

handlerton inherits it, so handlerton itself doesn't change.
but entities that only need to participate in a transaction,
like binlog or online alter log, use a transaction_participant
and no longer need to pretend to be a full-blown but invisible
storage engine which doesn't support create table.

Author: vuvova

include/mysql/plugin.h

@@ -645,7 +645,7 @@ struct st_mysql_storage_engine
   int interface_version;
 };
 
-struct handlerton;
+struct transaction_participant;
 
 
 /*
@@ -748,7 +748,7 @@ void mysql_query_cache_invalidate4(MYSQL_THD thd,
 /**
   Provide a handler data getter to simplify coding
 */
-void *thd_get_ha_data(const MYSQL_THD thd, const struct handlerton *hton);
+void *thd_get_ha_data(const MYSQL_THD thd, const struct transaction_participant *hton);
 
 
 /**
@@ -769,10 +769,10 @@ void *thd_get_ha_data(const MYSQL_THD thd, const struct handlerton *hton);
   thd_set_ha_data() in this connection before, storage engine
   plugin lock gets released.
 
-  If handlerton::close_connection() didn't reset ha_data, server does
-  it immediately after calling handlerton::close_connection().
+  If transaction_participant::close_connection() didn't reset ha_data, server
+  does it immediately after calling transaction_participant::close_connection()
 */
-void thd_set_ha_data(MYSQL_THD thd, const struct handlerton *hton,
+void thd_set_ha_data(MYSQL_THD thd, const struct transaction_participant *hton,
                      const void *ha_data);
 
 

include/mysql/plugin_audit.h.pp

@@ -643,7 +643,7 @@
 {
   int interface_version;
 };
-struct handlerton;
+struct transaction_participant;
  struct Mysql_replication {
    int interface_version;
  };
@@ -671,8 +671,8 @@
 void mysql_query_cache_invalidate4(THD* thd,
                                    const char *key, unsigned int key_length,
                                    int using_trx);
-void *thd_get_ha_data(const THD* thd, const struct handlerton *hton);
-void thd_set_ha_data(THD* thd, const struct handlerton *hton,
+void *thd_get_ha_data(const THD* thd, const struct transaction_participant *hton);
+void thd_set_ha_data(THD* thd, const struct transaction_participant *hton,
                      const void *ha_data);
 void thd_wakeup_subsequent_commits(THD* thd, int wakeup_error);
 }

include/mysql/plugin_auth.h.pp

@@ -643,7 +643,7 @@
 {
   int interface_version;
 };
-struct handlerton;
+struct transaction_participant;
  struct Mysql_replication {
    int interface_version;
  };
@@ -671,8 +671,8 @@
 void mysql_query_cache_invalidate4(THD* thd,
                                    const char *key, unsigned int key_length,
                                    int using_trx);
-void *thd_get_ha_data(const THD* thd, const struct handlerton *hton);
-void thd_set_ha_data(THD* thd, const struct handlerton *hton,
+void *thd_get_ha_data(const THD* thd, const struct transaction_participant *hton);
+void thd_set_ha_data(THD* thd, const struct transaction_participant *hton,
                      const void *ha_data);
 void thd_wakeup_subsequent_commits(THD* thd, int wakeup_error);
 }

include/mysql/plugin_data_type.h.pp

@@ -643,7 +643,7 @@
 {
   int interface_version;
 };
-struct handlerton;
+struct transaction_participant;
  struct Mysql_replication {
    int interface_version;
  };
@@ -671,8 +671,8 @@
 void mysql_query_cache_invalidate4(THD* thd,
                                    const char *key, unsigned int key_length,
                                    int using_trx);
-void *thd_get_ha_data(const THD* thd, const struct handlerton *hton);
-void thd_set_ha_data(THD* thd, const struct handlerton *hton,
+void *thd_get_ha_data(const THD* thd, const struct transaction_participant *hton);
+void thd_set_ha_data(THD* thd, const struct transaction_participant *hton,
                      const void *ha_data);
 void thd_wakeup_subsequent_commits(THD* thd, int wakeup_error);
 }

include/mysql/plugin_encryption.h.pp

@@ -643,7 +643,7 @@
 {
   int interface_version;
 };
-struct handlerton;
+struct transaction_participant;
  struct Mysql_replication {
    int interface_version;
  };
@@ -671,8 +671,8 @@
 void mysql_query_cache_invalidate4(THD* thd,
                                    const char *key, unsigned int key_length,
                                    int using_trx);
-void *thd_get_ha_data(const THD* thd, const struct handlerton *hton);
-void thd_set_ha_data(THD* thd, const struct handlerton *hton,
+void *thd_get_ha_data(const THD* thd, const struct transaction_participant *hton);
+void thd_set_ha_data(THD* thd, const struct transaction_participant *hton,
                      const void *ha_data);
 void thd_wakeup_subsequent_commits(THD* thd, int wakeup_error);
 }

include/mysql/plugin_ftparser.h.pp

@@ -595,7 +595,7 @@
 {
   int interface_version;
 };
-struct handlerton;
+struct transaction_participant;
  struct Mysql_replication {
    int interface_version;
  };
@@ -623,8 +623,8 @@
 void mysql_query_cache_invalidate4(THD* thd,
                                    const char *key, unsigned int key_length,
                                    int using_trx);
-void *thd_get_ha_data(const THD* thd, const struct handlerton *hton);
-void thd_set_ha_data(THD* thd, const struct handlerton *hton,
+void *thd_get_ha_data(const THD* thd, const struct transaction_participant *hton);
+void thd_set_ha_data(THD* thd, const struct transaction_participant *hton,
                      const void *ha_data);
 void thd_wakeup_subsequent_commits(THD* thd, int wakeup_error);
 }

include/mysql/plugin_function.h.pp

@@ -643,7 +643,7 @@
 {
   int interface_version;
 };
-struct handlerton;
+struct transaction_participant;
  struct Mysql_replication {
    int interface_version;
  };
@@ -671,8 +671,8 @@
 void mysql_query_cache_invalidate4(THD* thd,
                                    const char *key, unsigned int key_length,
                                    int using_trx);
-void *thd_get_ha_data(const THD* thd, const struct handlerton *hton);
-void thd_set_ha_data(THD* thd, const struct handlerton *hton,
+void *thd_get_ha_data(const THD* thd, const struct transaction_participant *hton);
+void thd_set_ha_data(THD* thd, const struct transaction_participant *hton,
                      const void *ha_data);
 void thd_wakeup_subsequent_commits(THD* thd, int wakeup_error);
 }

include/mysql/plugin_password_validation.h.pp

@@ -643,7 +643,7 @@
 {
   int interface_version;
 };
-struct handlerton;
+struct transaction_participant;
  struct Mysql_replication {
    int interface_version;
  };
@@ -671,8 +671,8 @@
 void mysql_query_cache_invalidate4(THD* thd,
                                    const char *key, unsigned int key_length,
                                    int using_trx);
-void *thd_get_ha_data(const THD* thd, const struct handlerton *hton);
-void thd_set_ha_data(THD* thd, const struct handlerton *hton,
+void *thd_get_ha_data(const THD* thd, const struct transaction_participant *hton);
+void thd_set_ha_data(THD* thd, const struct transaction_participant *hton,
                      const void *ha_data);
 void thd_wakeup_subsequent_commits(THD* thd, int wakeup_error);
 }