---

events.h

#ifndef _EVENT_H_ #define _EVENT_H_ /* Copyright (c) 2004, 2013, Oracle and/or its affiliates. All rights reserved. This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; version 2 of the License. This program 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 this program; if not, write to the Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1335 USA */ /** @defgroup Event_Scheduler Event Scheduler @ingroup Runtime_Environment @{ @file events.h A public interface of Events_Scheduler module. */ #ifdef HAVE_PSI_INTERFACE extern PSI_mutex_key key_event_scheduler_LOCK_scheduler_state; extern PSI_cond_key key_event_scheduler_COND_state; extern PSI_thread_key key_thread_event_scheduler, key_thread_event_worker; #endif /* HAVE_PSI_INTERFACE */ extern PSI_memory_key key_memory_event_basic_root; /* Always defined, for SHOW PROCESSLIST. */ extern PSI_stage_info stage_waiting_on_empty_queue; extern PSI_stage_info stage_waiting_for_next_activation; extern PSI_stage_info stage_waiting_for_scheduler_to_stop; #include "sql_string.h" /* LEX_CSTRING */ #include "my_time.h" /* interval_type */ class Event_db_repository; class Event_parse_data; class Event_queue; class Event_scheduler; struct TABLE_LIST; class THD; typedef class Item COND; int sortcmp_lex_string(const LEX_CSTRING *s, const LEX_CSTRING *t, const CHARSET_INFO *cs); /** @brief A facade to the functionality of the Event Scheduler. Every public operation against the scheduler has to be executed via the interface provided by a static method of this class. No instance of this class is ever created and it has no non-static data members. The life cycle of the Events module is the following: At server start up: init_mutexes() -> init() When the server is running: create_event(), drop_event(), start_or_stop_event_scheduler(), etc At shutdown: deinit(), destroy_mutexes(). The peculiar initialization and shutdown cycle is an adaptation to the outside server startup/shutdown framework and mimics the rest of MySQL subsystems (ACL, time zone tables, etc). */ class Events { public: /* the following block is to support --event-scheduler command line option and the @@global.event_scheduler SQL variable. See sys_var.cc */ enum enum_opt_event_scheduler { EVENTS_OFF, EVENTS_ON, EVENTS_DISABLED, EVENTS_ORIGINAL }; /* Protected using LOCK_global_system_variables only. */ static ulong opt_event_scheduler, startup_state; static ulong inited; static bool check_if_system_tables_error(); static bool start(int *err_no); static bool stop(); public: /* A hack needed for Event_queue_element */ static Event_db_repository * get_db_repository() { return db_repository; } static bool init(THD *thd, bool opt_noacl); static void deinit(); static void init_mutexes(); static void destroy_mutexes(); static bool create_event(THD *thd, Event_parse_data *parse_data); static bool update_event(THD *thd, Event_parse_data *parse_data, LEX_CSTRING *new_dbname, LEX_CSTRING *new_name); static bool drop_event(THD *thd, const LEX_CSTRING *dbname, const LEX_CSTRING *name, bool if_exists); static void drop_schema_events(THD *thd, const LEX_CSTRING &db); static bool show_create_event(THD *thd, const LEX_CSTRING *dbname, const LEX_CSTRING *name); /* Needed for both SHOW CREATE EVENT and INFORMATION_SCHEMA */ static int reconstruct_interval_expression(String *buf, interval_type interval, longlong expression); static int fill_schema_events(THD *thd, TABLE_LIST *tables, COND * /* cond */); static void dump_internal_status(); static void set_original_state(ulong startup_state_org) { startup_state= startup_state_org; } private: static bool load_events_from_db(THD *thd); private: static Event_queue *event_queue; static Event_scheduler *scheduler; static Event_db_repository *db_repository; private: /* Prevent use of these */ Events(const Events &); void operator=(Events &); }; /** @} (end of group Event Scheduler) */ #endif /* _EVENT_H_ */

