rwlock.h 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. #ifndef _LIBLOCKDEP_RWLOCK_H
  2. #define _LIBLOCKDEP_RWLOCK_H
  3. #include <pthread.h>
  4. #include "common.h"
  5. struct liblockdep_pthread_rwlock {
  6. pthread_rwlock_t rwlock;
  7. struct lockdep_map dep_map;
  8. };
  9. typedef struct liblockdep_pthread_rwlock liblockdep_pthread_rwlock_t;
  10. #define LIBLOCKDEP_PTHREAD_RWLOCK_INITIALIZER(rwl) \
  11. (struct liblockdep_pthread_rwlock) { \
  12. .rwlock = PTHREAD_RWLOCK_INITIALIZER, \
  13. .dep_map = STATIC_LOCKDEP_MAP_INIT(#rwl, &((&(rwl))->dep_map)), \
  14. }
  15. static inline int __rwlock_init(liblockdep_pthread_rwlock_t *lock,
  16. const char *name,
  17. struct lock_class_key *key,
  18. const pthread_rwlockattr_t *attr)
  19. {
  20. lockdep_init_map(&lock->dep_map, name, key, 0);
  21. return pthread_rwlock_init(&lock->rwlock, attr);
  22. }
  23. #define liblockdep_pthread_rwlock_init(lock, attr) \
  24. ({ \
  25. static struct lock_class_key __key; \
  26. \
  27. __rwlock_init((lock), #lock, &__key, (attr)); \
  28. })
  29. static inline int liblockdep_pthread_rwlock_rdlock(liblockdep_pthread_rwlock_t *lock)
  30. {
  31. lock_acquire(&lock->dep_map, 0, 0, 2, 1, NULL, (unsigned long)_RET_IP_);
  32. return pthread_rwlock_rdlock(&lock->rwlock);
  33. }
  34. static inline int liblockdep_pthread_rwlock_unlock(liblockdep_pthread_rwlock_t *lock)
  35. {
  36. lock_release(&lock->dep_map, 0, (unsigned long)_RET_IP_);
  37. return pthread_rwlock_unlock(&lock->rwlock);
  38. }
  39. static inline int liblockdep_pthread_rwlock_wrlock(liblockdep_pthread_rwlock_t *lock)
  40. {
  41. lock_acquire(&lock->dep_map, 0, 0, 0, 1, NULL, (unsigned long)_RET_IP_);
  42. return pthread_rwlock_wrlock(&lock->rwlock);
  43. }
  44. static inline int liblockdep_pthread_rwlock_tryrdlock(liblockdep_pthread_rwlock_t *lock)
  45. {
  46. lock_acquire(&lock->dep_map, 0, 1, 2, 1, NULL, (unsigned long)_RET_IP_);
  47. return pthread_rwlock_tryrdlock(&lock->rwlock) == 0 ? 1 : 0;
  48. }
  49. static inline int liblockdep_pthread_rwlock_trywlock(liblockdep_pthread_rwlock_t *lock)
  50. {
  51. lock_acquire(&lock->dep_map, 0, 1, 0, 1, NULL, (unsigned long)_RET_IP_);
  52. return pthread_rwlock_trywlock(&lock->rwlock) == 0 ? 1 : 0;
  53. }
  54. static inline int liblockdep_rwlock_destroy(liblockdep_pthread_rwlock_t *lock)
  55. {
  56. return pthread_rwlock_destroy(&lock->rwlock);
  57. }
  58. #ifdef __USE_LIBLOCKDEP
  59. #define pthread_rwlock_t liblockdep_pthread_rwlock_t
  60. #define pthread_rwlock_init liblockdep_pthread_rwlock_init
  61. #define pthread_rwlock_rdlock liblockdep_pthread_rwlock_rdlock
  62. #define pthread_rwlock_unlock liblockdep_pthread_rwlock_unlock
  63. #define pthread_rwlock_wrlock liblockdep_pthread_rwlock_wrlock
  64. #define pthread_rwlock_tryrdlock liblockdep_pthread_rwlock_tryrdlock
  65. #define pthread_rwlock_trywlock liblockdep_pthread_rwlock_trywlock
  66. #define pthread_rwlock_destroy liblockdep_rwlock_destroy
  67. #endif
  68. #endif