56#ifdef HAVE_PSI_INTERFACE
94 return (lhs < rhs ? -1 : (lhs > rhs ? 1 : 0));
132 void lock_data(
const char *func, uint line);
138 const char *src_file, uint src_line);
Definition: event_data_objects.h:80
@ DISABLED
Definition: event_parse_data.h:51
Definition: event_data_objects.h:55
Definition: event_data_objects.h:96
my_time_t m_execute_at
Definition: event_data_objects.h:103
int m_status
Definition: event_data_objects.h:99
Queue of active events awaiting execution.
Definition: event_queue.h:102
uint mutex_last_unlocked_at_line
Definition: event_queue.h:161
bool waiting_on_cond
Definition: event_queue.h:168
mysql_cond_t COND_queue_state
Definition: event_queue.h:149
bool mutex_queue_data_locked
Definition: event_queue.h:166
uint mutex_last_locked_at_line
Definition: event_queue.h:160
my_time_t next_activation_at
Definition: event_queue.h:158
std::atomic< const char * > mutex_last_attempted_lock_in_func
Definition: event_queue.h:165
const char * mutex_last_locked_in_func
Definition: event_queue.h:163
const char * mutex_last_unlocked_in_func
Definition: event_queue.h:164
std::atomic< uint > mutex_last_attempted_lock_at_line
Definition: event_queue.h:162
mysql_mutex_t LOCK_event_queue
Definition: event_queue.h:148
std::atomic< bool > mutex_queue_data_attempting_lock
Definition: event_queue.h:167
Priority_queue< Event_queue_element *, std::vector< Event_queue_element *, Malloc_allocator< Event_queue_element * > >, Event_queue_less > queue
Definition: event_queue.h:156
Malloc_allocator is a C++ STL memory allocator based on my_malloc/my_free.
Definition: malloc_allocator.h:63
Implements a priority queue using a vector-based max-heap.
Definition: priority_queue.h:104
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:36
bool get_top_for_execution_if_time(THD *thd, Event_queue_element_for_exec **event_name)
Definition: event_queue.cc:531
void update_event(THD *thd, LEX_CSTRING dbname, LEX_CSTRING name, Event_queue_element *new_element)
Definition: event_queue.cc:205
void lock_data(const char *func, uint line)
Definition: event_queue.cc:658
Event_queue()
Definition: event_queue.cc:76
void recalculate_activation_times(THD *thd)
Definition: event_queue.cc:376
void drop_matching_events(LEX_CSTRING pattern, bool(*)(LEX_CSTRING, Event_basic *))
Definition: event_queue.cc:277
void find_n_remove_event(LEX_CSTRING db, LEX_CSTRING name)
Definition: event_queue.cc:348
void cond_wait(THD *thd, struct timespec *abstime, const PSI_stage_info *stage, const char *src_func, const char *src_file, uint src_line)
Definition: event_queue.cc:705
void empty_queue()
Definition: event_queue.cc:476
PSI_cond_key key_COND_queue_state
Definition: events.cc:1017
~Event_queue()
Definition: event_queue.cc:94
void dbug_dump_queue(time_t now)
Definition: event_queue.cc:494
void unlock_data(const char *func, uint line)
Definition: event_queue.cc:684
void drop_schema_events(LEX_CSTRING schema)
Definition: event_queue.cc:328
bool init_queue()
Definition: event_queue.cc:116
PSI_mutex_key key_LOCK_event_queue
Definition: events.cc:1007
bool create_event(THD *thd, Event_queue_element *new_element, bool *created)
Adds an event to the queue.
Definition: event_queue.cc:169
void dump_internal_status()
Definition: event_queue.cc:745
void deinit_queue()
Definition: event_queue.cc:143
void drop_event(THD *thd, LEX_CSTRING dbname, LEX_CSTRING name)
Definition: event_queue.cc:246
unsigned int PSI_cond_key
Instrumented cond key.
Definition: psi_cond_bits.h:44
unsigned int PSI_mutex_key
Instrumented mutex key.
Definition: psi_mutex_bits.h:52
Defines various enable/disable and HAVE_ macros related to the performance schema instrumentation sys...
Interface for low level time utilities.
int64_t my_time_t
Portable time_t replacement.
Definition: my_time_t.h:32
Instrumentation helpers for conditions.
ABI for instrumented mutexes.
std::vector< T, ut::allocator< T > > vector
Specialization of vector which uses allocator.
Definition: ut0new.h:2875
Performance schema instrumentation interface.
Instrumentation helpers for mutexes.
Performance schema instrumentation interface.
case opt name
Definition: sslopt-case.h:29
Definition: event_queue.h:61
int event_queue_element_compare_q(Event_queue_element *left, Event_queue_element *right)
Compares the execute_at members of two Event_queue_element instances.
Definition: event_queue.h:85
bool operator()(Event_queue_element *left, Event_queue_element *right)
Maps compare function to strict weak ordering required by Priority_queue.
Definition: event_queue.h:63
Definition: mysql_lex_string.h:40
Stage instrument information.
Definition: psi_stage_bits.h:74
An instrumented cond structure.
Definition: mysql_cond_bits.h:50
An instrumented mutex structure.
Definition: mysql_mutex_bits.h:50
Include file for Sun RPC to compile out of the box.