---

docroot: /home/induvedam/public_html

---

curdir: /usr/include/mysql/server/private

	.		16384
	..		4096
X	aligned.h		1136
X	aria_backup.h		1787
X	assume_aligned.h		2350
	atomic		67
X	authors.h		10194
X	backup.h		1703
X	bounded_queue.h		6093
X	char_buffer.h		3169
X	charset_collations.h		6562
X	client_settings.h		1912
X	compat56.h		2280
X	config.h		14363
X	contributors.h		4931
X	create_options.h		4193
X	create_tmp_table.h		2808
X	cset_narrowing.h		3968
X	custom_conf.h		1082
X	datadict.h		1700
X	ddl_log.h		12807
X	debug.h		1289
X	debug_sync.h		2046
X	deprecation.h		2802
X	derived_handler.h		2379
X	derror.h		980
X	des_key_file.h		1236
X	discover.h		1570
X	dur_prop.h		1082
X	embedded_priv.h		1733
X	event_data_objects.h		4187
X	event_db_repository.h		3648
X	event_parse_data.h		2899
X	event_queue.h		3438
X	event_scheduler.h		3290
X	events.h		4711
X	field.h		223130
X	field_comp.h		1174
X	filesort.h		7304
X	filesort_utils.h		10787
X	ft_global.h		3113
X	gcalc_slicescan.h		17330
X	gcalc_tools.h		11900
X	grant.h		2758
X	group_by_handler.h		3534
X	gstream.h		2437
X	gtid_index.h		20005
X	ha_handler_stats.h		2335
X	ha_partition.h		64977
X	ha_sequence.h		6280
X	handle_connections_win.h		884
X	handler.h		211498
X	hash.h		4452
X	hash_filo.h		5599
X	heap.h		9487
X	hostname.h		5419
X	ilist.h		7237
X	init.h		852
X	innodb_priv.h		1319
X	item.h		287178
X	item_cmpfunc.h		136041
X	item_create.h		11508
X	item_func.h		139016
X	item_geofunc.h		39612
X	item_jsonfunc.h		29120
X	item_row.h		5229
X	item_strfunc.h		78524
X	item_subselect.h		59087
X	item_sum.h		72695
X	item_timefunc.h		66022
X	item_vers.h		4413
X	item_windowfunc.h		35089
X	item_xmlfunc.h		4650
X	json_schema.h		25811
X	json_schema_helper.h		1152
X	json_table.h		9667
X	key.h		2132
X	keycaches.h		1985
X	lex.h		30248
X	lex_charset.h		26540
X	lex_hash.h		145350
X	lex_ident.h		5275
X	lex_string.h		4881
X	lex_symbol.h		1323
X	lex_token.h		43014
X	lf.h		6462
X	lock.h		2253
X	log.h		52664
X	log_cache.h		7756
X	log_event.h		177066
X	log_event_data_type.h		1890
X	log_slow.h		2442
X	maria.h		5872
X	mariadb.h		1277
X	mdl.h		38945
X	mem_root_array.h		7106
X	message.h		1195
X	multi_range_read.h		23193
X	my_apc.h		4747
X	my_atomic.h		7281
X	my_atomic_wrapper.h		3051
X	my_base.h		28032
X	my_bit.h		6196
X	my_bitmap.h		5502
X	my_check_opt.h		2618
X	my_compare.h		11135
X	my_counter.h		1721
X	my_cpu.h		4885
X	my_crypt.h		904
X	my_decimal.h		14504
X	my_default.h		1880
X	my_handler_errors.h		4882
X	my_json_writer.h		18713
X	my_libwrap.h		1183
X	my_md5.h		1486
X	my_minidump.h		848
X	my_nosys.h		1438
X	my_rdtsc.h		10119
X	my_rnd.h		1014
X	my_service_manager.h		2117
X	my_stack_alloc.h		6493
X	my_stacktrace.h		3215
X	my_time.h		10414
X	my_tracker.h		1405
X	my_tree.h		3991
X	my_uctype.h		69528
X	my_user.h		1126
X	my_virtual_mem.h		1255
X	myisam.h		17597
X	myisamchk.h		4734
X	myisammrg.h		4897
X	myisampack.h		14929
X	mysqld.h		42272
X	mysqld_default_groups.h		204
X	mysqld_suffix.h		1201
X	mysys_err.h		3057
X	opt_histogram_json.h		4827
X	opt_range.h		66708
X	opt_rewrite_date_cmp.h		3934
X	opt_subselect.h		15134
X	opt_trace.h		9501
X	opt_trace_context.h		3291
X	optimizer_costs.h		6032
X	optimizer_defaults.h		7545
X	parse_file.h		4424
X	partition_element.h		5428
X	partition_info.h		19987
X	password.h		1621
X	pfs_file_provider.h		3153
X	pfs_idle_provider.h		1385
X	pfs_memory_provider.h		1626
X	pfs_metadata_provider.h		1898
X	pfs_socket_provider.h		2258
X	pfs_stage_provider.h		1556
X	pfs_statement_provider.h		4347
X	pfs_table_provider.h		2625
X	pfs_thread_provider.h		5560
X	pfs_transaction_provider.h		2846
X	privilege.h		29091
X	probes_mysql.h		973
X	probes_mysql_dtrace.h		33005
X	probes_mysql_nodtrace.h		5005
X	procedure.h		6819
X	protocol.h		12569
	providers		77
