diff options
Diffstat (limited to 'include/thr_lock.h')
-rw-r--r-- | include/thr_lock.h | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/include/thr_lock.h b/include/thr_lock.h index aa5eb7426ae..74d65c2fa7a 100644 --- a/include/thr_lock.h +++ b/include/thr_lock.h @@ -83,7 +83,7 @@ extern enum thr_lock_type thr_upgraded_concurrent_insert_lock; typedef struct st_thr_lock_info { pthread_t thread; - ulong thread_id; + my_thread_id thread_id; ulong n_cursors; } THR_LOCK_INFO; @@ -148,10 +148,12 @@ void thr_unlock(THR_LOCK_DATA *data); enum enum_thr_lock_result thr_multi_lock(THR_LOCK_DATA **data, uint count, THR_LOCK_OWNER *owner); void thr_multi_unlock(THR_LOCK_DATA **data,uint count); -void thr_abort_locks(THR_LOCK *lock); -my_bool thr_abort_locks_for_thread(THR_LOCK *lock, pthread_t thread); +void thr_abort_locks(THR_LOCK *lock, bool upgrade_lock); +my_bool thr_abort_locks_for_thread(THR_LOCK *lock, my_thread_id thread); void thr_print_locks(void); /* For debugging */ my_bool thr_upgrade_write_delay_lock(THR_LOCK_DATA *data); +void thr_downgrade_write_lock(THR_LOCK_DATA *data, + enum thr_lock_type new_lock_type); my_bool thr_reschedule_write_lock(THR_LOCK_DATA *data); #ifdef __cplusplus } |