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>
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_list.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"
80
#include "drizzled/visibility.h"
70
#include "drizzled/plugin/event_observer.h"
82
72
#include <google/protobuf/stubs/common.h>
84
#include <drizzled/refresh_version.h>
86
74
#if TIME_WITH_SYS_TIME
87
75
# include <sys/time.h>
1128
1199
pid_file.replace_extension(".pid");
1130
1201
system_config_dir /= "drizzle";
1202
std::string system_config_file_drizzle("drizzled.cnf");
1132
1204
config_options.add_options()
1133
1205
("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."))
1206
N_("Display this help and exit."))
1137
1207
("no-defaults", po::value<bool>()->default_value(false)->zero_tokens(),
1138
_("Configuration file defaults are not used if no-defaults is set"))
1208
N_("Configuration file defaults are not used if no-defaults is set"))
1139
1209
("defaults-file", po::value<vector<string> >()->composing()->notifier(&compose_defaults_file_list),
1140
_("Configuration file to use"))
1210
N_("Configuration file to use"))
1141
1211
("config-dir", po::value<fs::path>(&system_config_dir),
1142
_("Base location for config files"))
1212
N_("Base location for config files"))
1143
1213
("plugin-dir", po::value<fs::path>(&plugin_dir)->notifier(¬ify_plugin_dir),
1144
_("Directory for plugins."))
1214
N_("Directory for plugins."))
1147
1217
plugin_load_options.add_options()
1148
1218
("plugin-add", po::value<vector<string> >()->composing()->notifier(&compose_plugin_add),
1149
_("Optional comma separated list of plugins to load at startup in addition "
1219
N_("Optional comma separated list of plugins to load at startup in addition "
1150
1220
"to the default list of plugins. "
1151
1221
"[for example: --plugin_add=crc32,logger_gearman]"))
1152
1222
("plugin-remove", po::value<vector<string> >()->composing()->notifier(&compose_plugin_remove),
1153
_("Optional comma separated list of plugins to not load at startup. Effectively "
1223
N_("Optional comma separated list of plugins to not load at startup. Effectively "
1154
1224
"removes a plugin from the list of plugins to be loaded. "
1155
1225
"[for example: --plugin_remove=crc32,logger_gearman]"))
1156
1226
("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 "
1227
N_("Optional comma separated list of plugins to load at starup instead of "
1158
1228
"the default plugin load list. "
1159
1229
"[for example: --plugin_load=crc32,logger_gearman]"))
1162
1232
long_options.add_options()
1163
1233
("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"))
1234
N_("Auto-increment columns are incremented by this"))
1165
1235
("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"))
1236
N_("Offset added to Auto-increment columns. Used when auto-increment-increment != 1"))
1167
1237
("basedir,b", po::value<fs::path>(&basedir),
1168
_("Path to installation directory. All paths are usually resolved "
1238
N_("Path to installation directory. All paths are usually resolved "
1169
1239
"relative to this."))
1170
1240
("chroot,r", po::value<string>(),
1171
_("Chroot drizzled daemon during startup."))
1241
N_("Chroot drizzled daemon during startup."))
1172
1242
("collation-server", po::value<string>(),
1173
_("Set the default collation."))
1243
N_("Set the default collation."))
1174
1244
("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."))
1245
N_("Default completion type."))
1246
("core-file", N_("Write core on errors."))
1247
("datadir", po::value<fs::path>(&data_home),
1248
N_("Path to the database root."))
1179
1249
("default-storage-engine", po::value<string>(),
1180
_("Set the default storage engine for tables."))
1250
N_("Set the default storage engine for tables."))
1181
1251
("default-time-zone", po::value<string>(),
1182
_("Set the default time zone."))
1252
N_("Set the default time zone."))
1183
1253
("exit-info,T", po::value<long>(),
1184
_("Used for debugging; Use at your own risk!"))
1254
N_("Used for debugging; Use at your own risk!"))
1185
1255
("gdb", po::value<bool>(&opt_debugging)->default_value(false)->zero_tokens(),
1186
_("Set up signals usable for debugging"))
1256
N_("Set up signals usable for debugging"))
1187
1257
("lc-time-name", po::value<string>(),
1188
_("Set the language used for the month names and the days of the week."))
1258
N_("Set the language used for the month names and the days of the week."))
1189
1259
("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."))
1260
N_("Log some not critical warnings to the log file."))
1191
1261
("pid-file", po::value<fs::path>(&pid_file),
1192
_("Pid file used by drizzled."))
1262
N_("Pid file used by drizzled."))
1193
1263
("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. "))
1195
("replicate-query", po::value<bool>(&global_system_variables.replicate_query)->default_value(false)->zero_tokens(),
1196
_("Include the SQL query in replicated protobuf messages."))
1264
N_("Maximum time in seconds to wait for the port to become free. "))
1197
1265
("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 "
1266
N_("Limit LOAD DATA, SELECT ... OUTFILE, and LOAD_FILE() to files "
1199
1267
"within specified directory"))
1200
1268
("server-id", po::value<uint32_t>(&server_id)->default_value(0),
1201
_("Uniquely identifies the server instance in the community of "
1269
N_("Uniquely identifies the server instance in the community of "
1202
1270
"replication partners."))
1203
1271
("skip-stack-trace",
1204
_("Don't print a stack trace on failure."))
1272
N_("Don't print a stack trace on failure."))
1205
1273
("symbolic-links,s", po::value<bool>(&internal::my_use_symdir)->default_value(IF_PURIFY(false,true))->zero_tokens(),
1206
_("Enable symbolic link support."))
1274
N_("Enable symbolic link support."))
1207
1275
("timed-mutexes", po::value<bool>(&internal::timed_mutexes)->default_value(false)->zero_tokens(),
1208
_("Specify whether to time mutexes (only InnoDB mutexes are currently "
1276
N_("Specify whether to time mutexes (only InnoDB mutexes are currently "
1210
1278
("tmpdir,t", po::value<string>(),
1211
_("Path for temporary files."))
1279
N_("Path for temporary files."))
1212
1280
("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."))
1281
N_("Default transaction isolation level."))
1282
("transaction-message-threshold", po::value<size_t>(&global_system_variables.transaction_message_threshold)->default_value(1024*1024)->notifier(&check_limits_transaction_message_threshold),
1283
N_("Max message size written to transaction log, valid values 131072 - 1048576 bytes."))
1216
1284
("user,u", po::value<string>(),
1217
_("Run drizzled daemon as user."))
1285
N_("Run drizzled daemon as user."))
1219
_("Output version information and exit."))
1287
N_("Output version information and exit."))
1220
1288
("back-log", po::value<back_log_constraints>(&back_log),
1221
_("The number of outstanding connection requests Drizzle can have. This "
1289
N_("The number of outstanding connection requests Drizzle can have. This "
1222
1290
"comes into play when the main Drizzle thread gets very many connection "
1223
1291
"requests in a very short time."))
1224
1292
("bulk-insert-buffer-size",
1225
1293
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 "
1294
N_("Size of tree cache used in bulk insert optimization. Note that this is "
1227
1295
"a limit per thread!"))
1228
1296
("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 "
1297
N_("Precision of the result of '/' operator will be increased on that "
1231
1299
("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."))
1300
N_("The maximum length of the result of function group_concat."))
1233
1301
("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."))
1235
("join-heap-threshold",
1236
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)"))
1238
("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."))
1302
N_("The size of the buffer that is used for full joins."))
1303
("max-allowed-packet", po::value<uint32_t>(&global_system_variables.max_allowed_packet)->default_value(1024*1024L)->notifier(&check_limits_map),
1304
N_("Max packetlength to send/receive from to server."))
1305
("max-connect-errors", po::value<uint64_t>(&max_connect_errors)->default_value(MAX_CONNECT_ERRORS)->notifier(&check_limits_mce),
1306
N_("If there is more than this number of interrupted connections from a "
1307
"host this host will be blocked from further connections."))
1240
1308
("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."))
1309
N_("Max number of errors/warnings to store for a statement."))
1242
1310
("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."))
1311
N_("Don't allow creation of heap tables bigger than this."))
1244
1312
("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 "
1313
N_("Joins that are probably going to read more than max_join_size records "
1246
1314
"return an error."))
1247
1315
("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."))
1316
N_("Max number of bytes in sorted records."))
1249
1317
("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"))
1318
N_("Limit assumed max number of seeks when looking up rows based on a key"))
1251
1319
("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 "
1320
N_("The number of bytes to use when sorting BLOB or TEXT values "
1253
1321
"(only the first max_sort_length bytes of each value are used; the "
1254
1322
"rest are ignored)."))
1255
1323
("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."))
1324
N_("After this many write locks, allow some read locks to run in between."))
1257
1325
("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 "
1326
N_("Don't log queries which examine less than min_examined_row_limit "
1259
1327
"rows to file."))
1260
1328
("disable-optimizer-prune",
1261
_("Do not apply any heuristic(s) during query optimization to prune, "
1329
N_("Do not apply any heuristic(s) during query optimization to prune, "
1262
1330
"thus perform an exhaustive search from the optimizer search space."))
1263
1331
("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 "
1332
N_("Maximum depth of search performed by the query optimizer. Values "
1265
1333
"larger than the number of relations in a query result in better query "
1266
1334
"plans, but take longer to compile a query. Smaller values than the "
1267
1335
"number of tables in a relation result in faster optimization, but may "
1270
1338
"optimizer will switch to the original find_best (used for "
1271
1339
"testing/comparison)."))
1272
1340
("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"))
1341
N_("The size of the buffer that is allocated when preloading indexes"))
1274
1342
("query-alloc-block-size",
1275
1343
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"))
1344
N_("Allocation block size for query parsing and execution"))
1277
1345
("query-prealloc-size",
1278
1346
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"))
1347
N_("Persistent buffer for query parsing and execution"))
1280
1348
("range-alloc-block-size",
1281
1349
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"))
1350
N_("Allocation block size for storing ranges during optimization"))
1283
1351
("read-buffer-size",
1284
1352
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 "
1353
N_("Each thread that does a sequential scan allocates a buffer of this "
1286
1354
"size for each table it scans. If you do many sequential scans, you may "
1287
1355
"want to increase this value."))
1288
("read-buffer-threshold",
1289
po::value<uint64_t>()->default_value(0),
1290
_("A global cap on the size of read-buffer-size (0 means unlimited)"))
1291
1356
("read-rnd-buffer-size",
1292
1357
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 "
1358
N_("When reading rows in sorted order after a sort, the rows are read "
1294
1359
"through this buffer to avoid a disk seeks. If not set, then it's set "
1295
1360
"to the value of record_buffer."))
1296
("read-rnd-threshold",
1297
po::value<uint64_t>()->default_value(0),
1298
_("A global cap on the size of read-rnd-buffer-size (0 means unlimited)"))
1299
1361
("scheduler", po::value<string>(),
1300
_("Select scheduler to be used (by default multi-thread)."))
1362
N_("Select scheduler to be used (by default multi-thread)."))
1301
1363
("sort-buffer-size",
1302
1364
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."))
1304
("sort-heap-threshold",
1305
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)"))
1365
N_("Each thread that needs to do a sort allocates a buffer of this size."))
1307
1366
("table-definition-cache", po::value<size_t>(&table_def_size)->default_value(128)->notifier(&check_limits_tdc),
1308
_("The number of cached table definitions."))
1367
N_("The number of cached table definitions."))
1309
1368
("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."))
1369
N_("The number of cached open tables."))
1311
1370
("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 "
1371
N_("Timeout in seconds to wait for a table level lock before returning an "
1313
1372
"error. Used only if the connection has active cursors."))
1314
1373
("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."))
1374
N_("The stack size for each thread."))
1316
1375
("tmp-table-size",
1317
1376
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"
1377
N_("If an internal in-memory temporary table exceeds this size, Drizzle will"
1319
1378
" automatically convert it to an on-disk MyISAM table."))