atomic64.c 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169
  1. /*
  2. * Generic implementation of 64-bit atomics using spinlocks,
  3. * useful on processors that don't have 64-bit atomic instructions.
  4. *
  5. * Copyright © 2009 Paul Mackerras, IBM Corp. <paulus@au1.ibm.com>
  6. *
  7. * This program is free software; you can redistribute it and/or
  8. * modify it under the terms of the GNU General Public License
  9. * as published by the Free Software Foundation; either version
  10. * 2 of the License, or (at your option) any later version.
  11. */
  12. #include <linux/types.h>
  13. #include <linux/cache.h>
  14. #include <linux/spinlock.h>
  15. #include <linux/init.h>
  16. #include <linux/export.h>
  17. #include <linux/atomic.h>
  18. /*
  19. * We use a hashed array of spinlocks to provide exclusive access
  20. * to each atomic64_t variable. Since this is expected to used on
  21. * systems with small numbers of CPUs (<= 4 or so), we use a
  22. * relatively small array of 16 spinlocks to avoid wasting too much
  23. * memory on the spinlock array.
  24. */
  25. #define NR_LOCKS 16
  26. /*
  27. * Ensure each lock is in a separate cacheline.
  28. */
  29. static union {
  30. raw_spinlock_t lock;
  31. char pad[L1_CACHE_BYTES];
  32. } atomic64_lock[NR_LOCKS] __cacheline_aligned_in_smp = {
  33. [0 ... (NR_LOCKS - 1)] = {
  34. .lock = __RAW_SPIN_LOCK_UNLOCKED(atomic64_lock.lock),
  35. },
  36. };
  37. static inline raw_spinlock_t *lock_addr(const atomic64_t *v)
  38. {
  39. unsigned long addr = (unsigned long) v;
  40. addr >>= L1_CACHE_SHIFT;
  41. addr ^= (addr >> 8) ^ (addr >> 16);
  42. return &atomic64_lock[addr & (NR_LOCKS - 1)].lock;
  43. }
  44. long long atomic64_read(const atomic64_t *v)
  45. {
  46. unsigned long flags;
  47. raw_spinlock_t *lock = lock_addr(v);
  48. long long val;
  49. raw_spin_lock_irqsave(lock, flags);
  50. val = v->counter;
  51. raw_spin_unlock_irqrestore(lock, flags);
  52. return val;
  53. }
  54. EXPORT_SYMBOL(atomic64_read);
  55. void atomic64_set(atomic64_t *v, long long i)
  56. {
  57. unsigned long flags;
  58. raw_spinlock_t *lock = lock_addr(v);
  59. raw_spin_lock_irqsave(lock, flags);
  60. v->counter = i;
  61. raw_spin_unlock_irqrestore(lock, flags);
  62. }
  63. EXPORT_SYMBOL(atomic64_set);
  64. #define ATOMIC64_OP(op, c_op) \
  65. void atomic64_##op(long long a, atomic64_t *v) \
  66. { \
  67. unsigned long flags; \
  68. raw_spinlock_t *lock = lock_addr(v); \
  69. \
  70. raw_spin_lock_irqsave(lock, flags); \
  71. v->counter c_op a; \
  72. raw_spin_unlock_irqrestore(lock, flags); \
  73. } \
  74. EXPORT_SYMBOL(atomic64_##op);
  75. #define ATOMIC64_OP_RETURN(op, c_op) \
  76. long long atomic64_##op##_return(long long a, atomic64_t *v) \
  77. { \
  78. unsigned long flags; \
  79. raw_spinlock_t *lock = lock_addr(v); \
  80. long long val; \
  81. \
  82. raw_spin_lock_irqsave(lock, flags); \
  83. val = (v->counter c_op a); \
  84. raw_spin_unlock_irqrestore(lock, flags); \
  85. return val; \
  86. } \
  87. EXPORT_SYMBOL(atomic64_##op##_return);
  88. #define ATOMIC64_OPS(op, c_op) \
  89. ATOMIC64_OP(op, c_op) \
  90. ATOMIC64_OP_RETURN(op, c_op)
  91. ATOMIC64_OPS(add, +=)
  92. ATOMIC64_OPS(sub, -=)
  93. #undef ATOMIC64_OPS
  94. #undef ATOMIC64_OP_RETURN
  95. #undef ATOMIC64_OP
  96. long long atomic64_dec_if_positive(atomic64_t *v)
  97. {
  98. unsigned long flags;
  99. raw_spinlock_t *lock = lock_addr(v);
  100. long long val;
  101. raw_spin_lock_irqsave(lock, flags);
  102. val = v->counter - 1;
  103. if (val >= 0)
  104. v->counter = val;
  105. raw_spin_unlock_irqrestore(lock, flags);
  106. return val;
  107. }
  108. EXPORT_SYMBOL(atomic64_dec_if_positive);
  109. long long atomic64_cmpxchg(atomic64_t *v, long long o, long long n)
  110. {
  111. unsigned long flags;
  112. raw_spinlock_t *lock = lock_addr(v);
  113. long long val;
  114. raw_spin_lock_irqsave(lock, flags);
  115. val = v->counter;
  116. if (val == o)
  117. v->counter = n;
  118. raw_spin_unlock_irqrestore(lock, flags);
  119. return val;
  120. }
  121. EXPORT_SYMBOL(atomic64_cmpxchg);
  122. long long atomic64_xchg(atomic64_t *v, long long new)
  123. {
  124. unsigned long flags;
  125. raw_spinlock_t *lock = lock_addr(v);
  126. long long val;
  127. raw_spin_lock_irqsave(lock, flags);
  128. val = v->counter;
  129. v->counter = new;
  130. raw_spin_unlock_irqrestore(lock, flags);
  131. return val;
  132. }
  133. EXPORT_SYMBOL(atomic64_xchg);
  134. int atomic64_add_unless(atomic64_t *v, long long a, long long u)
  135. {
  136. unsigned long flags;
  137. raw_spinlock_t *lock = lock_addr(v);
  138. int ret = 0;
  139. raw_spin_lock_irqsave(lock, flags);
  140. if (v->counter != u) {
  141. v->counter += a;
  142. ret = 1;
  143. }
  144. raw_spin_unlock_irqrestore(lock, flags);
  145. return ret;
  146. }
  147. EXPORT_SYMBOL(atomic64_add_unless);