My Project
|
#include <binlog.h>
Classes | |
class | Mutex_queue |
Public Types | |
enum | StageID { FLUSH_STAGE, SYNC_STAGE, COMMIT_STAGE, STAGE_COUNTER } |
Public Member Functions | |
class Stage_manager::Mutex_queue | __attribute__ ((aligned(CPU_LEVEL1_DCACHE_LINESIZE))) |
void | init () |
void | deinit () |
bool | enroll_for (StageID stage, THD *first, mysql_mutex_t *stage_mutex) |
std::pair< bool, THD * > | pop_front (StageID stage) |
void | clear_preempt_status (THD *head) |
THD * | fetch_queue_for (StageID stage) |
void | signal_done (THD *queue) |
Public Attributes | |
enum Stage_manager::StageID | __attribute__ |
Class for maintaining the commit stages for binary log group commit.
Constants for queues for different stages.
THD* Stage_manager::fetch_queue_for | ( | StageID | stage | ) | [inline] |
Fetch the entire queue and empty it.