Adding upstream version 1:10.5.12.upstream/1%10.5.12upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 179 insertions, 0 deletions

diff --git a/storage/mroonga/mrn_table.hpp b/storage/mroonga/mrn_table.hpp
new file mode 100644
index 00000000..5ef7bc71
--- /dev/null
+++ b/storage/mroonga/mrn_table.hpp
@@ -0,0 +1,179 @@
+/* -*- c-basic-offset: 2 -*- */
+/*
+  Copyright(C) 2011-2013 Kentoku SHIBA
+  Copyright(C) 2011-2015 Kouhei Sutou <kou@clear-code.com>
+
+  This library is free software; you can redistribute it and/or
+  modify it under the terms of the GNU Lesser General Public
+  License as published by the Free Software Foundation; either
+  version 2.1 of the License, or (at your option) any later version.
+
+  This library is distributed in the hope that it will be useful,
+  but WITHOUT ANY WARRANTY; without even the implied warranty of
+  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+  Lesser General Public License for more details.
+
+  You should have received a copy of the GNU Lesser General Public
+  License along with this library; if not, write to the Free Software
+  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1335  USA
+*/
+
+#ifndef MRN_TABLE_HPP_
+#define MRN_TABLE_HPP_
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+#include <groonga.h>
+
+typedef struct st_mroonga_long_term_share
+{
+  char                *table_name;
+  uint                table_name_length;
+
+  // for auto_increment (storage mode only)
+  mysql_mutex_t       auto_inc_mutex;
+  bool                auto_inc_inited;
+  ulonglong           auto_inc_value;
+} MRN_LONG_TERM_SHARE;
+
+typedef struct st_mroonga_share
+{
+  char                *table_name;
+  uint                table_name_length;
+  uint                use_count;
+  mysql_mutex_t       record_mutex;
+  THR_LOCK            lock;
+  TABLE_SHARE         *table_share;
+  TABLE_SHARE         *wrap_table_share;
+  MRN_LONG_TERM_SHARE *long_term_share;
+
+  char                *engine;
+  int                 engine_length;
+  char                *default_tokenizer;
+  int                 default_tokenizer_length;
+  char                *normalizer;
+  int                 normalizer_length;
+  char                *token_filters;
+  int                 token_filters_length;
+  plugin_ref          plugin;
+  handlerton          *hton;
+  char                **index_table;
+  char                **key_tokenizer;
+  char                **col_flags;
+  char                **col_type;
+  uint                *index_table_length;
+  uint                *key_tokenizer_length;
+  uint                *col_flags_length;
+  uint                *col_type_length;
+  uint                *wrap_key_nr;
+  uint                wrap_keys;
+  uint                base_keys;
+  KEY                 *wrap_key_info;
+  KEY                 *base_key_info;
+  uint                wrap_primary_key;
+  uint                base_primary_key;
+  bool                wrapper_mode;
+  bool                disable_keys;
+} MRN_SHARE;
+
+struct st_mrn_wrap_hton
+{
+  char path[FN_REFLEN + 1];
+  handlerton *hton;
+  st_mrn_wrap_hton *next;
+};
+
+struct st_mrn_slot_data
+{
+  grn_id last_insert_record_id;
+  st_mrn_wrap_hton *first_wrap_hton;
+  HA_CREATE_INFO *alter_create_info;
+  HA_CREATE_INFO *disable_keys_create_info;
+  char *alter_connect_string;
+  char *alter_comment;
+};
+
+#define MRN_SET_WRAP_ALTER_KEY(file, ha_alter_info) \
+  alter_table_operations base_handler_flags = ha_alter_info->handler_flags; \
+  ha_table_option_struct* base_option_struct = ha_alter_info->create_info->option_struct; \
+  KEY  *base_key_info_buffer = ha_alter_info->key_info_buffer; \
+  uint base_key_count = ha_alter_info->key_count; \
+  uint base_index_drop_count = ha_alter_info->index_drop_count; \
+  KEY  **base_index_drop_buffer = ha_alter_info->index_drop_buffer; \
+  uint base_index_add_count = ha_alter_info->index_add_count; \
+  uint *base_index_add_buffer = ha_alter_info->index_add_buffer; \
+  ha_alter_info->handler_flags = file->alter_handler_flags; \
+  ha_alter_info->create_info->option_struct = wrap_altered_table->s->option_struct; \
+  ha_alter_info->key_info_buffer = file->alter_key_info_buffer; \
+  ha_alter_info->key_count = file->alter_key_count; \
+  ha_alter_info->index_drop_count = file->alter_index_drop_count; \
+  ha_alter_info->index_drop_buffer = &file->alter_index_drop_buffer; \
+  ha_alter_info->index_add_count = file->alter_index_add_count; \
+  ha_alter_info->index_add_buffer = file->alter_index_add_buffer;
+
+#define MRN_SET_BASE_ALTER_KEY(share, table_share) \
+  ha_alter_info->handler_flags = base_handler_flags; \
+  ha_alter_info->create_info->option_struct = base_option_struct; \
+  ha_alter_info->key_info_buffer = base_key_info_buffer; \
+  ha_alter_info->key_count = base_key_count; \
+  ha_alter_info->index_drop_count = base_index_drop_count; \
+  ha_alter_info->index_drop_buffer = base_index_drop_buffer; \
+  ha_alter_info->index_add_count = base_index_add_count; \
+  ha_alter_info->index_add_buffer = base_index_add_buffer;
+
+#define MRN_SET_WRAP_SHARE_KEY(share, table_share)
+/*
+  table_share->keys = share->wrap_keys; \
+  table_share->key_info = share->wrap_key_info; \
+  table_share->primary_key = share->wrap_primary_key;
+*/
+
+#define MRN_SET_BASE_SHARE_KEY(share, table_share)
+/*
+  table_share->keys = share->base_keys; \
+  table_share->key_info = share->base_key_info; \
+  table_share->primary_key = share->base_primary_key;
+*/
+
+#define MRN_SET_WRAP_TABLE_KEY(file, table) \
+  table->key_info = file->wrap_key_info; \
+  table->s = share->wrap_table_share;
+
+#define MRN_SET_BASE_TABLE_KEY(file, table) \
+  table->key_info = file->base_key_info; \
+  table->s = share->table_share;
+
+#ifdef WITH_PARTITION_STORAGE_ENGINE
+void mrn_get_partition_info(const char *table_name, uint table_name_length,
+                            const TABLE *table, partition_element **part_elem,
+                            partition_element **sub_elem);
+#endif
+int mrn_parse_table_param(MRN_SHARE *share, TABLE *table);
+bool mrn_is_geo_key(const KEY *key_info);
+int mrn_add_index_param(MRN_SHARE *share, KEY *key_info, int i);
+int mrn_parse_index_param(MRN_SHARE *share, TABLE *table);
+int mrn_add_column_param(MRN_SHARE *share, Field *field, int i);
+int mrn_parse_column_param(MRN_SHARE *share, TABLE *table);
+MRN_SHARE *mrn_get_share(const char *table_name, TABLE *table, int *error);
+int mrn_free_share_alloc(MRN_SHARE *share);
+int mrn_free_share(MRN_SHARE *share);
+MRN_LONG_TERM_SHARE *mrn_get_long_term_share(const char *table_name,
+                                             uint table_name_length,
+                                             int *error);
+void mrn_free_long_term_share(MRN_LONG_TERM_SHARE *long_term_share);
+TABLE_SHARE *mrn_get_table_share(TABLE_LIST *table_list, int *error);
+TABLE_SHARE *mrn_create_tmp_table_share(TABLE_LIST *table_list, const char *path,
+                                        int *error);
+void mrn_free_tmp_table_share(TABLE_SHARE *table_share);
+KEY *mrn_create_key_info_for_table(MRN_SHARE *share, TABLE *table, int *error);
+void mrn_set_bitmap_by_key(MY_BITMAP *map, KEY *key_info);
+st_mrn_slot_data *mrn_get_slot_data(THD *thd, bool can_create);
+void mrn_clear_slot_data(THD *thd);
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif /* MRN_TABLE_HPP_ */