32
31
#include <stdexcept>
34
33
#include <boost/program_options.hpp>
35
#include <drizzled/program_options/config_file.h>
34
#include "drizzled/program_options/config_file.h"
36
35
#include <boost/thread/recursive_mutex.hpp>
37
36
#include <boost/thread/mutex.hpp>
38
37
#include <boost/thread/shared_mutex.hpp>
39
38
#include <boost/thread/condition_variable.hpp>
40
39
#include <boost/filesystem.hpp>
41
#include <boost/detail/atomic_count.hpp>
43
#include <drizzled/cached_directory.h>
44
#include <drizzled/charset.h>
45
#include <drizzled/data_home.h>
46
#include <drizzled/debug.h>
47
#include <drizzled/definition/cache.h>
48
#include <drizzled/drizzled.h>
41
#include "drizzled/internal/my_sys.h"
42
#include "drizzled/internal/my_bit.h"
43
#include <drizzled/my_hash.h>
44
#include <drizzled/error.h>
49
45
#include <drizzled/errmsg_print.h>
50
#include <drizzled/error.h>
51
#include <drizzled/global_buffer.h>
52
#include <drizzled/internal/my_bit.h>
53
#include <drizzled/internal/my_sys.h>
46
#include <drizzled/tztime.h>
47
#include <drizzled/sql_base.h>
48
#include <drizzled/show.h>
49
#include <drizzled/sql_parse.h>
54
50
#include <drizzled/item/cmpfunc.h>
51
#include <drizzled/session.h>
55
52
#include <drizzled/item/create.h>
56
#include <drizzled/message/cache.h>
57
#include <drizzled/module/load_list.h>
58
#include <drizzled/module/registry.h>
59
#include <drizzled/my_hash.h>
60
#include <drizzled/plugin/client.h>
61
#include <drizzled/plugin/error_message.h>
62
#include <drizzled/plugin/event_observer.h>
63
#include <drizzled/plugin/listen.h>
64
#include <drizzled/plugin/monitored_in_transaction.h>
65
#include <drizzled/plugin/scheduler.h>
66
#include <drizzled/plugin/storage_engine.h>
67
#include <drizzled/plugin/xa_resource_manager.h>
68
#include <drizzled/probes.h>
69
#include <drizzled/replication_services.h> /* For ReplicationServices::evaluateRegisteredPlugins() */
70
#include <drizzled/session.h>
71
#include <drizzled/session/cache.h>
72
#include <drizzled/show.h>
73
#include <drizzled/sql_base.h>
74
#include <drizzled/sql_parse.h>
75
#include <drizzled/temporal_format.h> /* For init_temporal_formats() */
76
#include <drizzled/tztime.h>
77
53
#include <drizzled/unireg.h>
78
#include <plugin/myisam/myisam.h>
80
#include "drizzled/visibility.h"
54
#include "drizzled/temporal_format.h" /* For init_temporal_formats() */
55
#include "drizzled/plugin/listen.h"
56
#include "drizzled/plugin/error_message.h"
57
#include "drizzled/plugin/client.h"
58
#include "drizzled/plugin/scheduler.h"
59
#include "drizzled/plugin/xa_resource_manager.h"
60
#include "drizzled/plugin/monitored_in_transaction.h"
61
#include "drizzled/replication_services.h" /* For ReplicationServices::evaluateRegisteredPlugins() */
62
#include "drizzled/probes.h"
63
#include "drizzled/session/cache.h"
64
#include "drizzled/charset.h"
65
#include "plugin/myisam/myisam.h"
66
#include "drizzled/drizzled.h"
67
#include "drizzled/module/registry.h"
68
#include "drizzled/module/load_list.h"
69
#include "drizzled/global_buffer.h"
71
#include "drizzled/definition/cache.h"
73
#include "drizzled/plugin/event_observer.h"
75
#include "drizzled/message/cache.h"
82
77
#include <google/protobuf/stubs/common.h>
84
#include <drizzled/refresh_version.h>
86
79
#if TIME_WITH_SYS_TIME
87
80
# include <sys/time.h>
1132
1151
config_options.add_options()
1133
1152
("help,?", po::value<bool>(&opt_help)->default_value(false)->zero_tokens(),
1134
_("Display this help and exit."))
1135
("daemon,d", po::value<bool>(&opt_daemon)->default_value(false)->zero_tokens(),
1136
_("Run as a daemon."))
1153
N_("Display this help and exit."))
1137
1154
("no-defaults", po::value<bool>()->default_value(false)->zero_tokens(),
1138
_("Configuration file defaults are not used if no-defaults is set"))
1155
N_("Configuration file defaults are not used if no-defaults is set"))
1139
1156
("defaults-file", po::value<vector<string> >()->composing()->notifier(&compose_defaults_file_list),
1140
_("Configuration file to use"))
1157
N_("Configuration file to use"))
1141
1158
("config-dir", po::value<fs::path>(&system_config_dir),
1142
_("Base location for config files"))
1159
N_("Base location for config files"))
1143
1160
("plugin-dir", po::value<fs::path>(&plugin_dir)->notifier(¬ify_plugin_dir),
1144
_("Directory for plugins."))
1161
N_("Directory for plugins."))
1147
1164
plugin_load_options.add_options()
1148
1165
("plugin-add", po::value<vector<string> >()->composing()->notifier(&compose_plugin_add),
1149
_("Optional comma separated list of plugins to load at startup in addition "
1166
N_("Optional comma separated list of plugins to load at startup in addition "
1150
1167
"to the default list of plugins. "
1151
1168
"[for example: --plugin_add=crc32,logger_gearman]"))
1152
1169
("plugin-remove", po::value<vector<string> >()->composing()->notifier(&compose_plugin_remove),
1153
_("Optional comma separated list of plugins to not load at startup. Effectively "
1170
N_("Optional comma separated list of plugins to not load at startup. Effectively "
1154
1171
"removes a plugin from the list of plugins to be loaded. "
1155
1172
"[for example: --plugin_remove=crc32,logger_gearman]"))
1156
1173
("plugin-load", po::value<string>()->notifier(¬ify_plugin_load)->default_value(PANDORA_PLUGIN_LIST),
1157
_("Optional comma separated list of plugins to load at starup instead of "
1174
N_("Optional comma separated list of plugins to load at starup instead of "
1158
1175
"the default plugin load list. "
1159
1176
"[for example: --plugin_load=crc32,logger_gearman]"))
1162
1179
long_options.add_options()
1163
1180
("auto-increment-increment", po::value<uint64_t>(&global_system_variables.auto_increment_increment)->default_value(1)->notifier(&check_limits_aii),
1164
_("Auto-increment columns are incremented by this"))
1181
N_("Auto-increment columns are incremented by this"))
1165
1182
("auto-increment-offset", po::value<uint64_t>(&global_system_variables.auto_increment_offset)->default_value(1)->notifier(&check_limits_aio),
1166
_("Offset added to Auto-increment columns. Used when auto-increment-increment != 1"))
1183
N_("Offset added to Auto-increment columns. Used when auto-increment-increment != 1"))
1167
1184
("basedir,b", po::value<fs::path>(&basedir),
1168
_("Path to installation directory. All paths are usually resolved "
1185
N_("Path to installation directory. All paths are usually resolved "
1169
1186
"relative to this."))
1170
1187
("chroot,r", po::value<string>(),
1171
_("Chroot drizzled daemon during startup."))
1188
N_("Chroot drizzled daemon during startup."))
1172
1189
("collation-server", po::value<string>(),
1173
_("Set the default collation."))
1190
N_("Set the default collation."))
1174
1191
("completion-type", po::value<uint32_t>(&global_system_variables.completion_type)->default_value(0)->notifier(&check_limits_completion_type),
1175
_("Default completion type."))
1176
("core-file", _("Write core on errors."))
1177
("datadir", po::value<fs::path>(&getDataHome()),
1178
_("Path to the database root."))
1192
N_("Default completion type."))
1193
("core-file", N_("Write core on errors."))
1194
("datadir", po::value<fs::path>(&data_home),
1195
N_("Path to the database root."))
1179
1196
("default-storage-engine", po::value<string>(),
1180
_("Set the default storage engine for tables."))
1197
N_("Set the default storage engine for tables."))
1181
1198
("default-time-zone", po::value<string>(),
1182
_("Set the default time zone."))
1199
N_("Set the default time zone."))
1183
1200
("exit-info,T", po::value<long>(),
1184
_("Used for debugging; Use at your own risk!"))
1201
N_("Used for debugging; Use at your own risk!"))
1185
1202
("gdb", po::value<bool>(&opt_debugging)->default_value(false)->zero_tokens(),
1186
_("Set up signals usable for debugging"))
1203
N_("Set up signals usable for debugging"))
1187
1204
("lc-time-name", po::value<string>(),
1188
_("Set the language used for the month names and the days of the week."))
1205
N_("Set the language used for the month names and the days of the week."))
1189
1206
("log-warnings,W", po::value<bool>(&global_system_variables.log_warnings)->default_value(false)->zero_tokens(),
1190
_("Log some not critical warnings to the log file."))
1207
N_("Log some not critical warnings to the log file."))
1191
1208
("pid-file", po::value<fs::path>(&pid_file),
1192
_("Pid file used by drizzled."))
1209
N_("Pid file used by drizzled."))
1193
1210
("port-open-timeout", po::value<uint32_t>(&drizzled_bind_timeout)->default_value(0),
1194
_("Maximum time in seconds to wait for the port to become free. "))
1211
N_("Maximum time in seconds to wait for the port to become free. "))
1195
1212
("replicate-query", po::value<bool>(&global_system_variables.replicate_query)->default_value(false)->zero_tokens(),
1196
_("Include the SQL query in replicated protobuf messages."))
1213
N_("Include the SQL query in replicated protobuf messages."))
1197
1214
("secure-file-priv", po::value<fs::path>(&secure_file_priv)->notifier(expand_secure_file_priv),
1198
_("Limit LOAD DATA, SELECT ... OUTFILE, and LOAD_FILE() to files "
1215
N_("Limit LOAD DATA, SELECT ... OUTFILE, and LOAD_FILE() to files "
1199
1216
"within specified directory"))
1200
1217
("server-id", po::value<uint32_t>(&server_id)->default_value(0),
1201
_("Uniquely identifies the server instance in the community of "
1218
N_("Uniquely identifies the server instance in the community of "
1202
1219
"replication partners."))
1203
1220
("skip-stack-trace",
1204
_("Don't print a stack trace on failure."))
1221
N_("Don't print a stack trace on failure."))
1205
1222
("symbolic-links,s", po::value<bool>(&internal::my_use_symdir)->default_value(IF_PURIFY(false,true))->zero_tokens(),
1206
_("Enable symbolic link support."))
1223
N_("Enable symbolic link support."))
1207
1224
("timed-mutexes", po::value<bool>(&internal::timed_mutexes)->default_value(false)->zero_tokens(),
1208
_("Specify whether to time mutexes (only InnoDB mutexes are currently "
1225
N_("Specify whether to time mutexes (only InnoDB mutexes are currently "
1210
1227
("tmpdir,t", po::value<string>(),
1211
_("Path for temporary files."))
1228
N_("Path for temporary files."))
1212
1229
("transaction-isolation", po::value<string>(),
1213
_("Default transaction isolation level."))
1214
("transaction-message-threshold", po::value<size_t>(&transaction_message_threshold)->default_value(1024*1024)->notifier(&check_limits_transaction_message_threshold),
1215
_("Max message size written to transaction log, valid values 131072 - 1048576 bytes."))
1230
N_("Default transaction isolation level."))
1231
("transaction-message-threshold", po::value<size_t>(&global_system_variables.transaction_message_threshold)->default_value(1024*1024)->notifier(&check_limits_transaction_message_threshold),
1232
N_("Max message size written to transaction log, valid values 131072 - 1048576 bytes."))
1216
1233
("user,u", po::value<string>(),
1217
_("Run drizzled daemon as user."))
1234
N_("Run drizzled daemon as user."))
1219
_("Output version information and exit."))
1236
N_("Output version information and exit."))
1220
1237
("back-log", po::value<back_log_constraints>(&back_log),
1221
_("The number of outstanding connection requests Drizzle can have. This "
1238
N_("The number of outstanding connection requests Drizzle can have. This "
1222
1239
"comes into play when the main Drizzle thread gets very many connection "
1223
1240
"requests in a very short time."))
1224
1241
("bulk-insert-buffer-size",
1225
1242
po::value<uint64_t>(&global_system_variables.bulk_insert_buff_size)->default_value(8192*1024),
1226
_("Size of tree cache used in bulk insert optimization. Note that this is "
1243
N_("Size of tree cache used in bulk insert optimization. Note that this is "
1227
1244
"a limit per thread!"))
1228
1245
("div-precision-increment", po::value<uint32_t>(&global_system_variables.div_precincrement)->default_value(4)->notifier(&check_limits_dpi),
1229
_("Precision of the result of '/' operator will be increased on that "
1246
N_("Precision of the result of '/' operator will be increased on that "
1231
1248
("group-concat-max-len", po::value<uint64_t>(&global_system_variables.group_concat_max_len)->default_value(1024)->notifier(&check_limits_gcml),
1232
_("The maximum length of the result of function group_concat."))
1249
N_("The maximum length of the result of function group_concat."))
1233
1250
("join-buffer-size", po::value<uint64_t>(&global_system_variables.join_buff_size)->default_value(128*1024L)->notifier(&check_limits_join_buffer_size),
1234
_("The size of the buffer that is used for full joins."))
1251
N_("The size of the buffer that is used for full joins."))
1235
1252
("join-heap-threshold",
1236
1253
po::value<uint64_t>()->default_value(0),
1237
_("A global cap on the amount of memory that can be allocated by session join buffers (0 means unlimited)"))
1254
N_("A global cap on the amount of memory that can be allocated by session join buffers (0 means unlimited)"))
1238
1255
("max-allowed-packet", po::value<uint32_t>(&global_system_variables.max_allowed_packet)->default_value(64*1024*1024L)->notifier(&check_limits_map),
1239
_("Max packetlength to send/receive from to server."))
1256
N_("Max packetlength to send/receive from to server."))
1257
("max-connect-errors", po::value<uint64_t>(&max_connect_errors)->default_value(MAX_CONNECT_ERRORS)->notifier(&check_limits_mce),
1258
N_("If there is more than this number of interrupted connections from a "
1259
"host this host will be blocked from further connections."))
1240
1260
("max-error-count", po::value<uint64_t>(&global_system_variables.max_error_count)->default_value(DEFAULT_ERROR_COUNT)->notifier(&check_limits_max_err_cnt),
1241
_("Max number of errors/warnings to store for a statement."))
1261
N_("Max number of errors/warnings to store for a statement."))
1242
1262
("max-heap-table-size", po::value<uint64_t>(&global_system_variables.max_heap_table_size)->default_value(16*1024*1024L)->notifier(&check_limits_mhts),
1243
_("Don't allow creation of heap tables bigger than this."))
1263
N_("Don't allow creation of heap tables bigger than this."))
1244
1264
("max-join-size", po::value<drizzled::ha_rows>(&global_system_variables.max_join_size)->default_value(INT32_MAX)->notifier(&check_limits_max_join_size),
1245
_("Joins that are probably going to read more than max_join_size records "
1265
N_("Joins that are probably going to read more than max_join_size records "
1246
1266
"return an error."))
1247
1267
("max-length-for-sort-data", po::value<uint64_t>(&global_system_variables.max_length_for_sort_data)->default_value(1024)->notifier(&check_limits_mlfsd),
1248
_("Max number of bytes in sorted records."))
1268
N_("Max number of bytes in sorted records."))
1249
1269
("max-seeks-for-key", po::value<uint64_t>(&global_system_variables.max_seeks_for_key)->default_value(ULONG_MAX)->notifier(&check_limits_msfk),
1250
_("Limit assumed max number of seeks when looking up rows based on a key"))
1270
N_("Limit assumed max number of seeks when looking up rows based on a key"))
1251
1271
("max-sort-length", po::value<size_t>(&global_system_variables.max_sort_length)->default_value(1024)->notifier(&check_limits_max_sort_length),
1252
_("The number of bytes to use when sorting BLOB or TEXT values "
1272
N_("The number of bytes to use when sorting BLOB or TEXT values "
1253
1273
"(only the first max_sort_length bytes of each value are used; the "
1254
1274
"rest are ignored)."))
1255
1275
("max-write-lock-count", po::value<uint64_t>(&max_write_lock_count)->default_value(UINT64_MAX),
1256
_("After this many write locks, allow some read locks to run in between."))
1276
N_("After this many write locks, allow some read locks to run in between."))
1257
1277
("min-examined-row-limit", po::value<uint64_t>(&global_system_variables.min_examined_row_limit)->default_value(0)->notifier(&check_limits_merl),
1258
_("Don't log queries which examine less than min_examined_row_limit "
1278
N_("Don't log queries which examine less than min_examined_row_limit "
1259
1279
"rows to file."))
1260
1280
("disable-optimizer-prune",
1261
_("Do not apply any heuristic(s) during query optimization to prune, "
1281
N_("Do not apply any heuristic(s) during query optimization to prune, "
1262
1282
"thus perform an exhaustive search from the optimizer search space."))
1263
1283
("optimizer-search-depth", po::value<uint32_t>(&global_system_variables.optimizer_search_depth)->default_value(0)->notifier(&check_limits_osd),
1264
_("Maximum depth of search performed by the query optimizer. Values "
1284
N_("Maximum depth of search performed by the query optimizer. Values "
1265
1285
"larger than the number of relations in a query result in better query "
1266
1286
"plans, but take longer to compile a query. Smaller values than the "
1267
1287
"number of tables in a relation result in faster optimization, but may "
1270
1290
"optimizer will switch to the original find_best (used for "
1271
1291
"testing/comparison)."))
1272
1292
("preload-buffer-size", po::value<uint64_t>(&global_system_variables.preload_buff_size)->default_value(32*1024L)->notifier(&check_limits_pbs),
1273
_("The size of the buffer that is allocated when preloading indexes"))
1293
N_("The size of the buffer that is allocated when preloading indexes"))
1274
1294
("query-alloc-block-size",
1275
1295
po::value<uint32_t>(&global_system_variables.query_alloc_block_size)->default_value(QUERY_ALLOC_BLOCK_SIZE)->notifier(&check_limits_qabs),
1276
_("Allocation block size for query parsing and execution"))
1296
N_("Allocation block size for query parsing and execution"))
1277
1297
("query-prealloc-size",
1278
1298
po::value<uint32_t>(&global_system_variables.query_prealloc_size)->default_value(QUERY_ALLOC_PREALLOC_SIZE)->notifier(&check_limits_qps),
1279
_("Persistent buffer for query parsing and execution"))
1299
N_("Persistent buffer for query parsing and execution"))
1280
1300
("range-alloc-block-size",
1281
1301
po::value<size_t>(&global_system_variables.range_alloc_block_size)->default_value(RANGE_ALLOC_BLOCK_SIZE)->notifier(&check_limits_rabs),
1282
_("Allocation block size for storing ranges during optimization"))
1302
N_("Allocation block size for storing ranges during optimization"))
1283
1303
("read-buffer-size",
1284
1304
po::value<uint32_t>(&global_system_variables.read_buff_size)->default_value(128*1024L)->notifier(&check_limits_read_buffer_size),
1285
_("Each thread that does a sequential scan allocates a buffer of this "
1305
N_("Each thread that does a sequential scan allocates a buffer of this "
1286
1306
"size for each table it scans. If you do many sequential scans, you may "
1287
1307
"want to increase this value."))
1288
1308
("read-buffer-threshold",
1289
1309
po::value<uint64_t>()->default_value(0),
1290
_("A global cap on the size of read-buffer-size (0 means unlimited)"))
1310
N_("A global cap on the size of read-buffer-size (0 means unlimited)"))
1291
1311
("read-rnd-buffer-size",
1292
1312
po::value<uint32_t>(&global_system_variables.read_rnd_buff_size)->default_value(256*1024L)->notifier(&check_limits_read_rnd_buffer_size),
1293
_("When reading rows in sorted order after a sort, the rows are read "
1313
N_("When reading rows in sorted order after a sort, the rows are read "
1294
1314
"through this buffer to avoid a disk seeks. If not set, then it's set "
1295
1315
"to the value of record_buffer."))
1296
1316
("read-rnd-threshold",
1297
1317
po::value<uint64_t>()->default_value(0),
1298
_("A global cap on the size of read-rnd-buffer-size (0 means unlimited)"))
1318
N_("A global cap on the size of read-rnd-buffer-size (0 means unlimited)"))
1299
1319
("scheduler", po::value<string>(),
1300
_("Select scheduler to be used (by default multi-thread)."))
1320
N_("Select scheduler to be used (by default multi-thread)."))
1301
1321
("sort-buffer-size",
1302
1322
po::value<size_t>(&global_system_variables.sortbuff_size)->default_value(MAX_SORT_MEMORY)->notifier(&check_limits_sort_buffer_size),
1303
_("Each thread that needs to do a sort allocates a buffer of this size."))
1323
N_("Each thread that needs to do a sort allocates a buffer of this size."))
1304
1324
("sort-heap-threshold",
1305
1325
po::value<uint64_t>()->default_value(0),
1306
_("A global cap on the amount of memory that can be allocated by session sort buffers (0 means unlimited)"))
1326
N_("A global cap on the amount of memory that can be allocated by session sort buffers (0 means unlimited)"))
1307
1327
("table-definition-cache", po::value<size_t>(&table_def_size)->default_value(128)->notifier(&check_limits_tdc),
1308
_("The number of cached table definitions."))
1328
N_("The number of cached table definitions."))
1309
1329
("table-open-cache", po::value<uint64_t>(&table_cache_size)->default_value(TABLE_OPEN_CACHE_DEFAULT)->notifier(&check_limits_toc),
1310
_("The number of cached open tables."))
1330
N_("The number of cached open tables."))
1311
1331
("table-lock-wait-timeout", po::value<uint64_t>(&table_lock_wait_timeout)->default_value(50)->notifier(&check_limits_tlwt),
1312
_("Timeout in seconds to wait for a table level lock before returning an "
1332
N_("Timeout in seconds to wait for a table level lock before returning an "
1313
1333
"error. Used only if the connection has active cursors."))
1314
1334
("thread-stack", po::value<size_t>(&my_thread_stack_size)->default_value(DEFAULT_THREAD_STACK)->notifier(&check_limits_thread_stack),
1315
_("The stack size for each thread."))
1335
N_("The stack size for each thread."))
1316
1336
("tmp-table-size",
1317
1337
po::value<uint64_t>(&global_system_variables.tmp_table_size)->default_value(16*1024*1024L)->notifier(&check_limits_tmp_table_size),
1318
_("If an internal in-memory temporary table exceeds this size, Drizzle will"
1338
N_("If an internal in-memory temporary table exceeds this size, Drizzle will"
1319
1339
" automatically convert it to an on-disk MyISAM table."))