X	proxy_protocol.h		548
X	queues.h		3477
X	records.h		3147
X	repl_failsafe.h		1585
X	replication.h		15565
X	rijndael.h		1711
X	rowid_filter.h		16406
X	rpl_constants.h		3357
X	rpl_filter.h		4774
X	rpl_gtid.h		30718
X	rpl_injector.h		9621
X	rpl_mi.h		16676
X	rpl_parallel.h		18228
X	rpl_record.h		1525
X	rpl_reporting.h		3713
X	rpl_rli.h		35861
X	rpl_tblmap.h		3177
X	rpl_utility.h		11362
X	scheduler.h		3199
X	scope.h		4393
X	select_handler.h		3419
X	semisync.h		2287
X	semisync_master.h		25764
X	semisync_master_ack_receiver.h		8709
X	semisync_slave.h		3736
X	service_versions.h		2285
X	session_tracker.h		14081
X	set_var.h		17459
X	simple_tokenizer.h		2013
X	slave.h		12392
X	socketpair.h		842
X	source_revision.h		67
X	sp.h		23669
X	sp_cache.h		2037
X	sp_head.h		39927
X	sp_instr.h		42003
X	sp_pcontext.h		25841
X	sp_rcontext.h		14423
X	span.h		3931
X	spatial.h		22698
X	sql_acl.h		14076
X	sql_admin.h		2915
X	sql_alloc.h		1732
X	sql_alter.h		15445
X	sql_analyse.h		11052
X	sql_analyze_stmt.h		12700
X	sql_array.h		7137
X	sql_audit.h		14162
X	sql_base.h		26500
X	sql_basic_types.h		9523
X	sql_binlog.h		895
X	sql_bitmap.h		8066
X	sql_bootstrap.h		1812
X	sql_cache.h		21857
X	sql_callback.h		1542
X	sql_class.h		279830
X	sql_cmd.h		12003
X	sql_command.h		4974
X	sql_connect.h		4054
X	sql_const.h		10525
X	sql_crypt.h		1437
X	sql_cte.h		16494
X	sql_cursor.h		4428
X	sql_db.h		2330
X	sql_debug.h		5727
X	sql_delete.h		3604
X	sql_derived.h		1289
X	sql_digest.h		3819
X	sql_digest_stream.h		1567
X	sql_do.h		954
X	sql_error.h		40340
X	sql_explain.h		31122
X	sql_expression_cache.h		4359
X	sql_get_diagnostics.h		7883
X	sql_handler.h		2910
X	sql_help.h		995
X	sql_hset.h		3401
X	sql_i_s.h		8487
X	sql_insert.h		5173
X	sql_join_cache.h		48659
X	sql_lex.h		179015
X	sql_lifo_buffer.h		9685
X	sql_limit.h		3187
X	sql_list.h		22391
X	sql_load.h		1276
X	sql_locale.h		3239
X	sql_manager.h		960
X	sql_mode.h		6735
X	sql_parse.h		9012
X	sql_partition.h		12674
X	sql_partition_admin.h		5940
X	sql_plist.h		7711
X	sql_plugin.h		7577
X	sql_plugin_compat.h		2237
X	sql_prepare.h		11670
X	sql_priv.h		15444
X	sql_profile.h		7816
X	sql_reload.h		1036
X	sql_rename.h		982
X	sql_repl.h		3066
X	sql_schema.h		3303
X	sql_select.h		93875
X	sql_sequence.h		5177
X	sql_servers.h		1777
X	sql_show.h		9951
X	sql_signal.h		3362
X	sql_sort.h		22491
X	sql_statistics.h		16814
X	sql_string.h		38827
X	sql_table.h		9812
X	sql_test.h		2665
X	sql_time.h		7542
X	sql_trigger.h		12168
X	sql_truncate.h		2079
X	sql_tvc.h		2418
X	sql_type.h		299843
X	sql_type_fixedbin.h		65584
X	sql_type_fixedbin_storage.h		5467
X	sql_type_geom.h		19039
X	sql_type_int.h		10001
X	sql_type_json.h		6155
X	sql_type_real.h		1257
X	sql_type_string.h		1629
X	sql_type_timeofday.h		2311
X	sql_udf.h		4850
X	sql_union.h		1068
X	sql_update.h		3632
X	sql_used.h		1043
X	sql_view.h		2470
X	sql_window.h		6814
X	ssl_compat.h		3380
X	strfunc.h		2549
X	structs.h		31489
X	sys_vars_shared.h		2729
X	t_ctype.h		5639
X	table.h		121942
X	table_cache.h		4246
X	thr_lock.h		7228
X	thr_malloc.h		1202
X	thr_timer.h		1563
X	thread_cache.h		5905
X	threadpool.h		4810
X	threadpool_generic.h		3969
X	threadpool_winsockets.h		2290
X	transaction.h		1466
X	tzfile.h		5014
X	tztime.h		3734
X	uniques.h		4225
X	unireg.h		7945
X	vers_string.h		2449
X	violite.h		9956
X	waiting_threads.h		4532
X	welcome_copyright_notice.h		1450
X	winservice.h		6019
X	wqueue.h		1565
X	wsrep.h		3308
X	wsrep_allowlist_service.h		1035
X	wsrep_applier.h		2703
X	wsrep_binlog.h		3551
X	wsrep_client_service.h		2602
X	wsrep_client_state.h		1566
X	wsrep_condition_variable.h		1484
X	wsrep_event_service.h		1351
X	wsrep_high_priority_service.h		4912
X	wsrep_mutex.h		1239
X	wsrep_mysqld.h		22006
X	wsrep_mysqld_c.h		1227
X	wsrep_on.h		1718
X	wsrep_plugin.h		1380
X	wsrep_priv.h		1634
X	wsrep_schema.h		5886
X	wsrep_server_service.h		3631
X	wsrep_server_state.h		3130
X	wsrep_sst.h		3951
X	wsrep_status.h		1973
X	wsrep_storage_service.h		1809
X	wsrep_thd.h		11487
X	wsrep_trans_observer.h		18174
X	wsrep_types.h		1110
X	wsrep_utils.h		10251
X	wsrep_var.h		4535
X	wsrep_xid.h		1509
X	xa.h		1903