20
20
#ifndef DRIZZLED_LOCK_H
21
21
#define DRIZZLED_LOCK_H
24
#include <drizzled/thr_lock.h>
25
#include <drizzled/locking/global.h>
23
#include <mysys/definitions.h>
42
THR_LOCK_DATA **getLocks()
47
size_t sizeTable() const
52
void resizeTable(size_t arg)
57
size_t sizeLock() const
67
void setLock(size_t arg)
73
void unlock(uint32_t count);
75
DrizzleLock(size_t table_count_arg)
77
table.resize(table_count_arg);
78
lock_count= table_count_arg * 2;
79
locks.resize(lock_count);
85
std::vector<Table *> table;
86
std::vector<THR_LOCK_DATA *> locks;
87
std::vector<THR_LOCK_DATA *> copy_of;
90
/* lockTables() and open_table() flags bits */
28
typedef struct st_mysql_lock DRIZZLE_LOCK;
30
DRIZZLE_LOCK *mysql_lock_tables(Session *session, Table **table, uint32_t count,
31
uint32_t flags, bool *need_reopen);
32
/* mysql_lock_tables() and open_table() flags bits */
91
33
#define DRIZZLE_LOCK_IGNORE_GLOBAL_READ_LOCK 0x0001
92
34
#define DRIZZLE_LOCK_IGNORE_FLUSH 0x0002
93
35
#define DRIZZLE_LOCK_NOTIFY_IF_NEED_REOPEN 0x0004
94
36
#define DRIZZLE_OPEN_TEMPORARY_ONLY 0x0008
96
} /* namespace drizzled */
37
#define DRIZZLE_LOCK_PERF_SCHEMA 0x0020
39
void mysql_unlock_tables(Session *session, DRIZZLE_LOCK *sql_lock);
40
void mysql_unlock_read_tables(Session *session, DRIZZLE_LOCK *sql_lock);
41
void mysql_unlock_some_tables(Session *session, Table **table,uint32_t count);
42
void mysql_lock_remove(Session *session, DRIZZLE_LOCK *locked,Table *table,
44
void mysql_lock_abort(Session *session, Table *table, bool upgrade_lock);
45
void mysql_lock_downgrade_write(Session *session, Table *table,
46
thr_lock_type new_lock_type);
47
bool mysql_lock_abort_for_thread(Session *session, Table *table);
48
DRIZZLE_LOCK *mysql_lock_merge(DRIZZLE_LOCK *a,DRIZZLE_LOCK *b);
49
TableList *mysql_lock_have_duplicate(Session *session, TableList *needle,
51
bool lock_global_read_lock(Session *session);
52
void unlock_global_read_lock(Session *session);
53
bool wait_if_global_read_lock(Session *session, bool abort_on_refresh,
55
void start_waiting_global_read_lock(Session *session);
56
bool make_global_read_lock_block_commit(Session *session);
57
bool set_protect_against_global_read_lock(void);
58
void unset_protect_against_global_read_lock(void);
59
void broadcast_refresh(void);
60
int try_transactional_lock(Session *session, TableList *table_list);
61
int check_transactional_lock(Session *session, TableList *table_list);
62
int set_handler_table_locks(Session *session, TableList *table_list,
65
/* Lock based on name */
66
int lock_and_wait_for_table_name(Session *session, TableList *table_list);
67
int lock_table_name(Session *session, TableList *table_list, bool check_in_use);
68
void unlock_table_name(Session *session, TableList *table_list);
69
bool wait_for_locked_table_names(Session *session, TableList *table_list);
70
bool lock_table_names(Session *session, TableList *table_list);
71
void unlock_table_names(Session *session, TableList *table_list,
72
TableList *last_table);
73
bool lock_table_names_exclusively(Session *session, TableList *table_list);
74
bool is_table_name_exclusively_locked_by_this_thread(Session *session,
75
TableList *table_list);
76
bool is_table_name_exclusively_locked_by_this_thread(Session *session,
98
80
#endif /* DRIZZLED_LOCK_H */