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
|
#ifndef _EVENT_SCHEDULER_H_
#define _EVENT_SCHEDULER_H_
/* Copyright (c) 2004, 2025, Oracle and/or its affiliates.
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License, version 2.0,
as published by the Free Software Foundation.
This program is designed to work with certain software (including
but not limited to OpenSSL) that is licensed under separate terms,
as designated in a particular file or component or in included license
documentation. The authors of MySQL hereby grant you an additional
permission to link the program and your derivative works with the
separately licensed software that they have either included with
the program or referenced in the documentation.
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, version 2.0, 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-1301 USA */
/**
@addtogroup Event_Scheduler
@{
*/
/**
@file
Declarations of the scheduler thread class
and related functionality.
This file is internal to Event_Scheduler module. Please do not
include it directly. All public declarations of Event_Scheduler
module are in events.h and event_data_objects.h.
*/
#include <sys/types.h>
#include "my_inttypes.h"
#include "mysql/components/services/bits/mysql_cond_bits.h"
#include "mysql/components/services/bits/mysql_mutex_bits.h"
#include "mysql/components/services/bits/psi_stage_bits.h"
class Event_db_repository;
class Event_job_data;
class Event_queue;
class Event_queue_element_for_exec;
class THD;
void pre_init_event_thread(THD *thd);
bool post_init_event_thread(THD *thd);
void deinit_event_thread(THD *thd);
class Event_worker_thread {
public:
void run(THD *thd, Event_queue_element_for_exec *event);
private:
void print_warnings(THD *thd, Event_job_data *et);
};
class Event_scheduler {
public:
Event_scheduler(Event_queue *event_queue_arg);
~Event_scheduler();
/* State changing methods follow */
bool start(int *err_no);
bool stop();
/*
Need to be public because has to be called from the function
passed to my_thread_create.
*/
bool run(THD *thd);
/* Information retrieving methods follow */
bool is_running();
void dump_internal_status();
private:
int workers_count();
/* helper functions */
bool execute_top(Event_queue_element_for_exec *event_name);
/* helper functions for working with mutexes & conditionals */
void lock_data(const char *func, uint line);
void unlock_data(const char *func, uint line);
void cond_wait(THD *thd, struct timespec *abstime,
const PSI_stage_info *stage, const char *src_func,
const char *src_file, uint src_line);
mysql_mutex_t LOCK_scheduler_state;
enum enum_state { INITIALIZED = 0, RUNNING, STOPPING };
/* This is the current status of the life-cycle of the scheduler. */
enum enum_state state;
THD *scheduler_thd;
mysql_cond_t COND_state;
Event_queue *queue;
uint mutex_last_locked_at_line;
uint mutex_last_unlocked_at_line;
const char *mutex_last_locked_in_func;
const char *mutex_last_unlocked_in_func;
bool mutex_scheduler_data_locked;
bool waiting_on_cond;
ulonglong started_events;
private:
// Disallow copy construction and assignment.
Event_scheduler(const Event_scheduler &) = delete;
void operator=(Event_scheduler &) = delete;
};
/**
@} (End of group Event_Scheduler)
*/
#endif /* _EVENT_SCHEDULER_H_ */
|
