idr.c 27 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054
  1. #include <common/idr.h>
  2. #include <mm/slab.h>
  3. /**
  4. * @brief 更换两个idr_layer指针
  5. *
  6. * @param a
  7. * @param b
  8. */
  9. static void __swap(struct idr_layer **a, struct idr_layer **b)
  10. {
  11. struct idr_layer *t = *a;
  12. *a = *b, *b = t;
  13. }
  14. /**
  15. * @brief 初始化idr - 你需要保证函数调用之前 free_list指针 为空
  16. *
  17. * @param idp
  18. */
  19. void idr_init(struct idr *idp)
  20. {
  21. memset(idp, 0, sizeof(struct idr));
  22. spin_init(&idp->lock);
  23. }
  24. /**
  25. * @brief 向idr的free_list中添加一个节点(空节点)
  26. *
  27. * @param idp
  28. * @param p
  29. */
  30. static void __move_to_free_list(struct idr *idp, struct idr_layer *p)
  31. {
  32. unsigned long flags;
  33. spin_lock_irqsave(&idp->lock, flags);
  34. // 插入free_list
  35. p->ary[0] = idp->free_list;
  36. io_sfence();
  37. idp->free_list = p;
  38. io_sfence();
  39. ++(idp->id_free_cnt);
  40. spin_unlock_irqrestore(&idp->lock, flags);
  41. }
  42. /**
  43. * @brief Get the free_idr_layer from free list object
  44. *
  45. * @param idp
  46. * @return void*
  47. */
  48. static void *__get_from_free_list(struct idr *idp)
  49. {
  50. if (idp->id_free_cnt == 0)
  51. {
  52. if (idr_preload(idp, 0) != 0)
  53. {
  54. kBUG("idr-module find a BUG: get free node fail.(Possible ENOMEM error)");
  55. return NULL;
  56. }
  57. }
  58. unsigned long flags;
  59. spin_lock_irqsave(&idp->lock, flags);
  60. // free_list还有节点
  61. struct idr_layer *item = idp->free_list;
  62. if (item == NULL)
  63. {
  64. BUG_ON(1);
  65. }
  66. io_sfence();
  67. idp->free_list = idp->free_list->ary[0];
  68. io_sfence();
  69. item->ary[0] = NULL; // 记得清空原来的数据
  70. io_sfence();
  71. --(idp->id_free_cnt);
  72. spin_unlock_irqrestore(&idp->lock, flags);
  73. return item;
  74. }
  75. /**
  76. * @brief 为idr预分配空间
  77. *
  78. * @param idp
  79. * @param gfp_mask
  80. * @return int (如果分配成功,将返回0; 否则返回负数 -ENOMEM, 有可能是内存空间不够)
  81. */
  82. int idr_preload(struct idr *idp, gfp_t gfp_mask)
  83. {
  84. int timer = 0;
  85. while (idp->id_free_cnt < IDR_FREE_MAX)
  86. {
  87. struct idr_layer *new_one;
  88. new_one = kzalloc(sizeof(struct idr_layer), gfp_mask); // 默认清空?
  89. if (unlikely(new_one == NULL))
  90. return -ENOMEM;
  91. __move_to_free_list(idp, new_one);
  92. timer++;
  93. }
  94. return 0;
  95. }
  96. /**
  97. * @brief 释放一个layer的空间
  98. *
  99. * @param p
  100. */
  101. static void __idr_layer_free(struct idr_layer *p)
  102. {
  103. kfree(p);
  104. }
  105. /**
  106. * @brief 向上生长一层idr_layer
  107. *
  108. * @param idp
  109. * @return int (0生长成功, 否则返回错误码)
  110. */
  111. static int __idr_grow(struct idr *idp)
  112. {
  113. struct idr_layer *new_node = __get_from_free_list(idp);
  114. if (NULL == new_node)
  115. return -ENOMEM;
  116. __swap(&new_node, &idp->top);
  117. idp->top->ary[0] = new_node;
  118. idp->top->layer = new_node ? (new_node->layer + 1) : 0; // 注意特判空指针
  119. idp->top->bitmap = 0;
  120. idp->top->full = 0; // clear
  121. if (new_node != NULL) // 设置第0位 = 1, 同时维护树的大小
  122. {
  123. idp->top->bitmap = 1;
  124. }
  125. if (new_node != NULL && new_node->full == IDR_FULL)
  126. {
  127. idp->top->full = 1; // 别忘了初始化 full
  128. }
  129. return 0;
  130. }
  131. /**
  132. * @brief 获取一个没有被占领的ID
  133. *
  134. * @param idp
  135. * @param stk 栈空间
  136. * @return int (负数表示获取ID失败, [0 <= id && id <= INT_MAX] 则获取ID成功)
  137. */
  138. static int __idr_get_empty_slot(struct idr *idp, struct idr_layer **stk)
  139. {
  140. // 注意特判 idp->top == NULL
  141. while (NULL == idp->top || idp->top->full == IDR_FULL)
  142. if (__idr_grow(idp) != 0)
  143. return -ENOMEM;
  144. int64_t id = 0;
  145. int layer = idp->top->layer;
  146. BUG_ON(layer + 1 >= 7);
  147. stk[layer + 1] = NULL; // 标志为数组末尾
  148. struct idr_layer *cur_layer = idp->top;
  149. while (layer >= 0)
  150. {
  151. stk[layer] = cur_layer;
  152. int pos = __lowbit_id(~cur_layer->full);
  153. if (unlikely(pos < 0))
  154. {
  155. kBUG("Value 'cur_layer->full' had been full;"
  156. "but __idr_get_empty_slot still try to insert a value.");
  157. }
  158. id = (id << IDR_BITS) | pos;
  159. cur_layer = cur_layer->ary[pos];
  160. if (layer > 0 && NULL == cur_layer) // 只有非叶子节点才需要开辟儿子节点
  161. {
  162. // 初始化儿子节点
  163. cur_layer = __get_from_free_list(idp);
  164. if (NULL == cur_layer)
  165. return -ENOMEM;
  166. cur_layer->layer = layer - 1; // 儿子节点的layer
  167. cur_layer->full = 0;
  168. cur_layer->bitmap = 0;
  169. stk[layer]->ary[pos] = cur_layer; // 最后别忘了记录儿子节点
  170. }
  171. --layer;
  172. }
  173. return id;
  174. }
  175. /**
  176. * @brief 更新full对象 (辅助函数,内部没有边界特判)
  177. *
  178. * @param idp
  179. * @param id
  180. * @param stk 需要保证stk数组末尾是NULL
  181. * @param mark 0代表叶子空, 1代表叶子非空但未满, 2代表满
  182. */
  183. static __always_inline void __idr_mark_full(struct idr *idp, int id, struct idr_layer **stk, int mark)
  184. {
  185. int64_t __id = (int64_t)id;
  186. if (unlikely(NULL == stk[0] || NULL == idp->top))
  187. {
  188. kBUG("idr-module find a BUG: idp->top can't be NULL.");
  189. return;
  190. }
  191. // 处理叶子节点的full/bitmap标记
  192. int64_t layer_id = __id & IDR_MASK;
  193. if (mark == 2)
  194. stk[0]->full |= (1ull << layer_id);
  195. if (mark >= 1)
  196. stk[0]->bitmap |= (1ull << layer_id);
  197. for (int i = 1; stk[i]; ++i)
  198. {
  199. __id >>= IDR_BITS;
  200. layer_id = __id & IDR_MASK;
  201. stk[i]->bitmap |= (1ull << layer_id);
  202. if (stk[i - 1]->full == IDR_FULL)
  203. stk[i]->full |= (1ull << layer_id);
  204. }
  205. }
  206. /**
  207. * @brief 提取一条已存在的路径
  208. *
  209. * @param idp
  210. * @param id
  211. * @param stk
  212. * @return int (0表示没有这条路径, 1表示找到这条路径)
  213. */
  214. static __always_inline int __idr_get_path(struct idr *idp, int id, struct idr_layer **stk)
  215. {
  216. int64_t __id = (int64_t)id;
  217. if (unlikely(idp->top == NULL || __id < 0))
  218. {
  219. kBUG("idr-module find a BUG: idp->top can't be NULL and id must be non-negative.");
  220. return 0;
  221. }
  222. struct idr_layer *cur_layer = idp->top;
  223. int layer = cur_layer->layer;
  224. stk[layer + 1] = NULL; // 标志数组结尾
  225. if (unlikely((__id >> ((layer + 1ull) * IDR_BITS)) > 0))
  226. {
  227. kBUG("idr-module find a BUG: id is invalid.");
  228. return 0;
  229. }
  230. // 提取路径
  231. while (layer >= 0)
  232. {
  233. stk[layer] = cur_layer;
  234. int64_t layer_id = (__id >> (layer * IDR_BITS)) & IDR_MASK;
  235. if (unlikely(((cur_layer->bitmap >> layer_id) & 1) == 0))
  236. {
  237. kBUG("idr-module find a BUG: no-such son.");
  238. return 0; // 没有这一个儿子
  239. }
  240. cur_layer = cur_layer->ary[layer_id];
  241. --layer;
  242. }
  243. return 1;
  244. }
  245. /**
  246. * @brief 更新full对象 (辅助函数,内部没有边界特判)
  247. *
  248. * @param idp
  249. * @param id
  250. * @param stk 需要保证stk数组末尾是NULL
  251. * @param mark 0代表叶子空, 1代表叶子非空但未满, 2代表满
  252. */
  253. static __always_inline void __idr_erase_full(struct idr *idp, int id, struct idr_layer **stk, int mark)
  254. {
  255. int64_t __id = (int64_t)id;
  256. if (unlikely(NULL == stk[0] || NULL == idp->top))
  257. {
  258. kBUG("idr-module find a BUG: idp->top can't be NULL.");
  259. return;
  260. }
  261. // 处理叶子节点的full/bitmap标记
  262. int64_t layer_id = __id & IDR_MASK;
  263. if (mark == 0) // 叶子的某个插槽为空
  264. {
  265. stk[0]->ary[layer_id] = NULL;
  266. stk[0]->bitmap ^= (1ull << layer_id);
  267. }
  268. if (mark != 2 && ((stk[0]->full >> layer_id) & 1))
  269. stk[0]->full ^= (1ull << layer_id);
  270. // 删除节点
  271. for (int layer = 1; stk[layer]; ++layer)
  272. {
  273. __id >>= IDR_BITS;
  274. layer_id = __id & IDR_MASK;
  275. if (NULL == stk[layer - 1]->bitmap) // 儿子是空节点
  276. {
  277. stk[layer]->ary[layer_id] = NULL;
  278. stk[layer]->bitmap ^= (1ull << layer_id);
  279. if ((stk[layer]->full >> layer_id) & 1)
  280. stk[layer]->full ^= (1ull << layer_id);
  281. __idr_layer_free(stk[layer - 1]);
  282. stk[layer - 1] = NULL; // 释放空间记得设置为 NULL
  283. }
  284. else if (stk[layer - 1]->full != IDR_FULL)
  285. {
  286. if ((stk[layer]->full >> layer_id) & 1)
  287. stk[layer]->full ^= (1ull << layer_id);
  288. }
  289. }
  290. // 特判根节点是否只剩0号儿子节点 (注意还要layer > 0)
  291. // (注意,有可能出现idp->top=NULL)
  292. // bitmap: 1000...000/00.....000
  293. while (idp->top != NULL && ((idp->top->bitmap <= 1 && idp->top->layer > 0) || // 一条链的情况
  294. (idp->top->layer == 0 && idp->top->bitmap == 0))) // 最后一个点的情况
  295. {
  296. struct idr_layer *t = idp->top->layer ? idp->top->ary[0] : NULL;
  297. __idr_layer_free(idp->top);
  298. idp->top = t;
  299. }
  300. }
  301. /**
  302. * @brief 内部的分配ID函数 (辅助函数)
  303. *
  304. * @param idp
  305. * @param ptr
  306. * @param starting_id 暂时没用
  307. * @return (0 <= id <= INT_MAX 表示申请的ID;否则是负数错误码, 可能是内存空间不够或者程序逻辑有误);
  308. */
  309. static int __idr_get_new_above_int(struct idr *idp, void *ptr, int starting_id)
  310. {
  311. struct idr_layer *stk[MAX_LEVEL + 1] = {0};
  312. // kdebug("stk=%#018lx, sizeof_stk=%d", stk, sizeof(stk));
  313. // memset(stk, 0, sizeof(stk));
  314. // 你可以选择 memset(stk, 0, sizeof(stk));
  315. int64_t id = __idr_get_empty_slot(idp, stk);
  316. if (id >= 0)
  317. {
  318. stk[0]->ary[IDR_MASK & id] = ptr;
  319. __idr_mark_full(idp, id, stk, 2);
  320. }
  321. return id;
  322. }
  323. /**
  324. * @brief 从[0,INT_MAX]区间内返回一个最小的空闲ID
  325. *
  326. * @param idp
  327. * @param ptr - id 所对应的指针
  328. * @param int* id - 传入int指针,获取到的NEW_ID存在id里
  329. * @return int (0表示获取id成功, 负数代表错误 - 可能是内存空间不够)
  330. */
  331. int idr_alloc(struct idr *idp, void *ptr, int *id)
  332. {
  333. int rv = __idr_get_new_above_int(idp, ptr, 0);
  334. if (rv < 0)
  335. return rv; // error
  336. *id = rv;
  337. return 0;
  338. }
  339. /**
  340. * @brief 删除一个id, 但是不释放对应的ptr指向的空间, 同时返回这个被删除id所对应的ptr
  341. *
  342. * @param idp
  343. * @param id
  344. * @return void*
  345. * (如果删除成功,就返回被删除id所对应的ptr;否则返回NULL。注意:如果这个id本来就和NULL绑定,那么也会返回NULL)
  346. */
  347. void *idr_remove(struct idr *idp, int id)
  348. {
  349. int64_t __id = (int64_t)id;
  350. if (unlikely(idp->top == NULL || __id < 0))
  351. return NULL;
  352. struct idr_layer *stk[MAX_LEVEL + 1] = {0};
  353. if (0 == __idr_get_path(idp, __id, stk))
  354. return NULL; // 找不到路径
  355. void *ret = stk[0]->ary[__id & IDR_MASK];
  356. __idr_erase_full(idp, __id, stk, 0);
  357. return ret;
  358. }
  359. /**
  360. * @brief 移除IDR中所有的节点,如果free=true,则同时释放所有数据指针的空间(kfree)
  361. *
  362. * @param idp
  363. * @param free
  364. */
  365. static void __idr_remove_all_with_free(struct idr *idp, bool free)
  366. {
  367. if (unlikely(NULL == idp->top))
  368. {
  369. kBUG("idr-module find a BUG: idp->top can't be NULL.");
  370. return;
  371. }
  372. int sz = sizeof(struct idr_layer);
  373. struct idr_layer *stk[MAX_LEVEL + 1] = {0};
  374. struct idr_layer *cur_layer = idp->top;
  375. int layer = cur_layer->layer;
  376. BUG_ON(layer + 1 >= 7);
  377. stk[layer + 1] = NULL; // 标记数组结尾
  378. while (cur_layer != NULL)
  379. {
  380. if (layer > 0 && cur_layer->bitmap) // 非叶子节点
  381. {
  382. stk[layer] = cur_layer; // 入栈
  383. int64_t id = __lowbit_id(cur_layer->bitmap);
  384. cur_layer->bitmap ^= (1ull << id);
  385. cur_layer = cur_layer->ary[id];
  386. stk[layer]->ary[id] = NULL;
  387. --layer;
  388. }
  389. else
  390. {
  391. if (free)
  392. {
  393. for (int i = 0; i < IDR_SIZE; i++) // 释放数据指针的空间
  394. {
  395. kfree(cur_layer->ary[i]);
  396. cur_layer->ary[i] = NULL;
  397. }
  398. }
  399. __idr_layer_free(cur_layer); // 释放空间记得设置为NULL
  400. ++layer;
  401. cur_layer = stk[layer]; // 出栈
  402. }
  403. }
  404. idp->top = NULL;
  405. }
  406. /**
  407. * @brief 删除idr的所有节点,同时释放数据指针的空间,回收free_list的所有空间 - (数据指针指ID所绑定的pointer)
  408. * @param idp
  409. */
  410. static void __idr_destroy_with_free(struct idr *idp)
  411. {
  412. if (likely(idp->top))
  413. __idr_remove_all_with_free(idp, 1);
  414. idp->top = NULL;
  415. while (idp->id_free_cnt)
  416. __idr_layer_free(__get_from_free_list(idp));
  417. idp->free_list = NULL;
  418. }
  419. /**
  420. * @brief 删除所有的ID
  421. *
  422. * @param idp
  423. */
  424. void idr_remove_all(struct idr *idp)
  425. {
  426. if (unlikely(NULL == idp->top))
  427. return;
  428. __idr_remove_all_with_free(idp, 0);
  429. }
  430. /**
  431. * @brief 释放一个idr占用的所有空间
  432. *
  433. * @param idp
  434. */
  435. void idr_destroy(struct idr *idp)
  436. {
  437. idr_remove_all(idp);
  438. idp->top = NULL;
  439. while (idp->id_free_cnt)
  440. __idr_layer_free(__get_from_free_list(idp));
  441. idp->free_list = NULL;
  442. }
  443. /**
  444. * @brief 返回id对应的数据指针
  445. *
  446. * @param idp
  447. * @param id
  448. * @return void* (如果id不存在返回NULL;否则返回对应的指针ptr; 注意: 有可能用户的数据本来就是NULL)
  449. */
  450. void *idr_find(struct idr *idp, int id)
  451. {
  452. int64_t __id = (int64_t)id;
  453. if (unlikely(idp->top == NULL || __id < 0))
  454. {
  455. // kwarn("idr-find: idp->top == NULL || id < 0.");
  456. return NULL;
  457. }
  458. struct idr_layer *cur_layer = idp->top;
  459. int layer = cur_layer->layer; // 特判NULL
  460. barrier();
  461. // 如果查询的ID的bit数量比layer*IDR_BITS还大, 直接返回NULL
  462. if ((__id >> ((layer + 1) * IDR_BITS)) > 0)
  463. return NULL;
  464. barrier();
  465. barrier();
  466. int64_t layer_id = 0;
  467. while (layer >= 0 && cur_layer != NULL)
  468. {
  469. barrier();
  470. layer_id = (__id >> (IDR_BITS * layer)) & IDR_MASK;
  471. barrier();
  472. cur_layer = cur_layer->ary[layer_id];
  473. --layer;
  474. }
  475. return cur_layer;
  476. }
  477. /**
  478. * @brief 返回id大于 start_id 的数据指针(即非空闲id对应的指针), 如果没有则返回NULL; 可以传入nextid指针,获取下一个id;
  479. * 时间复杂度O(log_64(n)), 空间复杂度O(log_64(n)) 约为 6;
  480. *
  481. * @param idp
  482. * @param start_id
  483. * @param nextid
  484. * @return void* (如果分配,将返回该ID对应的数据指针; 否则返回NULL。注意,
  485. * 返回NULL不一定代表这ID不存在,有可能该ID就是与空指针绑定。)
  486. */
  487. void *idr_find_next_getid(struct idr *idp, int64_t start_id, int *nextid)
  488. {
  489. BUG_ON(nextid == NULL);
  490. if (unlikely(idp->top == NULL))
  491. {
  492. *nextid = -1;
  493. return NULL;
  494. }
  495. ++start_id;
  496. start_id = max(0, start_id); // 特判负数
  497. *nextid = 0;
  498. struct idr_layer *stk[MAX_LEVEL + 1] = {0};
  499. // memset(stk, 0, sizeof(struct idr_layer *) * (MAX_LEVEL + 1));
  500. bool state[MAX_LEVEL + 1] = {0}; // 标记是否大于等于]
  501. int pos_i[MAX_LEVEL + 1] = {0};
  502. // memset(state, 0, sizeof(state));
  503. // memset(pos_i, 0, sizeof(pos_i)); // 必须清空
  504. struct idr_layer *cur_layer = idp->top;
  505. bool cur_state = false;
  506. bool init_flag = true;
  507. int layer = cur_layer->layer;
  508. BUG_ON(layer + 1 >= 7);
  509. stk[layer + 1] = NULL; // 标记数组结尾
  510. // 如果查询的ID的bit数量比layer*IDR_BITS还大, 直接返回NULL
  511. if ((start_id >> ((layer + 1) * IDR_BITS)) > 0)
  512. {
  513. *nextid = -1;
  514. return NULL;
  515. }
  516. while (cur_layer) // layer < top->layer + 1
  517. {
  518. BUG_ON(layer < 0);
  519. if (init_flag) // 第一次入栈
  520. {
  521. stk[layer] = cur_layer;
  522. state[layer] = cur_state;
  523. pos_i[layer] = cur_state ? 0 : ((start_id >> (layer * IDR_BITS)) & IDR_MASK);
  524. }
  525. else
  526. {
  527. pos_i[layer]++;
  528. state[layer] = cur_state = true;
  529. }
  530. BUG_ON(pos_i[layer] >= 64);
  531. unsigned long t_bitmap = (cur_layer->bitmap >> pos_i[layer]);
  532. if (t_bitmap) // 进一步递归到儿子下面去
  533. {
  534. int64_t layer_id = __lowbit_id(t_bitmap) + pos_i[layer];
  535. // 特别情况
  536. if ((cur_state == false) && (layer_id > pos_i[layer] > 0))
  537. cur_state = true;
  538. pos_i[layer] = layer_id;
  539. *nextid = (((uint64_t)*nextid) << IDR_BITS) | layer_id; // 更新答案
  540. if (layer == 0)
  541. {
  542. // 找到下一个id: nextid
  543. return cur_layer->ary[layer_id];
  544. }
  545. cur_layer = cur_layer->ary[layer_id];
  546. init_flag = true; // 儿子节点第一次入栈, 需要init
  547. --layer;
  548. }
  549. else // 子树搜索完毕,向上回溯
  550. {
  551. (*nextid) >>= IDR_BITS; // 维护答案
  552. ++layer;
  553. cur_layer = stk[layer];
  554. init_flag = false; // 不是第一次入栈, 不需要init
  555. }
  556. }
  557. *nextid = -1;
  558. return NULL; // 找不到
  559. }
  560. /**
  561. * @brief 返回id大于 start_id 的数据指针(即非空闲id对应的指针), 如果没有则返回NULL
  562. *
  563. * @param idp
  564. * @param start_id
  565. * @return void* (如果分配,将返回该ID对应的数据指针; 否则返回NULL。注意,
  566. * 返回NULL不一定代表这ID不存在,有可能该ID就是与空指针绑定。)
  567. */
  568. void *idr_find_next(struct idr *idp, int start_id)
  569. {
  570. int nextid;
  571. void *ptr = idr_find_next_getid(idp, start_id, &nextid);
  572. return ptr; // 当 nextid == -1 时, 出现错误
  573. }
  574. /**
  575. * @brief 根据id替换指针,你需要保证这个id存在于idr中,否则将会出现错误
  576. *
  577. * @param idp
  578. * @param ptr (要替换旧指针的新指针 - new_ptr)
  579. * @param id
  580. * @param old_ptr (返回旧指针, 注意NULL不一定是出现错误,有可能是数据本来就是NULL)
  581. * @return int (0代表成功,否则就是负数 - 代表错误)
  582. */
  583. int idr_replace_get_old(struct idr *idp, void *ptr, int id, void **old_ptr)
  584. {
  585. int64_t __id = (int64_t)id;
  586. if (unlikely(old_ptr == NULL))
  587. {
  588. BUG_ON(1);
  589. return -EINVAL;
  590. }
  591. *old_ptr = NULL;
  592. if (unlikely(idp->top == NULL || __id < 0))
  593. return -EDOM; // 参数错误
  594. struct idr_layer *cur_layer = idp->top;
  595. int64_t layer = cur_layer->layer;
  596. // 如果查询的ID的bit数量比layer*IDR_BITS还大, 直接返回NULL
  597. if ((__id >> ((layer + 1) * IDR_BITS)) > 0)
  598. return -EDOM;
  599. while (layer > 0)
  600. {
  601. int64_t layer_id = (__id >> (layer * IDR_BITS)) & IDR_MASK;
  602. if (unlikely(NULL == cur_layer->ary[layer_id]))
  603. return -ENOMEM;
  604. cur_layer = cur_layer->ary[layer_id];
  605. layer--;
  606. }
  607. __id &= IDR_MASK;
  608. *old_ptr = cur_layer->ary[__id];
  609. cur_layer->ary[__id] = ptr;
  610. return 0;
  611. }
  612. /**
  613. * @brief 根据id替换指针,你需要保证这个id存在于idr中,否则将会出现错误
  614. *
  615. * @param idp
  616. * @param ptr (要替换 '旧数据指针' 的 '新数据指针' - new_ptr)
  617. * @param id
  618. * @return int (0代表成功,否则就是错误码 - 代表错误)
  619. */
  620. int idr_replace(struct idr *idp, void *ptr, int id)
  621. {
  622. int64_t __id = (int64_t)id;
  623. if (__id < 0)
  624. return -EDOM;
  625. void *old_ptr;
  626. int flags = idr_replace_get_old(idp, ptr, __id, &old_ptr);
  627. return flags;
  628. }
  629. /**
  630. * @brief 判断一个idr是否为空
  631. *
  632. * @param idp
  633. * @return true
  634. * @return false
  635. */
  636. bool idr_empty(struct idr *idp)
  637. {
  638. if (idp == NULL || idp->top == NULL || !idp->top->bitmap)
  639. return true;
  640. return false;
  641. }
  642. static bool __idr_cnt_pd(struct idr_layer *cur_layer, int layer_id)
  643. {
  644. // if(layer_id)
  645. unsigned long flags = ((cur_layer->bitmap) >> layer_id);
  646. if ((flags % 2) == 0)
  647. {
  648. barrier();
  649. return false; // 没有这一个儿子
  650. }
  651. return true;
  652. }
  653. static bool __idr_cnt(int layer, int id, struct idr_layer *cur_layer)
  654. {
  655. int64_t __id = (int64_t)id;
  656. while (layer >= 0) // 提取路径
  657. {
  658. barrier();
  659. int64_t layer_id = (__id >> (layer * IDR_BITS)) & IDR_MASK;
  660. barrier();
  661. if (__idr_cnt_pd(cur_layer, layer_id) == false)
  662. return false;
  663. barrier();
  664. barrier();
  665. cur_layer = cur_layer->ary[layer_id];
  666. barrier();
  667. --layer;
  668. }
  669. return true;
  670. }
  671. /**
  672. * @brief 这个函数是可以用于判断一个ID是否已经被分配的。
  673. *
  674. * @param idp
  675. * @param id
  676. * @return true
  677. * @return false
  678. */
  679. bool idr_count(struct idr *idp, int id)
  680. {
  681. int64_t __id = (int64_t)id;
  682. barrier();
  683. if (unlikely(idp == NULL || idp->top == NULL || __id < 0))
  684. return false;
  685. barrier();
  686. struct idr_layer *cur_layer = idp->top;
  687. barrier();
  688. int layer = cur_layer->layer;
  689. // 如果查询的ID的bit数量比 layer*IDR_BITS 还大, 直接返回false
  690. if (unlikely((__id >> ((layer + 1ull) * IDR_BITS)) > 0))
  691. {
  692. BUG_ON(1);
  693. return false;
  694. }
  695. barrier();
  696. return __idr_cnt(layer, id, cur_layer);
  697. }
  698. /********* ****************************************** ida - idr 函数实现分割线
  699. * **********************************************************/
  700. /**
  701. * @brief 初始化IDA, 你需要保证调用函数之前, ida的free_list为空, 否则会导致内存泄漏
  702. * @param ida_p
  703. */
  704. void ida_init(struct ida *ida_p)
  705. {
  706. memset(ida_p, 0, sizeof(struct ida));
  707. idr_init(&ida_p->idr);
  708. }
  709. /**
  710. * @brief 释放bitmap空间
  711. *
  712. */
  713. static void __ida_bitmap_free(struct ida_bitmap *bitmap)
  714. {
  715. kfree(bitmap);
  716. }
  717. /**
  718. * @brief 为ida预分配空间
  719. *
  720. * @param ida_p
  721. * @param gfp_mask
  722. * @return int (如果分配成功,将返回0; 否则返回负数错误码, 有可能是内存空间不够)
  723. */
  724. int ida_preload(struct ida *ida_p, gfp_t gfp_mask)
  725. {
  726. if (idr_preload(&ida_p->idr, gfp_mask) != 0)
  727. return -ENOMEM;
  728. spin_lock(&ida_p->idr.lock);
  729. if (NULL == ida_p->free_list)
  730. {
  731. struct ida_bitmap *bitmap;
  732. bitmap = kzalloc(sizeof(struct ida_bitmap), gfp_mask);
  733. if (NULL == bitmap)
  734. {
  735. spin_unlock(&ida_p->idr.lock);
  736. return -ENOMEM;
  737. }
  738. ida_p->free_list = bitmap;
  739. }
  740. spin_unlock(&ida_p->idr.lock);
  741. return 0;
  742. }
  743. /**
  744. * @brief Get the ida bitmap object
  745. *
  746. * @param ida_p
  747. * @return void*
  748. */
  749. static void *__get_ida_bitmap(struct ida *ida_p, gfp_t gfp_mask)
  750. {
  751. if (NULL == ida_p->free_list)
  752. if (ida_preload(ida_p, gfp_mask) < 0)
  753. {
  754. kBUG("error : no memory.");
  755. return NULL;
  756. }
  757. struct ida_bitmap *tmp = ida_p->free_list;
  758. ida_p->free_list = NULL;
  759. return tmp;
  760. }
  761. /**
  762. * @brief 从bitmap中获取id, 并且标记这个ID已经被使用
  763. * @return int
  764. */
  765. static int __get_id_from_bitmap(struct ida_bitmap *bmp)
  766. {
  767. int ret = 0;
  768. for (int ary_id = 0; ary_id < IDA_BITMAP_LONGS; ary_id++)
  769. {
  770. if (bmp->bitmap[ary_id] != IDR_FULL)
  771. {
  772. int bmp_id = __lowbit_id(~bmp->bitmap[ary_id]);
  773. bmp->bitmap[ary_id] |= (1ull << bmp_id);
  774. bmp->count++; // 注意, 这里已经标记这一位已经使用, 同时更新了ida_count
  775. if (unlikely((unsigned long long)ary_id * IDA_BMP_SIZE + bmp_id > INT32_MAX))
  776. {
  777. BUG_ON(1);
  778. // kBUG("ida设置id范围为[0, INT32_MAX], 但ida获取的id数值超过INT32_MAX.");
  779. return -EDOM;
  780. }
  781. return ary_id * IDA_BMP_SIZE + bmp_id;
  782. }
  783. }
  784. return -EDOM; // 不合法
  785. }
  786. /**
  787. * @brief 获取一个ID
  788. *
  789. * @param ida_p
  790. * @param p_id
  791. * @return int (0表示获取ID成功, 否则是负数 - 错误码)
  792. */
  793. int ida_alloc(struct ida *ida_p, int *p_id)
  794. {
  795. BUG_ON(p_id == NULL);
  796. *p_id = -1;
  797. struct idr_layer *stk[MAX_LEVEL + 1] = {0}; // 你可以选择memset(0)
  798. // memset(stk, 0, sizeof(struct idr_layer *) * (MAX_LEVEL + 1));
  799. io_sfence();
  800. int64_t idr_id = __idr_get_empty_slot(&ida_p->idr, stk);
  801. // 如果stk[0]=NULL,可能是idr内部出错/内存空间不够
  802. if (unlikely(NULL == stk[0]))
  803. return -ENOMEM;
  804. if (unlikely(idr_id < 0))
  805. return idr_id;
  806. int64_t layer_id = idr_id & IDR_MASK;
  807. if (NULL == stk[0]->ary[layer_id])
  808. stk[0]->ary[layer_id] = __get_ida_bitmap(ida_p, 0);
  809. if (unlikely(NULL == stk[0]->ary[layer_id]))
  810. return -ENOMEM;
  811. struct ida_bitmap *bmp = (struct ida_bitmap *)stk[0]->ary[layer_id];
  812. int low_id = __get_id_from_bitmap(bmp);
  813. if (unlikely(low_id < 0))
  814. return low_id;
  815. *p_id = idr_id * IDA_BITMAP_BITS + low_id;
  816. __idr_mark_full(&ida_p->idr, idr_id, stk, (bmp->count == IDA_FULL ? 2 : 1));
  817. return 0;
  818. }
  819. /**
  820. * @brief 查询ID是否已经被分配
  821. *
  822. * @param ida_p
  823. * @param id
  824. * @return true
  825. * @return false
  826. */
  827. bool ida_count(struct ida *ida_p, int id)
  828. {
  829. int64_t __id = (int64_t)id;
  830. if (unlikely(NULL == ida_p || NULL == ida_p->idr.top || id < 0))
  831. return false;
  832. int idr_id = __id / IDA_BITMAP_BITS;
  833. int ary_id = (__id % IDA_BITMAP_BITS) / IDA_BMP_SIZE;
  834. int bmp_id = (__id % IDA_BITMAP_BITS) % IDA_BMP_SIZE;
  835. struct ida_bitmap *bmp = idr_find(&ida_p->idr, idr_id);
  836. if (NULL == bmp)
  837. return false;
  838. return ((bmp->bitmap[ary_id] >> bmp_id) & 1);
  839. }
  840. /**
  841. * @brief 删除一个ID
  842. *
  843. * @param ida_p
  844. * @param id
  845. */
  846. void ida_remove(struct ida *ida_p, int id)
  847. {
  848. int64_t __id = (int64_t)id;
  849. if (unlikely(NULL == ida_p || NULL == ida_p->idr.top || id < 0))
  850. return;
  851. int64_t idr_id = __id / IDA_BITMAP_BITS;
  852. int64_t ary_id = (__id % IDA_BITMAP_BITS) / IDA_BMP_SIZE;
  853. int64_t bmp_id = (__id % IDA_BITMAP_BITS) % IDA_BMP_SIZE;
  854. struct idr_layer *stk[MAX_LEVEL + 1] = {0};
  855. // memset(stk, 0, sizeof(struct idr_layer *) * (MAX_LEVEL + 1));
  856. if (0 == __idr_get_path(&ida_p->idr, idr_id, stk))
  857. return;
  858. struct ida_bitmap *b_p = (struct ida_bitmap *)(stk[0]->ary[idr_id & IDR_MASK]);
  859. // 不存在这个ID 或者 b_p == NULL
  860. if (unlikely(NULL == b_p || 0 == ((b_p->bitmap[ary_id] >> bmp_id) & 1)))
  861. return;
  862. b_p->count--; // 更新了ida_count
  863. b_p->bitmap[ary_id] ^= (1ull << bmp_id);
  864. __idr_erase_full(&ida_p->idr, idr_id, stk, (b_p->count > 0 ? 1 : 0));
  865. if (0 == b_p->count)
  866. {
  867. __ida_bitmap_free(b_p);
  868. if (stk[0]) // stk[0] 有可能在 __idr_erase_full 里面已经kfree了
  869. stk[0]->ary[idr_id & IDR_MASK] = NULL; // 记得设置为空
  870. }
  871. }
  872. /**
  873. * @brief 释放所有空间(包括: idr + ida_bitmap + free_list)
  874. * @param ida_p
  875. */
  876. void ida_destroy(struct ida *ida_p)
  877. {
  878. if (unlikely(ida_p == NULL))
  879. {
  880. BUG_ON(1);
  881. return;
  882. }
  883. __idr_destroy_with_free(&ida_p->idr);
  884. ida_p->idr.top = NULL;
  885. __ida_bitmap_free(ida_p->free_list);
  886. ida_p->free_list = NULL;
  887. }
  888. /**
  889. * @brief 判断一个ida是否为空
  890. *
  891. * @param ida_p
  892. * @return true
  893. * @return false
  894. */
  895. bool ida_empty(struct ida *ida_p)
  896. {
  897. if (ida_p == NULL || ida_p->idr.top == NULL || !ida_p->idr.top->bitmap)
  898. return true;
  899. return false;
  900. }