1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
|
/* -*- mode: C++; c-basic-offset: 4; indent-tabs-mode: nil -*- */
// vim: ft=cpp:expandtab:ts=8:sw=4:softtabstop=4:
#ident "$Id$"
/*======
This file is part of TokuDB
Copyright (c) 2006, 2015, Percona and/or its affiliates. All rights reserved.
TokuDBis is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License, version 2,
as published by the Free Software Foundation.
TokuDB 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 General Public License for more details.
You should have received a copy of the GNU General Public License
along with TokuDB. If not, see <http://www.gnu.org/licenses/>.
======= */
#ident "Copyright (c) 2006, 2015, Percona and/or its affiliates. All rights reserved."
#ifndef _HATOKU_HTON_H
#define _HATOKU_HTON_H
#include "hatoku_defines.h"
#include "tokudb_debug.h"
#include "tokudb_information_schema.h"
#include "tokudb_memory.h"
#include "tokudb_thread.h"
#include "tokudb_time.h"
#include "tokudb_txn.h"
#include "tokudb_sysvars.h"
extern handlerton* tokudb_hton;
extern DB_ENV* db_env;
inline tokudb::sysvars::row_format_t toku_compression_method_to_row_format(
toku_compression_method method) {
switch (method) {
case TOKU_NO_COMPRESSION:
return tokudb::sysvars::SRV_ROW_FORMAT_UNCOMPRESSED;
case TOKU_ZLIB_WITHOUT_CHECKSUM_METHOD:
case TOKU_ZLIB_METHOD:
return tokudb::sysvars::SRV_ROW_FORMAT_ZLIB;
case TOKU_SNAPPY_METHOD:
return tokudb::sysvars::SRV_ROW_FORMAT_SNAPPY;
case TOKU_QUICKLZ_METHOD:
return tokudb::sysvars::SRV_ROW_FORMAT_QUICKLZ;
case TOKU_LZMA_METHOD:
return tokudb::sysvars::SRV_ROW_FORMAT_LZMA;
case TOKU_DEFAULT_COMPRESSION_METHOD:
return tokudb::sysvars::SRV_ROW_FORMAT_DEFAULT;
case TOKU_FAST_COMPRESSION_METHOD:
return tokudb::sysvars::SRV_ROW_FORMAT_FAST;
case TOKU_SMALL_COMPRESSION_METHOD:
return tokudb::sysvars::SRV_ROW_FORMAT_SMALL;
default:
assert_unreachable();
}
}
inline toku_compression_method row_format_to_toku_compression_method(
tokudb::sysvars::row_format_t row_format) {
switch (row_format) {
case tokudb::sysvars::SRV_ROW_FORMAT_UNCOMPRESSED:
return TOKU_NO_COMPRESSION;
case tokudb::sysvars::SRV_ROW_FORMAT_QUICKLZ:
case tokudb::sysvars::SRV_ROW_FORMAT_FAST:
return TOKU_QUICKLZ_METHOD;
case tokudb::sysvars::SRV_ROW_FORMAT_SNAPPY:
return TOKU_SNAPPY_METHOD;
case tokudb::sysvars::SRV_ROW_FORMAT_ZLIB:
case tokudb::sysvars::SRV_ROW_FORMAT_DEFAULT:
return TOKU_ZLIB_WITHOUT_CHECKSUM_METHOD;
case tokudb::sysvars::SRV_ROW_FORMAT_LZMA:
case tokudb::sysvars::SRV_ROW_FORMAT_SMALL:
return TOKU_LZMA_METHOD;
default:
assert_unreachable();
}
}
inline enum row_type row_format_to_row_type(
tokudb::sysvars::row_format_t row_format) {
#if TOKU_INCLUDE_ROW_TYPE_COMPRESSION
switch (row_format) {
case tokudb::sysvars::SRV_ROW_FORMAT_UNCOMPRESSED:
return ROW_TYPE_TOKU_UNCOMPRESSED;
case tokudb::sysvars::SRV_ROW_FORMAT_ZLIB:
return ROW_TYPE_TOKU_ZLIB;
case tokudb::sysvars::SRV_ROW_FORMAT_SNAPPY:
return ROW_TYPE_TOKU_SNAPPY;
case tokudb::sysvars::SRV_ROW_FORMAT_QUICKLZ:
return ROW_TYPE_TOKU_QUICKLZ;
case tokudb::sysvars::SRV_ROW_FORMAT_LZMA:
return ROW_TYPE_TOKU_LZMA;
case tokudb::sysvars::SRV_ROW_FORMAT_SMALL:
return ROW_TYPE_TOKU_SMALL;
case tokudb::sysvars::SRV_ROW_FORMAT_FAST:
return ROW_TYPE_TOKU_FAST;
case tokudb::sysvars::SRV_ROW_FORMAT_DEFAULT:
return ROW_TYPE_DEFAULT;
}
#endif
return ROW_TYPE_DEFAULT;
}
inline tokudb::sysvars::row_format_t row_type_to_row_format(
enum row_type type) {
#if TOKU_INCLUDE_ROW_TYPE_COMPRESSION
switch (type) {
case ROW_TYPE_TOKU_UNCOMPRESSED:
return tokudb::sysvars::SRV_ROW_FORMAT_UNCOMPRESSED;
case ROW_TYPE_TOKU_ZLIB:
return tokudb::sysvars::SRV_ROW_FORMAT_ZLIB;
case ROW_TYPE_TOKU_SNAPPY:
return tokudb::sysvars::SRV_ROW_FORMAT_SNAPPY;
case ROW_TYPE_TOKU_QUICKLZ:
return tokudb::sysvars::SRV_ROW_FORMAT_QUICKLZ;
case ROW_TYPE_TOKU_LZMA:
return tokudb::sysvars::SRV_ROW_FORMAT_LZMA;
case ROW_TYPE_TOKU_SMALL:
return tokudb::sysvars::SRV_ROW_FORMAT_SMALL;
case ROW_TYPE_TOKU_FAST:
return tokudb::sysvars::SRV_ROW_FORMAT_FAST;
case ROW_TYPE_DEFAULT:
return tokudb::sysvars::SRV_ROW_FORMAT_DEFAULT;
default:
return tokudb::sysvars::SRV_ROW_FORMAT_DEFAULT;
}
#endif
return tokudb::sysvars::SRV_ROW_FORMAT_DEFAULT;
}
inline enum row_type toku_compression_method_to_row_type(
toku_compression_method method) {
return row_format_to_row_type(
toku_compression_method_to_row_format(method));
}
inline toku_compression_method row_type_to_toku_compression_method(
enum row_type type) {
return row_format_to_toku_compression_method(row_type_to_row_format(type));
}
void tokudb_checkpoint_lock(THD * thd);
void tokudb_checkpoint_unlock(THD * thd);
inline uint64_t tokudb_get_lock_wait_time_callback(uint64_t default_wait_time) {
THD *thd = current_thd;
return tokudb::sysvars::lock_timeout(thd);
}
inline uint64_t tokudb_get_loader_memory_size_callback(void) {
THD *thd = current_thd;
return tokudb::sysvars::loader_memory_size(thd);
}
inline uint64_t tokudb_get_killed_time_callback(uint64_t default_killed_time) {
THD *thd = current_thd;
return tokudb::sysvars::killed_time(thd);
}
inline int tokudb_killed_callback(void) {
THD *thd = current_thd;
return thd_killed(thd);
}
inline bool tokudb_killed_thd_callback(void *extra, uint64_t deleted_rows) {
THD *thd = static_cast<THD *>(extra);
return thd_killed(thd) != 0;
}
extern HASH tokudb_open_tables;
extern tokudb::thread::mutex_t tokudb_mutex;
extern const char* tokudb_hton_name;
extern int tokudb_hton_initialized;
extern tokudb::thread::rwlock_t tokudb_hton_initialized_lock;
void toku_hton_update_primary_key_bytes_inserted(uint64_t row_size);
void tokudb_split_dname(
const char* dname,
String& database_name,
String& table_name,
String& dictionary_name);
void tokudb_pretty_left_key(const DB* db, const DBT* key, String* out);
void tokudb_pretty_right_key(const DB* db, const DBT* key, String* out);
const char *tokudb_get_index_name(DB* db);
#endif //#ifdef _HATOKU_HTON
|
