ref.c 8.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300
  1. /*
  2. * net/tipc/ref.c: TIPC object registry code
  3. *
  4. * Copyright (c) 1991-2006, Ericsson AB
  5. * Copyright (c) 2004-2007, Wind River Systems
  6. * All rights reserved.
  7. *
  8. * Redistribution and use in source and binary forms, with or without
  9. * modification, are permitted provided that the following conditions are met:
  10. *
  11. * 1. Redistributions of source code must retain the above copyright
  12. * notice, this list of conditions and the following disclaimer.
  13. * 2. Redistributions in binary form must reproduce the above copyright
  14. * notice, this list of conditions and the following disclaimer in the
  15. * documentation and/or other materials provided with the distribution.
  16. * 3. Neither the names of the copyright holders nor the names of its
  17. * contributors may be used to endorse or promote products derived from
  18. * this software without specific prior written permission.
  19. *
  20. * Alternatively, this software may be distributed under the terms of the
  21. * GNU General Public License ("GPL") version 2 as published by the Free
  22. * Software Foundation.
  23. *
  24. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  25. * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  26. * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  27. * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
  28. * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  29. * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  30. * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  31. * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  32. * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  33. * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
  34. * POSSIBILITY OF SUCH DAMAGE.
  35. */
  36. #include "core.h"
  37. #include "ref.h"
  38. /**
  39. * struct reference - TIPC object reference entry
  40. * @object: pointer to object associated with reference entry
  41. * @lock: spinlock controlling access to object
  42. * @ref: reference value for object (combines instance & array index info)
  43. */
  44. struct reference {
  45. void *object;
  46. spinlock_t lock;
  47. u32 ref;
  48. };
  49. /**
  50. * struct tipc_ref_table - table of TIPC object reference entries
  51. * @entries: pointer to array of reference entries
  52. * @capacity: array index of first unusable entry
  53. * @init_point: array index of first uninitialized entry
  54. * @first_free: array index of first unused object reference entry
  55. * @last_free: array index of last unused object reference entry
  56. * @index_mask: bitmask for array index portion of reference values
  57. * @start_mask: initial value for instance value portion of reference values
  58. */
  59. struct ref_table {
  60. struct reference *entries;
  61. u32 capacity;
  62. u32 init_point;
  63. u32 first_free;
  64. u32 last_free;
  65. u32 index_mask;
  66. u32 start_mask;
  67. };
  68. /*
  69. * Object reference table consists of 2**N entries.
  70. *
  71. * State Object ptr Reference
  72. * ----- ---------- ---------
  73. * In use non-NULL XXXX|own index
  74. * (XXXX changes each time entry is acquired)
  75. * Free NULL YYYY|next free index
  76. * (YYYY is one more than last used XXXX)
  77. * Uninitialized NULL 0
  78. *
  79. * Entry 0 is not used; this allows index 0 to denote the end of the free list.
  80. *
  81. * Note that a reference value of 0 does not necessarily indicate that an
  82. * entry is uninitialized, since the last entry in the free list could also
  83. * have a reference value of 0 (although this is unlikely).
  84. */
  85. static struct ref_table tipc_ref_table;
  86. static DEFINE_RWLOCK(ref_table_lock);
  87. /**
  88. * tipc_ref_table_init - create reference table for objects
  89. */
  90. int tipc_ref_table_init(u32 requested_size, u32 start)
  91. {
  92. struct reference *table;
  93. u32 actual_size;
  94. /* account for unused entry, then round up size to a power of 2 */
  95. requested_size++;
  96. for (actual_size = 16; actual_size < requested_size; actual_size <<= 1)
  97. /* do nothing */ ;
  98. /* allocate table & mark all entries as uninitialized */
  99. table = vzalloc(actual_size * sizeof(struct reference));
  100. if (table == NULL)
  101. return -ENOMEM;
  102. tipc_ref_table.entries = table;
  103. tipc_ref_table.capacity = requested_size;
  104. tipc_ref_table.init_point = 1;
  105. tipc_ref_table.first_free = 0;
  106. tipc_ref_table.last_free = 0;
  107. tipc_ref_table.index_mask = actual_size - 1;
  108. tipc_ref_table.start_mask = start & ~tipc_ref_table.index_mask;
  109. return 0;
  110. }
  111. /**
  112. * tipc_ref_table_stop - destroy reference table for objects
  113. */
  114. void tipc_ref_table_stop(void)
  115. {
  116. if (!tipc_ref_table.entries)
  117. return;
  118. vfree(tipc_ref_table.entries);
  119. tipc_ref_table.entries = NULL;
  120. }
  121. /**
  122. * tipc_ref_acquire - create reference to an object
  123. *
  124. * Register an object pointer in reference table and lock the object.
  125. * Returns a unique reference value that is used from then on to retrieve the
  126. * object pointer, or to determine that the object has been deregistered.
  127. *
  128. * Note: The object is returned in the locked state so that the caller can
  129. * register a partially initialized object, without running the risk that
  130. * the object will be accessed before initialization is complete.
  131. */
  132. u32 tipc_ref_acquire(void *object, spinlock_t **lock)
  133. {
  134. u32 index;
  135. u32 index_mask;
  136. u32 next_plus_upper;
  137. u32 ref;
  138. struct reference *entry = NULL;
  139. if (!object) {
  140. err("Attempt to acquire reference to non-existent object\n");
  141. return 0;
  142. }
  143. if (!tipc_ref_table.entries) {
  144. err("Reference table not found during acquisition attempt\n");
  145. return 0;
  146. }
  147. /* take a free entry, if available; otherwise initialize a new entry */
  148. write_lock_bh(&ref_table_lock);
  149. if (tipc_ref_table.first_free) {
  150. index = tipc_ref_table.first_free;
  151. entry = &(tipc_ref_table.entries[index]);
  152. index_mask = tipc_ref_table.index_mask;
  153. next_plus_upper = entry->ref;
  154. tipc_ref_table.first_free = next_plus_upper & index_mask;
  155. ref = (next_plus_upper & ~index_mask) + index;
  156. } else if (tipc_ref_table.init_point < tipc_ref_table.capacity) {
  157. index = tipc_ref_table.init_point++;
  158. entry = &(tipc_ref_table.entries[index]);
  159. spin_lock_init(&entry->lock);
  160. ref = tipc_ref_table.start_mask + index;
  161. } else {
  162. ref = 0;
  163. }
  164. write_unlock_bh(&ref_table_lock);
  165. /*
  166. * Grab the lock so no one else can modify this entry
  167. * While we assign its ref value & object pointer
  168. */
  169. if (entry) {
  170. spin_lock_bh(&entry->lock);
  171. entry->ref = ref;
  172. entry->object = object;
  173. *lock = &entry->lock;
  174. /*
  175. * keep it locked, the caller is responsible
  176. * for unlocking this when they're done with it
  177. */
  178. }
  179. return ref;
  180. }
  181. /**
  182. * tipc_ref_discard - invalidate references to an object
  183. *
  184. * Disallow future references to an object and free up the entry for re-use.
  185. * Note: The entry's spin_lock may still be busy after discard
  186. */
  187. void tipc_ref_discard(u32 ref)
  188. {
  189. struct reference *entry;
  190. u32 index;
  191. u32 index_mask;
  192. if (!tipc_ref_table.entries) {
  193. err("Reference table not found during discard attempt\n");
  194. return;
  195. }
  196. index_mask = tipc_ref_table.index_mask;
  197. index = ref & index_mask;
  198. entry = &(tipc_ref_table.entries[index]);
  199. write_lock_bh(&ref_table_lock);
  200. if (!entry->object) {
  201. err("Attempt to discard reference to non-existent object\n");
  202. goto exit;
  203. }
  204. if (entry->ref != ref) {
  205. err("Attempt to discard non-existent reference\n");
  206. goto exit;
  207. }
  208. /*
  209. * mark entry as unused; increment instance part of entry's reference
  210. * to invalidate any subsequent references
  211. */
  212. entry->object = NULL;
  213. entry->ref = (ref & ~index_mask) + (index_mask + 1);
  214. /* append entry to free entry list */
  215. if (tipc_ref_table.first_free == 0)
  216. tipc_ref_table.first_free = index;
  217. else
  218. tipc_ref_table.entries[tipc_ref_table.last_free].ref |= index;
  219. tipc_ref_table.last_free = index;
  220. exit:
  221. write_unlock_bh(&ref_table_lock);
  222. }
  223. /**
  224. * tipc_ref_lock - lock referenced object and return pointer to it
  225. */
  226. void *tipc_ref_lock(u32 ref)
  227. {
  228. if (likely(tipc_ref_table.entries)) {
  229. struct reference *entry;
  230. entry = &tipc_ref_table.entries[ref &
  231. tipc_ref_table.index_mask];
  232. if (likely(entry->ref != 0)) {
  233. spin_lock_bh(&entry->lock);
  234. if (likely((entry->ref == ref) && (entry->object)))
  235. return entry->object;
  236. spin_unlock_bh(&entry->lock);
  237. }
  238. }
  239. return NULL;
  240. }
  241. /**
  242. * tipc_ref_deref - return pointer referenced object (without locking it)
  243. */
  244. void *tipc_ref_deref(u32 ref)
  245. {
  246. if (likely(tipc_ref_table.entries)) {
  247. struct reference *entry;
  248. entry = &tipc_ref_table.entries[ref &
  249. tipc_ref_table.index_mask];
  250. if (likely(entry->ref == ref))
  251. return entry->object;
  252. }
  253. return NULL;
  254. }