xfs_qm.c 56 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320
  1. /*
  2. * Copyright (c) 2000-2005 Silicon Graphics, Inc.
  3. * All Rights Reserved.
  4. *
  5. * This program is free software; you can redistribute it and/or
  6. * modify it under the terms of the GNU General Public License as
  7. * published by the Free Software Foundation.
  8. *
  9. * This program is distributed in the hope that it would be useful,
  10. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12. * GNU General Public License for more details.
  13. *
  14. * You should have received a copy of the GNU General Public License
  15. * along with this program; if not, write the Free Software Foundation,
  16. * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  17. */
  18. #include "xfs.h"
  19. #include "xfs_fs.h"
  20. #include "xfs_bit.h"
  21. #include "xfs_log.h"
  22. #include "xfs_inum.h"
  23. #include "xfs_trans.h"
  24. #include "xfs_sb.h"
  25. #include "xfs_ag.h"
  26. #include "xfs_alloc.h"
  27. #include "xfs_quota.h"
  28. #include "xfs_mount.h"
  29. #include "xfs_bmap_btree.h"
  30. #include "xfs_ialloc_btree.h"
  31. #include "xfs_dinode.h"
  32. #include "xfs_inode.h"
  33. #include "xfs_ialloc.h"
  34. #include "xfs_itable.h"
  35. #include "xfs_rtalloc.h"
  36. #include "xfs_error.h"
  37. #include "xfs_bmap.h"
  38. #include "xfs_attr.h"
  39. #include "xfs_buf_item.h"
  40. #include "xfs_trans_space.h"
  41. #include "xfs_utils.h"
  42. #include "xfs_qm.h"
  43. #include "xfs_trace.h"
  44. /*
  45. * The global quota manager. There is only one of these for the entire
  46. * system, _not_ one per file system. XQM keeps track of the overall
  47. * quota functionality, including maintaining the freelist and hash
  48. * tables of dquots.
  49. */
  50. struct mutex xfs_Gqm_lock;
  51. struct xfs_qm *xfs_Gqm;
  52. uint ndquot;
  53. kmem_zone_t *qm_dqzone;
  54. kmem_zone_t *qm_dqtrxzone;
  55. STATIC void xfs_qm_list_init(xfs_dqlist_t *, char *, int);
  56. STATIC void xfs_qm_list_destroy(xfs_dqlist_t *);
  57. STATIC int xfs_qm_init_quotainos(xfs_mount_t *);
  58. STATIC int xfs_qm_init_quotainfo(xfs_mount_t *);
  59. STATIC int xfs_qm_shake(struct shrinker *, struct shrink_control *);
  60. static struct shrinker xfs_qm_shaker = {
  61. .shrink = xfs_qm_shake,
  62. .seeks = DEFAULT_SEEKS,
  63. };
  64. /*
  65. * Initialize the XQM structure.
  66. * Note that there is not one quota manager per file system.
  67. */
  68. STATIC struct xfs_qm *
  69. xfs_Gqm_init(void)
  70. {
  71. xfs_dqhash_t *udqhash, *gdqhash;
  72. xfs_qm_t *xqm;
  73. size_t hsize;
  74. uint i;
  75. /*
  76. * Initialize the dquot hash tables.
  77. */
  78. udqhash = kmem_zalloc_greedy(&hsize,
  79. XFS_QM_HASHSIZE_LOW * sizeof(xfs_dqhash_t),
  80. XFS_QM_HASHSIZE_HIGH * sizeof(xfs_dqhash_t));
  81. if (!udqhash)
  82. goto out;
  83. gdqhash = kmem_zalloc_large(hsize);
  84. if (!gdqhash)
  85. goto out_free_udqhash;
  86. hsize /= sizeof(xfs_dqhash_t);
  87. ndquot = hsize << 8;
  88. xqm = kmem_zalloc(sizeof(xfs_qm_t), KM_SLEEP);
  89. xqm->qm_dqhashmask = hsize - 1;
  90. xqm->qm_usr_dqhtable = udqhash;
  91. xqm->qm_grp_dqhtable = gdqhash;
  92. ASSERT(xqm->qm_usr_dqhtable != NULL);
  93. ASSERT(xqm->qm_grp_dqhtable != NULL);
  94. for (i = 0; i < hsize; i++) {
  95. xfs_qm_list_init(&(xqm->qm_usr_dqhtable[i]), "uxdqh", i);
  96. xfs_qm_list_init(&(xqm->qm_grp_dqhtable[i]), "gxdqh", i);
  97. }
  98. /*
  99. * Freelist of all dquots of all file systems
  100. */
  101. INIT_LIST_HEAD(&xqm->qm_dqfrlist);
  102. xqm->qm_dqfrlist_cnt = 0;
  103. mutex_init(&xqm->qm_dqfrlist_lock);
  104. /*
  105. * dquot zone. we register our own low-memory callback.
  106. */
  107. if (!qm_dqzone) {
  108. xqm->qm_dqzone = kmem_zone_init(sizeof(xfs_dquot_t),
  109. "xfs_dquots");
  110. qm_dqzone = xqm->qm_dqzone;
  111. } else
  112. xqm->qm_dqzone = qm_dqzone;
  113. register_shrinker(&xfs_qm_shaker);
  114. /*
  115. * The t_dqinfo portion of transactions.
  116. */
  117. if (!qm_dqtrxzone) {
  118. xqm->qm_dqtrxzone = kmem_zone_init(sizeof(xfs_dquot_acct_t),
  119. "xfs_dqtrx");
  120. qm_dqtrxzone = xqm->qm_dqtrxzone;
  121. } else
  122. xqm->qm_dqtrxzone = qm_dqtrxzone;
  123. atomic_set(&xqm->qm_totaldquots, 0);
  124. xqm->qm_dqfree_ratio = XFS_QM_DQFREE_RATIO;
  125. xqm->qm_nrefs = 0;
  126. return xqm;
  127. out_free_udqhash:
  128. kmem_free_large(udqhash);
  129. out:
  130. return NULL;
  131. }
  132. /*
  133. * Destroy the global quota manager when its reference count goes to zero.
  134. */
  135. STATIC void
  136. xfs_qm_destroy(
  137. struct xfs_qm *xqm)
  138. {
  139. struct xfs_dquot *dqp, *n;
  140. int hsize, i;
  141. ASSERT(xqm != NULL);
  142. ASSERT(xqm->qm_nrefs == 0);
  143. unregister_shrinker(&xfs_qm_shaker);
  144. hsize = xqm->qm_dqhashmask + 1;
  145. for (i = 0; i < hsize; i++) {
  146. xfs_qm_list_destroy(&(xqm->qm_usr_dqhtable[i]));
  147. xfs_qm_list_destroy(&(xqm->qm_grp_dqhtable[i]));
  148. }
  149. kmem_free_large(xqm->qm_usr_dqhtable);
  150. kmem_free_large(xqm->qm_grp_dqhtable);
  151. xqm->qm_usr_dqhtable = NULL;
  152. xqm->qm_grp_dqhtable = NULL;
  153. xqm->qm_dqhashmask = 0;
  154. /* frlist cleanup */
  155. mutex_lock(&xqm->qm_dqfrlist_lock);
  156. list_for_each_entry_safe(dqp, n, &xqm->qm_dqfrlist, q_freelist) {
  157. xfs_dqlock(dqp);
  158. list_del_init(&dqp->q_freelist);
  159. xfs_Gqm->qm_dqfrlist_cnt--;
  160. xfs_dqunlock(dqp);
  161. xfs_qm_dqdestroy(dqp);
  162. }
  163. mutex_unlock(&xqm->qm_dqfrlist_lock);
  164. mutex_destroy(&xqm->qm_dqfrlist_lock);
  165. kmem_free(xqm);
  166. }
  167. /*
  168. * Called at mount time to let XQM know that another file system is
  169. * starting quotas. This isn't crucial information as the individual mount
  170. * structures are pretty independent, but it helps the XQM keep a
  171. * global view of what's going on.
  172. */
  173. /* ARGSUSED */
  174. STATIC int
  175. xfs_qm_hold_quotafs_ref(
  176. struct xfs_mount *mp)
  177. {
  178. /*
  179. * Need to lock the xfs_Gqm structure for things like this. For example,
  180. * the structure could disappear between the entry to this routine and
  181. * a HOLD operation if not locked.
  182. */
  183. mutex_lock(&xfs_Gqm_lock);
  184. if (!xfs_Gqm) {
  185. xfs_Gqm = xfs_Gqm_init();
  186. if (!xfs_Gqm) {
  187. mutex_unlock(&xfs_Gqm_lock);
  188. return ENOMEM;
  189. }
  190. }
  191. /*
  192. * We can keep a list of all filesystems with quotas mounted for
  193. * debugging and statistical purposes, but ...
  194. * Just take a reference and get out.
  195. */
  196. xfs_Gqm->qm_nrefs++;
  197. mutex_unlock(&xfs_Gqm_lock);
  198. return 0;
  199. }
  200. /*
  201. * Release the reference that a filesystem took at mount time,
  202. * so that we know when we need to destroy the entire quota manager.
  203. */
  204. /* ARGSUSED */
  205. STATIC void
  206. xfs_qm_rele_quotafs_ref(
  207. struct xfs_mount *mp)
  208. {
  209. xfs_dquot_t *dqp, *n;
  210. ASSERT(xfs_Gqm);
  211. ASSERT(xfs_Gqm->qm_nrefs > 0);
  212. /*
  213. * Go thru the freelist and destroy all inactive dquots.
  214. */
  215. mutex_lock(&xfs_Gqm->qm_dqfrlist_lock);
  216. list_for_each_entry_safe(dqp, n, &xfs_Gqm->qm_dqfrlist, q_freelist) {
  217. xfs_dqlock(dqp);
  218. if (dqp->dq_flags & XFS_DQ_INACTIVE) {
  219. ASSERT(dqp->q_mount == NULL);
  220. ASSERT(! XFS_DQ_IS_DIRTY(dqp));
  221. ASSERT(list_empty(&dqp->q_hashlist));
  222. ASSERT(list_empty(&dqp->q_mplist));
  223. list_del_init(&dqp->q_freelist);
  224. xfs_Gqm->qm_dqfrlist_cnt--;
  225. xfs_dqunlock(dqp);
  226. xfs_qm_dqdestroy(dqp);
  227. } else {
  228. xfs_dqunlock(dqp);
  229. }
  230. }
  231. mutex_unlock(&xfs_Gqm->qm_dqfrlist_lock);
  232. /*
  233. * Destroy the entire XQM. If somebody mounts with quotaon, this'll
  234. * be restarted.
  235. */
  236. mutex_lock(&xfs_Gqm_lock);
  237. if (--xfs_Gqm->qm_nrefs == 0) {
  238. xfs_qm_destroy(xfs_Gqm);
  239. xfs_Gqm = NULL;
  240. }
  241. mutex_unlock(&xfs_Gqm_lock);
  242. }
  243. /*
  244. * Just destroy the quotainfo structure.
  245. */
  246. void
  247. xfs_qm_unmount(
  248. struct xfs_mount *mp)
  249. {
  250. if (mp->m_quotainfo) {
  251. xfs_qm_dqpurge_all(mp, XFS_QMOPT_QUOTALL);
  252. xfs_qm_destroy_quotainfo(mp);
  253. }
  254. }
  255. /*
  256. * This is called from xfs_mountfs to start quotas and initialize all
  257. * necessary data structures like quotainfo. This is also responsible for
  258. * running a quotacheck as necessary. We are guaranteed that the superblock
  259. * is consistently read in at this point.
  260. *
  261. * If we fail here, the mount will continue with quota turned off. We don't
  262. * need to inidicate success or failure at all.
  263. */
  264. void
  265. xfs_qm_mount_quotas(
  266. xfs_mount_t *mp)
  267. {
  268. int error = 0;
  269. uint sbf;
  270. /*
  271. * If quotas on realtime volumes is not supported, we disable
  272. * quotas immediately.
  273. */
  274. if (mp->m_sb.sb_rextents) {
  275. xfs_notice(mp, "Cannot turn on quotas for realtime filesystem");
  276. mp->m_qflags = 0;
  277. goto write_changes;
  278. }
  279. ASSERT(XFS_IS_QUOTA_RUNNING(mp));
  280. /*
  281. * Allocate the quotainfo structure inside the mount struct, and
  282. * create quotainode(s), and change/rev superblock if necessary.
  283. */
  284. error = xfs_qm_init_quotainfo(mp);
  285. if (error) {
  286. /*
  287. * We must turn off quotas.
  288. */
  289. ASSERT(mp->m_quotainfo == NULL);
  290. mp->m_qflags = 0;
  291. goto write_changes;
  292. }
  293. /*
  294. * If any of the quotas are not consistent, do a quotacheck.
  295. */
  296. if (XFS_QM_NEED_QUOTACHECK(mp)) {
  297. error = xfs_qm_quotacheck(mp);
  298. if (error) {
  299. /* Quotacheck failed and disabled quotas. */
  300. return;
  301. }
  302. }
  303. /*
  304. * If one type of quotas is off, then it will lose its
  305. * quotachecked status, since we won't be doing accounting for
  306. * that type anymore.
  307. */
  308. if (!XFS_IS_UQUOTA_ON(mp))
  309. mp->m_qflags &= ~XFS_UQUOTA_CHKD;
  310. if (!(XFS_IS_GQUOTA_ON(mp) || XFS_IS_PQUOTA_ON(mp)))
  311. mp->m_qflags &= ~XFS_OQUOTA_CHKD;
  312. write_changes:
  313. /*
  314. * We actually don't have to acquire the m_sb_lock at all.
  315. * This can only be called from mount, and that's single threaded. XXX
  316. */
  317. spin_lock(&mp->m_sb_lock);
  318. sbf = mp->m_sb.sb_qflags;
  319. mp->m_sb.sb_qflags = mp->m_qflags & XFS_MOUNT_QUOTA_ALL;
  320. spin_unlock(&mp->m_sb_lock);
  321. if (sbf != (mp->m_qflags & XFS_MOUNT_QUOTA_ALL)) {
  322. if (xfs_qm_write_sb_changes(mp, XFS_SB_QFLAGS)) {
  323. /*
  324. * We could only have been turning quotas off.
  325. * We aren't in very good shape actually because
  326. * the incore structures are convinced that quotas are
  327. * off, but the on disk superblock doesn't know that !
  328. */
  329. ASSERT(!(XFS_IS_QUOTA_RUNNING(mp)));
  330. xfs_alert(mp, "%s: Superblock update failed!",
  331. __func__);
  332. }
  333. }
  334. if (error) {
  335. xfs_warn(mp, "Failed to initialize disk quotas.");
  336. return;
  337. }
  338. }
  339. /*
  340. * Called from the vfsops layer.
  341. */
  342. void
  343. xfs_qm_unmount_quotas(
  344. xfs_mount_t *mp)
  345. {
  346. /*
  347. * Release the dquots that root inode, et al might be holding,
  348. * before we flush quotas and blow away the quotainfo structure.
  349. */
  350. ASSERT(mp->m_rootip);
  351. xfs_qm_dqdetach(mp->m_rootip);
  352. if (mp->m_rbmip)
  353. xfs_qm_dqdetach(mp->m_rbmip);
  354. if (mp->m_rsumip)
  355. xfs_qm_dqdetach(mp->m_rsumip);
  356. /*
  357. * Release the quota inodes.
  358. */
  359. if (mp->m_quotainfo) {
  360. if (mp->m_quotainfo->qi_uquotaip) {
  361. IRELE(mp->m_quotainfo->qi_uquotaip);
  362. mp->m_quotainfo->qi_uquotaip = NULL;
  363. }
  364. if (mp->m_quotainfo->qi_gquotaip) {
  365. IRELE(mp->m_quotainfo->qi_gquotaip);
  366. mp->m_quotainfo->qi_gquotaip = NULL;
  367. }
  368. }
  369. }
  370. /*
  371. * Flush all dquots of the given file system to disk. The dquots are
  372. * _not_ purged from memory here, just their data written to disk.
  373. */
  374. STATIC int
  375. xfs_qm_dqflush_all(
  376. struct xfs_mount *mp)
  377. {
  378. struct xfs_quotainfo *q = mp->m_quotainfo;
  379. int recl;
  380. struct xfs_dquot *dqp;
  381. int error;
  382. if (!q)
  383. return 0;
  384. again:
  385. mutex_lock(&q->qi_dqlist_lock);
  386. list_for_each_entry(dqp, &q->qi_dqlist, q_mplist) {
  387. xfs_dqlock(dqp);
  388. if (! XFS_DQ_IS_DIRTY(dqp)) {
  389. xfs_dqunlock(dqp);
  390. continue;
  391. }
  392. /* XXX a sentinel would be better */
  393. recl = q->qi_dqreclaims;
  394. if (!xfs_dqflock_nowait(dqp)) {
  395. /*
  396. * If we can't grab the flush lock then check
  397. * to see if the dquot has been flushed delayed
  398. * write. If so, grab its buffer and send it
  399. * out immediately. We'll be able to acquire
  400. * the flush lock when the I/O completes.
  401. */
  402. xfs_dqflock_pushbuf_wait(dqp);
  403. }
  404. /*
  405. * Let go of the mplist lock. We don't want to hold it
  406. * across a disk write.
  407. */
  408. mutex_unlock(&q->qi_dqlist_lock);
  409. error = xfs_qm_dqflush(dqp, 0);
  410. xfs_dqunlock(dqp);
  411. if (error)
  412. return error;
  413. mutex_lock(&q->qi_dqlist_lock);
  414. if (recl != q->qi_dqreclaims) {
  415. mutex_unlock(&q->qi_dqlist_lock);
  416. /* XXX restart limit */
  417. goto again;
  418. }
  419. }
  420. mutex_unlock(&q->qi_dqlist_lock);
  421. /* return ! busy */
  422. return 0;
  423. }
  424. /*
  425. * Release the group dquot pointers the user dquots may be
  426. * carrying around as a hint. mplist is locked on entry and exit.
  427. */
  428. STATIC void
  429. xfs_qm_detach_gdquots(
  430. struct xfs_mount *mp)
  431. {
  432. struct xfs_quotainfo *q = mp->m_quotainfo;
  433. struct xfs_dquot *dqp, *gdqp;
  434. int nrecl;
  435. again:
  436. ASSERT(mutex_is_locked(&q->qi_dqlist_lock));
  437. list_for_each_entry(dqp, &q->qi_dqlist, q_mplist) {
  438. xfs_dqlock(dqp);
  439. if ((gdqp = dqp->q_gdquot)) {
  440. xfs_dqlock(gdqp);
  441. dqp->q_gdquot = NULL;
  442. }
  443. xfs_dqunlock(dqp);
  444. if (gdqp) {
  445. /*
  446. * Can't hold the mplist lock across a dqput.
  447. * XXXmust convert to marker based iterations here.
  448. */
  449. nrecl = q->qi_dqreclaims;
  450. mutex_unlock(&q->qi_dqlist_lock);
  451. xfs_qm_dqput(gdqp);
  452. mutex_lock(&q->qi_dqlist_lock);
  453. if (nrecl != q->qi_dqreclaims)
  454. goto again;
  455. }
  456. }
  457. }
  458. /*
  459. * Go through all the incore dquots of this file system and take them
  460. * off the mplist and hashlist, if the dquot type matches the dqtype
  461. * parameter. This is used when turning off quota accounting for
  462. * users and/or groups, as well as when the filesystem is unmounting.
  463. */
  464. STATIC int
  465. xfs_qm_dqpurge_int(
  466. struct xfs_mount *mp,
  467. uint flags)
  468. {
  469. struct xfs_quotainfo *q = mp->m_quotainfo;
  470. struct xfs_dquot *dqp, *n;
  471. uint dqtype;
  472. int nrecl;
  473. int nmisses;
  474. if (!q)
  475. return 0;
  476. dqtype = (flags & XFS_QMOPT_UQUOTA) ? XFS_DQ_USER : 0;
  477. dqtype |= (flags & XFS_QMOPT_PQUOTA) ? XFS_DQ_PROJ : 0;
  478. dqtype |= (flags & XFS_QMOPT_GQUOTA) ? XFS_DQ_GROUP : 0;
  479. mutex_lock(&q->qi_dqlist_lock);
  480. /*
  481. * In the first pass through all incore dquots of this filesystem,
  482. * we release the group dquot pointers the user dquots may be
  483. * carrying around as a hint. We need to do this irrespective of
  484. * what's being turned off.
  485. */
  486. xfs_qm_detach_gdquots(mp);
  487. again:
  488. nmisses = 0;
  489. ASSERT(mutex_is_locked(&q->qi_dqlist_lock));
  490. /*
  491. * Try to get rid of all of the unwanted dquots. The idea is to
  492. * get them off mplist and hashlist, but leave them on freelist.
  493. */
  494. list_for_each_entry_safe(dqp, n, &q->qi_dqlist, q_mplist) {
  495. /*
  496. * It's OK to look at the type without taking dqlock here.
  497. * We're holding the mplist lock here, and that's needed for
  498. * a dqreclaim.
  499. */
  500. if ((dqp->dq_flags & dqtype) == 0)
  501. continue;
  502. if (!mutex_trylock(&dqp->q_hash->qh_lock)) {
  503. nrecl = q->qi_dqreclaims;
  504. mutex_unlock(&q->qi_dqlist_lock);
  505. mutex_lock(&dqp->q_hash->qh_lock);
  506. mutex_lock(&q->qi_dqlist_lock);
  507. /*
  508. * XXXTheoretically, we can get into a very long
  509. * ping pong game here.
  510. * No one can be adding dquots to the mplist at
  511. * this point, but somebody might be taking things off.
  512. */
  513. if (nrecl != q->qi_dqreclaims) {
  514. mutex_unlock(&dqp->q_hash->qh_lock);
  515. goto again;
  516. }
  517. }
  518. /*
  519. * Take the dquot off the mplist and hashlist. It may remain on
  520. * freelist in INACTIVE state.
  521. */
  522. nmisses += xfs_qm_dqpurge(dqp);
  523. }
  524. mutex_unlock(&q->qi_dqlist_lock);
  525. return nmisses;
  526. }
  527. int
  528. xfs_qm_dqpurge_all(
  529. xfs_mount_t *mp,
  530. uint flags)
  531. {
  532. int ndquots;
  533. /*
  534. * Purge the dquot cache.
  535. * None of the dquots should really be busy at this point.
  536. */
  537. if (mp->m_quotainfo) {
  538. while ((ndquots = xfs_qm_dqpurge_int(mp, flags))) {
  539. delay(ndquots * 10);
  540. }
  541. }
  542. return 0;
  543. }
  544. STATIC int
  545. xfs_qm_dqattach_one(
  546. xfs_inode_t *ip,
  547. xfs_dqid_t id,
  548. uint type,
  549. uint doalloc,
  550. xfs_dquot_t *udqhint, /* hint */
  551. xfs_dquot_t **IO_idqpp)
  552. {
  553. xfs_dquot_t *dqp;
  554. int error;
  555. ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
  556. error = 0;
  557. /*
  558. * See if we already have it in the inode itself. IO_idqpp is
  559. * &i_udquot or &i_gdquot. This made the code look weird, but
  560. * made the logic a lot simpler.
  561. */
  562. dqp = *IO_idqpp;
  563. if (dqp) {
  564. trace_xfs_dqattach_found(dqp);
  565. return 0;
  566. }
  567. /*
  568. * udqhint is the i_udquot field in inode, and is non-NULL only
  569. * when the type arg is group/project. Its purpose is to save a
  570. * lookup by dqid (xfs_qm_dqget) by caching a group dquot inside
  571. * the user dquot.
  572. */
  573. if (udqhint) {
  574. ASSERT(type == XFS_DQ_GROUP || type == XFS_DQ_PROJ);
  575. xfs_dqlock(udqhint);
  576. /*
  577. * No need to take dqlock to look at the id.
  578. *
  579. * The ID can't change until it gets reclaimed, and it won't
  580. * be reclaimed as long as we have a ref from inode and we
  581. * hold the ilock.
  582. */
  583. dqp = udqhint->q_gdquot;
  584. if (dqp && be32_to_cpu(dqp->q_core.d_id) == id) {
  585. xfs_dqlock(dqp);
  586. XFS_DQHOLD(dqp);
  587. ASSERT(*IO_idqpp == NULL);
  588. *IO_idqpp = dqp;
  589. xfs_dqunlock(dqp);
  590. xfs_dqunlock(udqhint);
  591. return 0;
  592. }
  593. /*
  594. * We can't hold a dquot lock when we call the dqget code.
  595. * We'll deadlock in no time, because of (not conforming to)
  596. * lock ordering - the inodelock comes before any dquot lock,
  597. * and we may drop and reacquire the ilock in xfs_qm_dqget().
  598. */
  599. xfs_dqunlock(udqhint);
  600. }
  601. /*
  602. * Find the dquot from somewhere. This bumps the
  603. * reference count of dquot and returns it locked.
  604. * This can return ENOENT if dquot didn't exist on
  605. * disk and we didn't ask it to allocate;
  606. * ESRCH if quotas got turned off suddenly.
  607. */
  608. error = xfs_qm_dqget(ip->i_mount, ip, id, type,
  609. doalloc | XFS_QMOPT_DOWARN, &dqp);
  610. if (error)
  611. return error;
  612. trace_xfs_dqattach_get(dqp);
  613. /*
  614. * dqget may have dropped and re-acquired the ilock, but it guarantees
  615. * that the dquot returned is the one that should go in the inode.
  616. */
  617. *IO_idqpp = dqp;
  618. xfs_dqunlock(dqp);
  619. return 0;
  620. }
  621. /*
  622. * Given a udquot and gdquot, attach a ptr to the group dquot in the
  623. * udquot as a hint for future lookups. The idea sounds simple, but the
  624. * execution isn't, because the udquot might have a group dquot attached
  625. * already and getting rid of that gets us into lock ordering constraints.
  626. * The process is complicated more by the fact that the dquots may or may not
  627. * be locked on entry.
  628. */
  629. STATIC void
  630. xfs_qm_dqattach_grouphint(
  631. xfs_dquot_t *udq,
  632. xfs_dquot_t *gdq)
  633. {
  634. xfs_dquot_t *tmp;
  635. xfs_dqlock(udq);
  636. if ((tmp = udq->q_gdquot)) {
  637. if (tmp == gdq) {
  638. xfs_dqunlock(udq);
  639. return;
  640. }
  641. udq->q_gdquot = NULL;
  642. /*
  643. * We can't keep any dqlocks when calling dqrele,
  644. * because the freelist lock comes before dqlocks.
  645. */
  646. xfs_dqunlock(udq);
  647. /*
  648. * we took a hard reference once upon a time in dqget,
  649. * so give it back when the udquot no longer points at it
  650. * dqput() does the unlocking of the dquot.
  651. */
  652. xfs_qm_dqrele(tmp);
  653. xfs_dqlock(udq);
  654. xfs_dqlock(gdq);
  655. } else {
  656. ASSERT(XFS_DQ_IS_LOCKED(udq));
  657. xfs_dqlock(gdq);
  658. }
  659. ASSERT(XFS_DQ_IS_LOCKED(udq));
  660. ASSERT(XFS_DQ_IS_LOCKED(gdq));
  661. /*
  662. * Somebody could have attached a gdquot here,
  663. * when we dropped the uqlock. If so, just do nothing.
  664. */
  665. if (udq->q_gdquot == NULL) {
  666. XFS_DQHOLD(gdq);
  667. udq->q_gdquot = gdq;
  668. }
  669. xfs_dqunlock(gdq);
  670. xfs_dqunlock(udq);
  671. }
  672. /*
  673. * Given a locked inode, attach dquot(s) to it, taking U/G/P-QUOTAON
  674. * into account.
  675. * If XFS_QMOPT_DQALLOC, the dquot(s) will be allocated if needed.
  676. * Inode may get unlocked and relocked in here, and the caller must deal with
  677. * the consequences.
  678. */
  679. int
  680. xfs_qm_dqattach_locked(
  681. xfs_inode_t *ip,
  682. uint flags)
  683. {
  684. xfs_mount_t *mp = ip->i_mount;
  685. uint nquotas = 0;
  686. int error = 0;
  687. if (!XFS_IS_QUOTA_RUNNING(mp) ||
  688. !XFS_IS_QUOTA_ON(mp) ||
  689. !XFS_NOT_DQATTACHED(mp, ip) ||
  690. ip->i_ino == mp->m_sb.sb_uquotino ||
  691. ip->i_ino == mp->m_sb.sb_gquotino)
  692. return 0;
  693. ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
  694. if (XFS_IS_UQUOTA_ON(mp)) {
  695. error = xfs_qm_dqattach_one(ip, ip->i_d.di_uid, XFS_DQ_USER,
  696. flags & XFS_QMOPT_DQALLOC,
  697. NULL, &ip->i_udquot);
  698. if (error)
  699. goto done;
  700. nquotas++;
  701. }
  702. ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
  703. if (XFS_IS_OQUOTA_ON(mp)) {
  704. error = XFS_IS_GQUOTA_ON(mp) ?
  705. xfs_qm_dqattach_one(ip, ip->i_d.di_gid, XFS_DQ_GROUP,
  706. flags & XFS_QMOPT_DQALLOC,
  707. ip->i_udquot, &ip->i_gdquot) :
  708. xfs_qm_dqattach_one(ip, xfs_get_projid(ip), XFS_DQ_PROJ,
  709. flags & XFS_QMOPT_DQALLOC,
  710. ip->i_udquot, &ip->i_gdquot);
  711. /*
  712. * Don't worry about the udquot that we may have
  713. * attached above. It'll get detached, if not already.
  714. */
  715. if (error)
  716. goto done;
  717. nquotas++;
  718. }
  719. /*
  720. * Attach this group quota to the user quota as a hint.
  721. * This WON'T, in general, result in a thrash.
  722. */
  723. if (nquotas == 2) {
  724. ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
  725. ASSERT(ip->i_udquot);
  726. ASSERT(ip->i_gdquot);
  727. /*
  728. * We may or may not have the i_udquot locked at this point,
  729. * but this check is OK since we don't depend on the i_gdquot to
  730. * be accurate 100% all the time. It is just a hint, and this
  731. * will succeed in general.
  732. */
  733. if (ip->i_udquot->q_gdquot == ip->i_gdquot)
  734. goto done;
  735. /*
  736. * Attach i_gdquot to the gdquot hint inside the i_udquot.
  737. */
  738. xfs_qm_dqattach_grouphint(ip->i_udquot, ip->i_gdquot);
  739. }
  740. done:
  741. #ifdef DEBUG
  742. if (!error) {
  743. if (XFS_IS_UQUOTA_ON(mp))
  744. ASSERT(ip->i_udquot);
  745. if (XFS_IS_OQUOTA_ON(mp))
  746. ASSERT(ip->i_gdquot);
  747. }
  748. ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
  749. #endif
  750. return error;
  751. }
  752. int
  753. xfs_qm_dqattach(
  754. struct xfs_inode *ip,
  755. uint flags)
  756. {
  757. int error;
  758. xfs_ilock(ip, XFS_ILOCK_EXCL);
  759. error = xfs_qm_dqattach_locked(ip, flags);
  760. xfs_iunlock(ip, XFS_ILOCK_EXCL);
  761. return error;
  762. }
  763. /*
  764. * Release dquots (and their references) if any.
  765. * The inode should be locked EXCL except when this's called by
  766. * xfs_ireclaim.
  767. */
  768. void
  769. xfs_qm_dqdetach(
  770. xfs_inode_t *ip)
  771. {
  772. if (!(ip->i_udquot || ip->i_gdquot))
  773. return;
  774. trace_xfs_dquot_dqdetach(ip);
  775. ASSERT(ip->i_ino != ip->i_mount->m_sb.sb_uquotino);
  776. ASSERT(ip->i_ino != ip->i_mount->m_sb.sb_gquotino);
  777. if (ip->i_udquot) {
  778. xfs_qm_dqrele(ip->i_udquot);
  779. ip->i_udquot = NULL;
  780. }
  781. if (ip->i_gdquot) {
  782. xfs_qm_dqrele(ip->i_gdquot);
  783. ip->i_gdquot = NULL;
  784. }
  785. }
  786. /*
  787. * The hash chains and the mplist use the same xfs_dqhash structure as
  788. * their list head, but we can take the mplist qh_lock and one of the
  789. * hash qh_locks at the same time without any problem as they aren't
  790. * related.
  791. */
  792. static struct lock_class_key xfs_quota_mplist_class;
  793. /*
  794. * This initializes all the quota information that's kept in the
  795. * mount structure
  796. */
  797. STATIC int
  798. xfs_qm_init_quotainfo(
  799. xfs_mount_t *mp)
  800. {
  801. xfs_quotainfo_t *qinf;
  802. int error;
  803. xfs_dquot_t *dqp;
  804. ASSERT(XFS_IS_QUOTA_RUNNING(mp));
  805. /*
  806. * Tell XQM that we exist as soon as possible.
  807. */
  808. if ((error = xfs_qm_hold_quotafs_ref(mp))) {
  809. return error;
  810. }
  811. qinf = mp->m_quotainfo = kmem_zalloc(sizeof(xfs_quotainfo_t), KM_SLEEP);
  812. /*
  813. * See if quotainodes are setup, and if not, allocate them,
  814. * and change the superblock accordingly.
  815. */
  816. if ((error = xfs_qm_init_quotainos(mp))) {
  817. kmem_free(qinf);
  818. mp->m_quotainfo = NULL;
  819. return error;
  820. }
  821. INIT_LIST_HEAD(&qinf->qi_dqlist);
  822. mutex_init(&qinf->qi_dqlist_lock);
  823. lockdep_set_class(&qinf->qi_dqlist_lock, &xfs_quota_mplist_class);
  824. qinf->qi_dqreclaims = 0;
  825. /* mutex used to serialize quotaoffs */
  826. mutex_init(&qinf->qi_quotaofflock);
  827. /* Precalc some constants */
  828. qinf->qi_dqchunklen = XFS_FSB_TO_BB(mp, XFS_DQUOT_CLUSTER_SIZE_FSB);
  829. ASSERT(qinf->qi_dqchunklen);
  830. qinf->qi_dqperchunk = BBTOB(qinf->qi_dqchunklen);
  831. do_div(qinf->qi_dqperchunk, sizeof(xfs_dqblk_t));
  832. mp->m_qflags |= (mp->m_sb.sb_qflags & XFS_ALL_QUOTA_CHKD);
  833. /*
  834. * We try to get the limits from the superuser's limits fields.
  835. * This is quite hacky, but it is standard quota practice.
  836. * We look at the USR dquot with id == 0 first, but if user quotas
  837. * are not enabled we goto the GRP dquot with id == 0.
  838. * We don't really care to keep separate default limits for user
  839. * and group quotas, at least not at this point.
  840. */
  841. error = xfs_qm_dqget(mp, NULL, (xfs_dqid_t)0,
  842. XFS_IS_UQUOTA_RUNNING(mp) ? XFS_DQ_USER :
  843. (XFS_IS_GQUOTA_RUNNING(mp) ? XFS_DQ_GROUP :
  844. XFS_DQ_PROJ),
  845. XFS_QMOPT_DQSUSER|XFS_QMOPT_DOWARN,
  846. &dqp);
  847. if (! error) {
  848. xfs_disk_dquot_t *ddqp = &dqp->q_core;
  849. /*
  850. * The warnings and timers set the grace period given to
  851. * a user or group before he or she can not perform any
  852. * more writing. If it is zero, a default is used.
  853. */
  854. qinf->qi_btimelimit = ddqp->d_btimer ?
  855. be32_to_cpu(ddqp->d_btimer) : XFS_QM_BTIMELIMIT;
  856. qinf->qi_itimelimit = ddqp->d_itimer ?
  857. be32_to_cpu(ddqp->d_itimer) : XFS_QM_ITIMELIMIT;
  858. qinf->qi_rtbtimelimit = ddqp->d_rtbtimer ?
  859. be32_to_cpu(ddqp->d_rtbtimer) : XFS_QM_RTBTIMELIMIT;
  860. qinf->qi_bwarnlimit = ddqp->d_bwarns ?
  861. be16_to_cpu(ddqp->d_bwarns) : XFS_QM_BWARNLIMIT;
  862. qinf->qi_iwarnlimit = ddqp->d_iwarns ?
  863. be16_to_cpu(ddqp->d_iwarns) : XFS_QM_IWARNLIMIT;
  864. qinf->qi_rtbwarnlimit = ddqp->d_rtbwarns ?
  865. be16_to_cpu(ddqp->d_rtbwarns) : XFS_QM_RTBWARNLIMIT;
  866. qinf->qi_bhardlimit = be64_to_cpu(ddqp->d_blk_hardlimit);
  867. qinf->qi_bsoftlimit = be64_to_cpu(ddqp->d_blk_softlimit);
  868. qinf->qi_ihardlimit = be64_to_cpu(ddqp->d_ino_hardlimit);
  869. qinf->qi_isoftlimit = be64_to_cpu(ddqp->d_ino_softlimit);
  870. qinf->qi_rtbhardlimit = be64_to_cpu(ddqp->d_rtb_hardlimit);
  871. qinf->qi_rtbsoftlimit = be64_to_cpu(ddqp->d_rtb_softlimit);
  872. /*
  873. * We sent the XFS_QMOPT_DQSUSER flag to dqget because
  874. * we don't want this dquot cached. We haven't done a
  875. * quotacheck yet, and quotacheck doesn't like incore dquots.
  876. */
  877. xfs_qm_dqdestroy(dqp);
  878. } else {
  879. qinf->qi_btimelimit = XFS_QM_BTIMELIMIT;
  880. qinf->qi_itimelimit = XFS_QM_ITIMELIMIT;
  881. qinf->qi_rtbtimelimit = XFS_QM_RTBTIMELIMIT;
  882. qinf->qi_bwarnlimit = XFS_QM_BWARNLIMIT;
  883. qinf->qi_iwarnlimit = XFS_QM_IWARNLIMIT;
  884. qinf->qi_rtbwarnlimit = XFS_QM_RTBWARNLIMIT;
  885. }
  886. return 0;
  887. }
  888. /*
  889. * Gets called when unmounting a filesystem or when all quotas get
  890. * turned off.
  891. * This purges the quota inodes, destroys locks and frees itself.
  892. */
  893. void
  894. xfs_qm_destroy_quotainfo(
  895. xfs_mount_t *mp)
  896. {
  897. xfs_quotainfo_t *qi;
  898. qi = mp->m_quotainfo;
  899. ASSERT(qi != NULL);
  900. ASSERT(xfs_Gqm != NULL);
  901. /*
  902. * Release the reference that XQM kept, so that we know
  903. * when the XQM structure should be freed. We cannot assume
  904. * that xfs_Gqm is non-null after this point.
  905. */
  906. xfs_qm_rele_quotafs_ref(mp);
  907. ASSERT(list_empty(&qi->qi_dqlist));
  908. mutex_destroy(&qi->qi_dqlist_lock);
  909. if (qi->qi_uquotaip) {
  910. IRELE(qi->qi_uquotaip);
  911. qi->qi_uquotaip = NULL; /* paranoia */
  912. }
  913. if (qi->qi_gquotaip) {
  914. IRELE(qi->qi_gquotaip);
  915. qi->qi_gquotaip = NULL;
  916. }
  917. mutex_destroy(&qi->qi_quotaofflock);
  918. kmem_free(qi);
  919. mp->m_quotainfo = NULL;
  920. }
  921. /* ------------------- PRIVATE STATIC FUNCTIONS ----------------------- */
  922. /* ARGSUSED */
  923. STATIC void
  924. xfs_qm_list_init(
  925. xfs_dqlist_t *list,
  926. char *str,
  927. int n)
  928. {
  929. mutex_init(&list->qh_lock);
  930. INIT_LIST_HEAD(&list->qh_list);
  931. list->qh_version = 0;
  932. list->qh_nelems = 0;
  933. }
  934. STATIC void
  935. xfs_qm_list_destroy(
  936. xfs_dqlist_t *list)
  937. {
  938. mutex_destroy(&(list->qh_lock));
  939. }
  940. /*
  941. * Create an inode and return with a reference already taken, but unlocked
  942. * This is how we create quota inodes
  943. */
  944. STATIC int
  945. xfs_qm_qino_alloc(
  946. xfs_mount_t *mp,
  947. xfs_inode_t **ip,
  948. __int64_t sbfields,
  949. uint flags)
  950. {
  951. xfs_trans_t *tp;
  952. int error;
  953. int committed;
  954. tp = xfs_trans_alloc(mp, XFS_TRANS_QM_QINOCREATE);
  955. if ((error = xfs_trans_reserve(tp,
  956. XFS_QM_QINOCREATE_SPACE_RES(mp),
  957. XFS_CREATE_LOG_RES(mp), 0,
  958. XFS_TRANS_PERM_LOG_RES,
  959. XFS_CREATE_LOG_COUNT))) {
  960. xfs_trans_cancel(tp, 0);
  961. return error;
  962. }
  963. error = xfs_dir_ialloc(&tp, NULL, S_IFREG, 1, 0, 0, 1, ip, &committed);
  964. if (error) {
  965. xfs_trans_cancel(tp, XFS_TRANS_RELEASE_LOG_RES |
  966. XFS_TRANS_ABORT);
  967. return error;
  968. }
  969. /*
  970. * Make the changes in the superblock, and log those too.
  971. * sbfields arg may contain fields other than *QUOTINO;
  972. * VERSIONNUM for example.
  973. */
  974. spin_lock(&mp->m_sb_lock);
  975. if (flags & XFS_QMOPT_SBVERSION) {
  976. ASSERT(!xfs_sb_version_hasquota(&mp->m_sb));
  977. ASSERT((sbfields & (XFS_SB_VERSIONNUM | XFS_SB_UQUOTINO |
  978. XFS_SB_GQUOTINO | XFS_SB_QFLAGS)) ==
  979. (XFS_SB_VERSIONNUM | XFS_SB_UQUOTINO |
  980. XFS_SB_GQUOTINO | XFS_SB_QFLAGS));
  981. xfs_sb_version_addquota(&mp->m_sb);
  982. mp->m_sb.sb_uquotino = NULLFSINO;
  983. mp->m_sb.sb_gquotino = NULLFSINO;
  984. /* qflags will get updated _after_ quotacheck */
  985. mp->m_sb.sb_qflags = 0;
  986. }
  987. if (flags & XFS_QMOPT_UQUOTA)
  988. mp->m_sb.sb_uquotino = (*ip)->i_ino;
  989. else
  990. mp->m_sb.sb_gquotino = (*ip)->i_ino;
  991. spin_unlock(&mp->m_sb_lock);
  992. xfs_mod_sb(tp, sbfields);
  993. if ((error = xfs_trans_commit(tp, XFS_TRANS_RELEASE_LOG_RES))) {
  994. xfs_alert(mp, "%s failed (error %d)!", __func__, error);
  995. return error;
  996. }
  997. return 0;
  998. }
  999. STATIC void
  1000. xfs_qm_reset_dqcounts(
  1001. xfs_mount_t *mp,
  1002. xfs_buf_t *bp,
  1003. xfs_dqid_t id,
  1004. uint type)
  1005. {
  1006. xfs_disk_dquot_t *ddq;
  1007. int j;
  1008. trace_xfs_reset_dqcounts(bp, _RET_IP_);
  1009. /*
  1010. * Reset all counters and timers. They'll be
  1011. * started afresh by xfs_qm_quotacheck.
  1012. */
  1013. #ifdef DEBUG
  1014. j = XFS_FSB_TO_B(mp, XFS_DQUOT_CLUSTER_SIZE_FSB);
  1015. do_div(j, sizeof(xfs_dqblk_t));
  1016. ASSERT(mp->m_quotainfo->qi_dqperchunk == j);
  1017. #endif
  1018. ddq = bp->b_addr;
  1019. for (j = 0; j < mp->m_quotainfo->qi_dqperchunk; j++) {
  1020. /*
  1021. * Do a sanity check, and if needed, repair the dqblk. Don't
  1022. * output any warnings because it's perfectly possible to
  1023. * find uninitialised dquot blks. See comment in xfs_qm_dqcheck.
  1024. */
  1025. (void) xfs_qm_dqcheck(mp, ddq, id+j, type, XFS_QMOPT_DQREPAIR,
  1026. "xfs_quotacheck");
  1027. ddq->d_bcount = 0;
  1028. ddq->d_icount = 0;
  1029. ddq->d_rtbcount = 0;
  1030. ddq->d_btimer = 0;
  1031. ddq->d_itimer = 0;
  1032. ddq->d_rtbtimer = 0;
  1033. ddq->d_bwarns = 0;
  1034. ddq->d_iwarns = 0;
  1035. ddq->d_rtbwarns = 0;
  1036. ddq = (xfs_disk_dquot_t *) ((xfs_dqblk_t *)ddq + 1);
  1037. }
  1038. }
  1039. STATIC int
  1040. xfs_qm_dqiter_bufs(
  1041. xfs_mount_t *mp,
  1042. xfs_dqid_t firstid,
  1043. xfs_fsblock_t bno,
  1044. xfs_filblks_t blkcnt,
  1045. uint flags)
  1046. {
  1047. xfs_buf_t *bp;
  1048. int error;
  1049. int type;
  1050. ASSERT(blkcnt > 0);
  1051. type = flags & XFS_QMOPT_UQUOTA ? XFS_DQ_USER :
  1052. (flags & XFS_QMOPT_PQUOTA ? XFS_DQ_PROJ : XFS_DQ_GROUP);
  1053. error = 0;
  1054. /*
  1055. * Blkcnt arg can be a very big number, and might even be
  1056. * larger than the log itself. So, we have to break it up into
  1057. * manageable-sized transactions.
  1058. * Note that we don't start a permanent transaction here; we might
  1059. * not be able to get a log reservation for the whole thing up front,
  1060. * and we don't really care to either, because we just discard
  1061. * everything if we were to crash in the middle of this loop.
  1062. */
  1063. while (blkcnt--) {
  1064. error = xfs_trans_read_buf(mp, NULL, mp->m_ddev_targp,
  1065. XFS_FSB_TO_DADDR(mp, bno),
  1066. mp->m_quotainfo->qi_dqchunklen, 0, &bp);
  1067. if (error)
  1068. break;
  1069. xfs_qm_reset_dqcounts(mp, bp, firstid, type);
  1070. xfs_buf_delwri_queue(bp);
  1071. xfs_buf_relse(bp);
  1072. /*
  1073. * goto the next block.
  1074. */
  1075. bno++;
  1076. firstid += mp->m_quotainfo->qi_dqperchunk;
  1077. }
  1078. return error;
  1079. }
  1080. /*
  1081. * Iterate over all allocated USR/GRP/PRJ dquots in the system, calling a
  1082. * caller supplied function for every chunk of dquots that we find.
  1083. */
  1084. STATIC int
  1085. xfs_qm_dqiterate(
  1086. xfs_mount_t *mp,
  1087. xfs_inode_t *qip,
  1088. uint flags)
  1089. {
  1090. xfs_bmbt_irec_t *map;
  1091. int i, nmaps; /* number of map entries */
  1092. int error; /* return value */
  1093. xfs_fileoff_t lblkno;
  1094. xfs_filblks_t maxlblkcnt;
  1095. xfs_dqid_t firstid;
  1096. xfs_fsblock_t rablkno;
  1097. xfs_filblks_t rablkcnt;
  1098. error = 0;
  1099. /*
  1100. * This looks racy, but we can't keep an inode lock across a
  1101. * trans_reserve. But, this gets called during quotacheck, and that
  1102. * happens only at mount time which is single threaded.
  1103. */
  1104. if (qip->i_d.di_nblocks == 0)
  1105. return 0;
  1106. map = kmem_alloc(XFS_DQITER_MAP_SIZE * sizeof(*map), KM_SLEEP);
  1107. lblkno = 0;
  1108. maxlblkcnt = XFS_B_TO_FSB(mp, (xfs_ufsize_t)XFS_MAXIOFFSET(mp));
  1109. do {
  1110. nmaps = XFS_DQITER_MAP_SIZE;
  1111. /*
  1112. * We aren't changing the inode itself. Just changing
  1113. * some of its data. No new blocks are added here, and
  1114. * the inode is never added to the transaction.
  1115. */
  1116. xfs_ilock(qip, XFS_ILOCK_SHARED);
  1117. error = xfs_bmapi_read(qip, lblkno, maxlblkcnt - lblkno,
  1118. map, &nmaps, 0);
  1119. xfs_iunlock(qip, XFS_ILOCK_SHARED);
  1120. if (error)
  1121. break;
  1122. ASSERT(nmaps <= XFS_DQITER_MAP_SIZE);
  1123. for (i = 0; i < nmaps; i++) {
  1124. ASSERT(map[i].br_startblock != DELAYSTARTBLOCK);
  1125. ASSERT(map[i].br_blockcount);
  1126. lblkno += map[i].br_blockcount;
  1127. if (map[i].br_startblock == HOLESTARTBLOCK)
  1128. continue;
  1129. firstid = (xfs_dqid_t) map[i].br_startoff *
  1130. mp->m_quotainfo->qi_dqperchunk;
  1131. /*
  1132. * Do a read-ahead on the next extent.
  1133. */
  1134. if ((i+1 < nmaps) &&
  1135. (map[i+1].br_startblock != HOLESTARTBLOCK)) {
  1136. rablkcnt = map[i+1].br_blockcount;
  1137. rablkno = map[i+1].br_startblock;
  1138. while (rablkcnt--) {
  1139. xfs_buf_readahead(mp->m_ddev_targp,
  1140. XFS_FSB_TO_DADDR(mp, rablkno),
  1141. mp->m_quotainfo->qi_dqchunklen);
  1142. rablkno++;
  1143. }
  1144. }
  1145. /*
  1146. * Iterate thru all the blks in the extent and
  1147. * reset the counters of all the dquots inside them.
  1148. */
  1149. if ((error = xfs_qm_dqiter_bufs(mp,
  1150. firstid,
  1151. map[i].br_startblock,
  1152. map[i].br_blockcount,
  1153. flags))) {
  1154. break;
  1155. }
  1156. }
  1157. if (error)
  1158. break;
  1159. } while (nmaps > 0);
  1160. kmem_free(map);
  1161. return error;
  1162. }
  1163. /*
  1164. * Called by dqusage_adjust in doing a quotacheck.
  1165. *
  1166. * Given the inode, and a dquot id this updates both the incore dqout as well
  1167. * as the buffer copy. This is so that once the quotacheck is done, we can
  1168. * just log all the buffers, as opposed to logging numerous updates to
  1169. * individual dquots.
  1170. */
  1171. STATIC int
  1172. xfs_qm_quotacheck_dqadjust(
  1173. struct xfs_inode *ip,
  1174. xfs_dqid_t id,
  1175. uint type,
  1176. xfs_qcnt_t nblks,
  1177. xfs_qcnt_t rtblks)
  1178. {
  1179. struct xfs_mount *mp = ip->i_mount;
  1180. struct xfs_dquot *dqp;
  1181. int error;
  1182. error = xfs_qm_dqget(mp, ip, id, type,
  1183. XFS_QMOPT_DQALLOC | XFS_QMOPT_DOWARN, &dqp);
  1184. if (error) {
  1185. /*
  1186. * Shouldn't be able to turn off quotas here.
  1187. */
  1188. ASSERT(error != ESRCH);
  1189. ASSERT(error != ENOENT);
  1190. return error;
  1191. }
  1192. trace_xfs_dqadjust(dqp);
  1193. /*
  1194. * Adjust the inode count and the block count to reflect this inode's
  1195. * resource usage.
  1196. */
  1197. be64_add_cpu(&dqp->q_core.d_icount, 1);
  1198. dqp->q_res_icount++;
  1199. if (nblks) {
  1200. be64_add_cpu(&dqp->q_core.d_bcount, nblks);
  1201. dqp->q_res_bcount += nblks;
  1202. }
  1203. if (rtblks) {
  1204. be64_add_cpu(&dqp->q_core.d_rtbcount, rtblks);
  1205. dqp->q_res_rtbcount += rtblks;
  1206. }
  1207. /*
  1208. * Set default limits, adjust timers (since we changed usages)
  1209. *
  1210. * There are no timers for the default values set in the root dquot.
  1211. */
  1212. if (dqp->q_core.d_id) {
  1213. xfs_qm_adjust_dqlimits(mp, &dqp->q_core);
  1214. xfs_qm_adjust_dqtimers(mp, &dqp->q_core);
  1215. }
  1216. dqp->dq_flags |= XFS_DQ_DIRTY;
  1217. xfs_qm_dqput(dqp);
  1218. return 0;
  1219. }
  1220. STATIC int
  1221. xfs_qm_get_rtblks(
  1222. xfs_inode_t *ip,
  1223. xfs_qcnt_t *O_rtblks)
  1224. {
  1225. xfs_filblks_t rtblks; /* total rt blks */
  1226. xfs_extnum_t idx; /* extent record index */
  1227. xfs_ifork_t *ifp; /* inode fork pointer */
  1228. xfs_extnum_t nextents; /* number of extent entries */
  1229. int error;
  1230. ASSERT(XFS_IS_REALTIME_INODE(ip));
  1231. ifp = XFS_IFORK_PTR(ip, XFS_DATA_FORK);
  1232. if (!(ifp->if_flags & XFS_IFEXTENTS)) {
  1233. if ((error = xfs_iread_extents(NULL, ip, XFS_DATA_FORK)))
  1234. return error;
  1235. }
  1236. rtblks = 0;
  1237. nextents = ifp->if_bytes / (uint)sizeof(xfs_bmbt_rec_t);
  1238. for (idx = 0; idx < nextents; idx++)
  1239. rtblks += xfs_bmbt_get_blockcount(xfs_iext_get_ext(ifp, idx));
  1240. *O_rtblks = (xfs_qcnt_t)rtblks;
  1241. return 0;
  1242. }
  1243. /*
  1244. * callback routine supplied to bulkstat(). Given an inumber, find its
  1245. * dquots and update them to account for resources taken by that inode.
  1246. */
  1247. /* ARGSUSED */
  1248. STATIC int
  1249. xfs_qm_dqusage_adjust(
  1250. xfs_mount_t *mp, /* mount point for filesystem */
  1251. xfs_ino_t ino, /* inode number to get data for */
  1252. void __user *buffer, /* not used */
  1253. int ubsize, /* not used */
  1254. int *ubused, /* not used */
  1255. int *res) /* result code value */
  1256. {
  1257. xfs_inode_t *ip;
  1258. xfs_qcnt_t nblks, rtblks = 0;
  1259. int error;
  1260. ASSERT(XFS_IS_QUOTA_RUNNING(mp));
  1261. /*
  1262. * rootino must have its resources accounted for, not so with the quota
  1263. * inodes.
  1264. */
  1265. if (ino == mp->m_sb.sb_uquotino || ino == mp->m_sb.sb_gquotino) {
  1266. *res = BULKSTAT_RV_NOTHING;
  1267. return XFS_ERROR(EINVAL);
  1268. }
  1269. /*
  1270. * We don't _need_ to take the ilock EXCL. However, the xfs_qm_dqget
  1271. * interface expects the inode to be exclusively locked because that's
  1272. * the case in all other instances. It's OK that we do this because
  1273. * quotacheck is done only at mount time.
  1274. */
  1275. error = xfs_iget(mp, NULL, ino, 0, XFS_ILOCK_EXCL, &ip);
  1276. if (error) {
  1277. *res = BULKSTAT_RV_NOTHING;
  1278. return error;
  1279. }
  1280. ASSERT(ip->i_delayed_blks == 0);
  1281. if (XFS_IS_REALTIME_INODE(ip)) {
  1282. /*
  1283. * Walk thru the extent list and count the realtime blocks.
  1284. */
  1285. error = xfs_qm_get_rtblks(ip, &rtblks);
  1286. if (error)
  1287. goto error0;
  1288. }
  1289. nblks = (xfs_qcnt_t)ip->i_d.di_nblocks - rtblks;
  1290. /*
  1291. * Add the (disk blocks and inode) resources occupied by this
  1292. * inode to its dquots. We do this adjustment in the incore dquot,
  1293. * and also copy the changes to its buffer.
  1294. * We don't care about putting these changes in a transaction
  1295. * envelope because if we crash in the middle of a 'quotacheck'
  1296. * we have to start from the beginning anyway.
  1297. * Once we're done, we'll log all the dquot bufs.
  1298. *
  1299. * The *QUOTA_ON checks below may look pretty racy, but quotachecks
  1300. * and quotaoffs don't race. (Quotachecks happen at mount time only).
  1301. */
  1302. if (XFS_IS_UQUOTA_ON(mp)) {
  1303. error = xfs_qm_quotacheck_dqadjust(ip, ip->i_d.di_uid,
  1304. XFS_DQ_USER, nblks, rtblks);
  1305. if (error)
  1306. goto error0;
  1307. }
  1308. if (XFS_IS_GQUOTA_ON(mp)) {
  1309. error = xfs_qm_quotacheck_dqadjust(ip, ip->i_d.di_gid,
  1310. XFS_DQ_GROUP, nblks, rtblks);
  1311. if (error)
  1312. goto error0;
  1313. }
  1314. if (XFS_IS_PQUOTA_ON(mp)) {
  1315. error = xfs_qm_quotacheck_dqadjust(ip, xfs_get_projid(ip),
  1316. XFS_DQ_PROJ, nblks, rtblks);
  1317. if (error)
  1318. goto error0;
  1319. }
  1320. xfs_iunlock(ip, XFS_ILOCK_EXCL);
  1321. IRELE(ip);
  1322. *res = BULKSTAT_RV_DIDONE;
  1323. return 0;
  1324. error0:
  1325. xfs_iunlock(ip, XFS_ILOCK_EXCL);
  1326. IRELE(ip);
  1327. *res = BULKSTAT_RV_GIVEUP;
  1328. return error;
  1329. }
  1330. /*
  1331. * Walk thru all the filesystem inodes and construct a consistent view
  1332. * of the disk quota world. If the quotacheck fails, disable quotas.
  1333. */
  1334. int
  1335. xfs_qm_quotacheck(
  1336. xfs_mount_t *mp)
  1337. {
  1338. int done, count, error;
  1339. xfs_ino_t lastino;
  1340. size_t structsz;
  1341. xfs_inode_t *uip, *gip;
  1342. uint flags;
  1343. count = INT_MAX;
  1344. structsz = 1;
  1345. lastino = 0;
  1346. flags = 0;
  1347. ASSERT(mp->m_quotainfo->qi_uquotaip || mp->m_quotainfo->qi_gquotaip);
  1348. ASSERT(XFS_IS_QUOTA_RUNNING(mp));
  1349. /*
  1350. * There should be no cached dquots. The (simplistic) quotacheck
  1351. * algorithm doesn't like that.
  1352. */
  1353. ASSERT(list_empty(&mp->m_quotainfo->qi_dqlist));
  1354. xfs_notice(mp, "Quotacheck needed: Please wait.");
  1355. /*
  1356. * First we go thru all the dquots on disk, USR and GRP/PRJ, and reset
  1357. * their counters to zero. We need a clean slate.
  1358. * We don't log our changes till later.
  1359. */
  1360. uip = mp->m_quotainfo->qi_uquotaip;
  1361. if (uip) {
  1362. error = xfs_qm_dqiterate(mp, uip, XFS_QMOPT_UQUOTA);
  1363. if (error)
  1364. goto error_return;
  1365. flags |= XFS_UQUOTA_CHKD;
  1366. }
  1367. gip = mp->m_quotainfo->qi_gquotaip;
  1368. if (gip) {
  1369. error = xfs_qm_dqiterate(mp, gip, XFS_IS_GQUOTA_ON(mp) ?
  1370. XFS_QMOPT_GQUOTA : XFS_QMOPT_PQUOTA);
  1371. if (error)
  1372. goto error_return;
  1373. flags |= XFS_OQUOTA_CHKD;
  1374. }
  1375. do {
  1376. /*
  1377. * Iterate thru all the inodes in the file system,
  1378. * adjusting the corresponding dquot counters in core.
  1379. */
  1380. error = xfs_bulkstat(mp, &lastino, &count,
  1381. xfs_qm_dqusage_adjust,
  1382. structsz, NULL, &done);
  1383. if (error)
  1384. break;
  1385. } while (!done);
  1386. /*
  1387. * We've made all the changes that we need to make incore.
  1388. * Flush them down to disk buffers if everything was updated
  1389. * successfully.
  1390. */
  1391. if (!error)
  1392. error = xfs_qm_dqflush_all(mp);
  1393. /*
  1394. * We can get this error if we couldn't do a dquot allocation inside
  1395. * xfs_qm_dqusage_adjust (via bulkstat). We don't care about the
  1396. * dirty dquots that might be cached, we just want to get rid of them
  1397. * and turn quotaoff. The dquots won't be attached to any of the inodes
  1398. * at this point (because we intentionally didn't in dqget_noattach).
  1399. */
  1400. if (error) {
  1401. xfs_qm_dqpurge_all(mp, XFS_QMOPT_QUOTALL);
  1402. goto error_return;
  1403. }
  1404. /*
  1405. * We didn't log anything, because if we crashed, we'll have to
  1406. * start the quotacheck from scratch anyway. However, we must make
  1407. * sure that our dquot changes are secure before we put the
  1408. * quotacheck'd stamp on the superblock. So, here we do a synchronous
  1409. * flush.
  1410. */
  1411. xfs_flush_buftarg(mp->m_ddev_targp, 1);
  1412. /*
  1413. * If one type of quotas is off, then it will lose its
  1414. * quotachecked status, since we won't be doing accounting for
  1415. * that type anymore.
  1416. */
  1417. mp->m_qflags &= ~(XFS_OQUOTA_CHKD | XFS_UQUOTA_CHKD);
  1418. mp->m_qflags |= flags;
  1419. error_return:
  1420. if (error) {
  1421. xfs_warn(mp,
  1422. "Quotacheck: Unsuccessful (Error %d): Disabling quotas.",
  1423. error);
  1424. /*
  1425. * We must turn off quotas.
  1426. */
  1427. ASSERT(mp->m_quotainfo != NULL);
  1428. ASSERT(xfs_Gqm != NULL);
  1429. xfs_qm_destroy_quotainfo(mp);
  1430. if (xfs_mount_reset_sbqflags(mp)) {
  1431. xfs_warn(mp,
  1432. "Quotacheck: Failed to reset quota flags.");
  1433. }
  1434. } else
  1435. xfs_notice(mp, "Quotacheck: Done.");
  1436. return (error);
  1437. }
  1438. /*
  1439. * This is called after the superblock has been read in and we're ready to
  1440. * iget the quota inodes.
  1441. */
  1442. STATIC int
  1443. xfs_qm_init_quotainos(
  1444. xfs_mount_t *mp)
  1445. {
  1446. xfs_inode_t *uip, *gip;
  1447. int error;
  1448. __int64_t sbflags;
  1449. uint flags;
  1450. ASSERT(mp->m_quotainfo);
  1451. uip = gip = NULL;
  1452. sbflags = 0;
  1453. flags = 0;
  1454. /*
  1455. * Get the uquota and gquota inodes
  1456. */
  1457. if (xfs_sb_version_hasquota(&mp->m_sb)) {
  1458. if (XFS_IS_UQUOTA_ON(mp) &&
  1459. mp->m_sb.sb_uquotino != NULLFSINO) {
  1460. ASSERT(mp->m_sb.sb_uquotino > 0);
  1461. if ((error = xfs_iget(mp, NULL, mp->m_sb.sb_uquotino,
  1462. 0, 0, &uip)))
  1463. return XFS_ERROR(error);
  1464. }
  1465. if (XFS_IS_OQUOTA_ON(mp) &&
  1466. mp->m_sb.sb_gquotino != NULLFSINO) {
  1467. ASSERT(mp->m_sb.sb_gquotino > 0);
  1468. if ((error = xfs_iget(mp, NULL, mp->m_sb.sb_gquotino,
  1469. 0, 0, &gip))) {
  1470. if (uip)
  1471. IRELE(uip);
  1472. return XFS_ERROR(error);
  1473. }
  1474. }
  1475. } else {
  1476. flags |= XFS_QMOPT_SBVERSION;
  1477. sbflags |= (XFS_SB_VERSIONNUM | XFS_SB_UQUOTINO |
  1478. XFS_SB_GQUOTINO | XFS_SB_QFLAGS);
  1479. }
  1480. /*
  1481. * Create the two inodes, if they don't exist already. The changes
  1482. * made above will get added to a transaction and logged in one of
  1483. * the qino_alloc calls below. If the device is readonly,
  1484. * temporarily switch to read-write to do this.
  1485. */
  1486. if (XFS_IS_UQUOTA_ON(mp) && uip == NULL) {
  1487. if ((error = xfs_qm_qino_alloc(mp, &uip,
  1488. sbflags | XFS_SB_UQUOTINO,
  1489. flags | XFS_QMOPT_UQUOTA)))
  1490. return XFS_ERROR(error);
  1491. flags &= ~XFS_QMOPT_SBVERSION;
  1492. }
  1493. if (XFS_IS_OQUOTA_ON(mp) && gip == NULL) {
  1494. flags |= (XFS_IS_GQUOTA_ON(mp) ?
  1495. XFS_QMOPT_GQUOTA : XFS_QMOPT_PQUOTA);
  1496. error = xfs_qm_qino_alloc(mp, &gip,
  1497. sbflags | XFS_SB_GQUOTINO, flags);
  1498. if (error) {
  1499. if (uip)
  1500. IRELE(uip);
  1501. return XFS_ERROR(error);
  1502. }
  1503. }
  1504. mp->m_quotainfo->qi_uquotaip = uip;
  1505. mp->m_quotainfo->qi_gquotaip = gip;
  1506. return 0;
  1507. }
  1508. /*
  1509. * Just pop the least recently used dquot off the freelist and
  1510. * recycle it. The returned dquot is locked.
  1511. */
  1512. STATIC xfs_dquot_t *
  1513. xfs_qm_dqreclaim_one(void)
  1514. {
  1515. xfs_dquot_t *dqpout;
  1516. xfs_dquot_t *dqp;
  1517. int restarts;
  1518. int startagain;
  1519. restarts = 0;
  1520. dqpout = NULL;
  1521. /* lockorder: hashchainlock, freelistlock, mplistlock, dqlock, dqflock */
  1522. again:
  1523. startagain = 0;
  1524. mutex_lock(&xfs_Gqm->qm_dqfrlist_lock);
  1525. list_for_each_entry(dqp, &xfs_Gqm->qm_dqfrlist, q_freelist) {
  1526. struct xfs_mount *mp = dqp->q_mount;
  1527. xfs_dqlock(dqp);
  1528. /*
  1529. * We are racing with dqlookup here. Naturally we don't
  1530. * want to reclaim a dquot that lookup wants. We release the
  1531. * freelist lock and start over, so that lookup will grab
  1532. * both the dquot and the freelistlock.
  1533. */
  1534. if (dqp->dq_flags & XFS_DQ_WANT) {
  1535. ASSERT(! (dqp->dq_flags & XFS_DQ_INACTIVE));
  1536. trace_xfs_dqreclaim_want(dqp);
  1537. XQM_STATS_INC(xqmstats.xs_qm_dqwants);
  1538. restarts++;
  1539. startagain = 1;
  1540. goto dqunlock;
  1541. }
  1542. /*
  1543. * If the dquot is inactive, we are assured that it is
  1544. * not on the mplist or the hashlist, and that makes our
  1545. * life easier.
  1546. */
  1547. if (dqp->dq_flags & XFS_DQ_INACTIVE) {
  1548. ASSERT(mp == NULL);
  1549. ASSERT(! XFS_DQ_IS_DIRTY(dqp));
  1550. ASSERT(list_empty(&dqp->q_hashlist));
  1551. ASSERT(list_empty(&dqp->q_mplist));
  1552. list_del_init(&dqp->q_freelist);
  1553. xfs_Gqm->qm_dqfrlist_cnt--;
  1554. dqpout = dqp;
  1555. XQM_STATS_INC(xqmstats.xs_qm_dqinact_reclaims);
  1556. goto dqunlock;
  1557. }
  1558. ASSERT(dqp->q_hash);
  1559. ASSERT(!list_empty(&dqp->q_mplist));
  1560. /*
  1561. * Try to grab the flush lock. If this dquot is in the process
  1562. * of getting flushed to disk, we don't want to reclaim it.
  1563. */
  1564. if (!xfs_dqflock_nowait(dqp))
  1565. goto dqunlock;
  1566. /*
  1567. * We have the flush lock so we know that this is not in the
  1568. * process of being flushed. So, if this is dirty, flush it
  1569. * DELWRI so that we don't get a freelist infested with
  1570. * dirty dquots.
  1571. */
  1572. if (XFS_DQ_IS_DIRTY(dqp)) {
  1573. int error;
  1574. trace_xfs_dqreclaim_dirty(dqp);
  1575. /*
  1576. * We flush it delayed write, so don't bother
  1577. * releasing the freelist lock.
  1578. */
  1579. error = xfs_qm_dqflush(dqp, SYNC_TRYLOCK);
  1580. if (error) {
  1581. xfs_warn(mp, "%s: dquot %p flush failed",
  1582. __func__, dqp);
  1583. }
  1584. goto dqunlock;
  1585. }
  1586. /*
  1587. * We're trying to get the hashlock out of order. This races
  1588. * with dqlookup; so, we giveup and goto the next dquot if
  1589. * we couldn't get the hashlock. This way, we won't starve
  1590. * a dqlookup process that holds the hashlock that is
  1591. * waiting for the freelist lock.
  1592. */
  1593. if (!mutex_trylock(&dqp->q_hash->qh_lock)) {
  1594. restarts++;
  1595. goto dqfunlock;
  1596. }
  1597. /*
  1598. * This races with dquot allocation code as well as dqflush_all
  1599. * and reclaim code. So, if we failed to grab the mplist lock,
  1600. * giveup everything and start over.
  1601. */
  1602. if (!mutex_trylock(&mp->m_quotainfo->qi_dqlist_lock)) {
  1603. restarts++;
  1604. startagain = 1;
  1605. goto qhunlock;
  1606. }
  1607. ASSERT(dqp->q_nrefs == 0);
  1608. list_del_init(&dqp->q_mplist);
  1609. mp->m_quotainfo->qi_dquots--;
  1610. mp->m_quotainfo->qi_dqreclaims++;
  1611. list_del_init(&dqp->q_hashlist);
  1612. dqp->q_hash->qh_version++;
  1613. list_del_init(&dqp->q_freelist);
  1614. xfs_Gqm->qm_dqfrlist_cnt--;
  1615. dqpout = dqp;
  1616. mutex_unlock(&mp->m_quotainfo->qi_dqlist_lock);
  1617. qhunlock:
  1618. mutex_unlock(&dqp->q_hash->qh_lock);
  1619. dqfunlock:
  1620. xfs_dqfunlock(dqp);
  1621. dqunlock:
  1622. xfs_dqunlock(dqp);
  1623. if (dqpout)
  1624. break;
  1625. if (restarts >= XFS_QM_RECLAIM_MAX_RESTARTS)
  1626. break;
  1627. if (startagain) {
  1628. mutex_unlock(&xfs_Gqm->qm_dqfrlist_lock);
  1629. goto again;
  1630. }
  1631. }
  1632. mutex_unlock(&xfs_Gqm->qm_dqfrlist_lock);
  1633. return dqpout;
  1634. }
  1635. /*
  1636. * Traverse the freelist of dquots and attempt to reclaim a maximum of
  1637. * 'howmany' dquots. This operation races with dqlookup(), and attempts to
  1638. * favor the lookup function ...
  1639. */
  1640. STATIC int
  1641. xfs_qm_shake_freelist(
  1642. int howmany)
  1643. {
  1644. int nreclaimed = 0;
  1645. xfs_dquot_t *dqp;
  1646. if (howmany <= 0)
  1647. return 0;
  1648. while (nreclaimed < howmany) {
  1649. dqp = xfs_qm_dqreclaim_one();
  1650. if (!dqp)
  1651. return nreclaimed;
  1652. xfs_qm_dqdestroy(dqp);
  1653. nreclaimed++;
  1654. }
  1655. return nreclaimed;
  1656. }
  1657. /*
  1658. * The kmem_shake interface is invoked when memory is running low.
  1659. */
  1660. /* ARGSUSED */
  1661. STATIC int
  1662. xfs_qm_shake(
  1663. struct shrinker *shrink,
  1664. struct shrink_control *sc)
  1665. {
  1666. int ndqused, nfree, n;
  1667. gfp_t gfp_mask = sc->gfp_mask;
  1668. if (!kmem_shake_allow(gfp_mask))
  1669. return 0;
  1670. if (!xfs_Gqm)
  1671. return 0;
  1672. nfree = xfs_Gqm->qm_dqfrlist_cnt; /* free dquots */
  1673. /* incore dquots in all f/s's */
  1674. ndqused = atomic_read(&xfs_Gqm->qm_totaldquots) - nfree;
  1675. ASSERT(ndqused >= 0);
  1676. if (nfree <= ndqused && nfree < ndquot)
  1677. return 0;
  1678. ndqused *= xfs_Gqm->qm_dqfree_ratio; /* target # of free dquots */
  1679. n = nfree - ndqused - ndquot; /* # over target */
  1680. return xfs_qm_shake_freelist(MAX(nfree, n));
  1681. }
  1682. /*------------------------------------------------------------------*/
  1683. /*
  1684. * Return a new incore dquot. Depending on the number of
  1685. * dquots in the system, we either allocate a new one on the kernel heap,
  1686. * or reclaim a free one.
  1687. * Return value is B_TRUE if we allocated a new dquot, B_FALSE if we managed
  1688. * to reclaim an existing one from the freelist.
  1689. */
  1690. boolean_t
  1691. xfs_qm_dqalloc_incore(
  1692. xfs_dquot_t **O_dqpp)
  1693. {
  1694. xfs_dquot_t *dqp;
  1695. /*
  1696. * Check against high water mark to see if we want to pop
  1697. * a nincompoop dquot off the freelist.
  1698. */
  1699. if (atomic_read(&xfs_Gqm->qm_totaldquots) >= ndquot) {
  1700. /*
  1701. * Try to recycle a dquot from the freelist.
  1702. */
  1703. if ((dqp = xfs_qm_dqreclaim_one())) {
  1704. XQM_STATS_INC(xqmstats.xs_qm_dqreclaims);
  1705. /*
  1706. * Just zero the core here. The rest will get
  1707. * reinitialized by caller. XXX we shouldn't even
  1708. * do this zero ...
  1709. */
  1710. memset(&dqp->q_core, 0, sizeof(dqp->q_core));
  1711. *O_dqpp = dqp;
  1712. return B_FALSE;
  1713. }
  1714. XQM_STATS_INC(xqmstats.xs_qm_dqreclaim_misses);
  1715. }
  1716. /*
  1717. * Allocate a brand new dquot on the kernel heap and return it
  1718. * to the caller to initialize.
  1719. */
  1720. ASSERT(xfs_Gqm->qm_dqzone != NULL);
  1721. *O_dqpp = kmem_zone_zalloc(xfs_Gqm->qm_dqzone, KM_SLEEP);
  1722. atomic_inc(&xfs_Gqm->qm_totaldquots);
  1723. return B_TRUE;
  1724. }
  1725. /*
  1726. * Start a transaction and write the incore superblock changes to
  1727. * disk. flags parameter indicates which fields have changed.
  1728. */
  1729. int
  1730. xfs_qm_write_sb_changes(
  1731. xfs_mount_t *mp,
  1732. __int64_t flags)
  1733. {
  1734. xfs_trans_t *tp;
  1735. int error;
  1736. tp = xfs_trans_alloc(mp, XFS_TRANS_QM_SBCHANGE);
  1737. if ((error = xfs_trans_reserve(tp, 0,
  1738. mp->m_sb.sb_sectsize + 128, 0,
  1739. 0,
  1740. XFS_DEFAULT_LOG_COUNT))) {
  1741. xfs_trans_cancel(tp, 0);
  1742. return error;
  1743. }
  1744. xfs_mod_sb(tp, flags);
  1745. error = xfs_trans_commit(tp, 0);
  1746. return error;
  1747. }
  1748. /* --------------- utility functions for vnodeops ---------------- */
  1749. /*
  1750. * Given an inode, a uid, gid and prid make sure that we have
  1751. * allocated relevant dquot(s) on disk, and that we won't exceed inode
  1752. * quotas by creating this file.
  1753. * This also attaches dquot(s) to the given inode after locking it,
  1754. * and returns the dquots corresponding to the uid and/or gid.
  1755. *
  1756. * in : inode (unlocked)
  1757. * out : udquot, gdquot with references taken and unlocked
  1758. */
  1759. int
  1760. xfs_qm_vop_dqalloc(
  1761. struct xfs_inode *ip,
  1762. uid_t uid,
  1763. gid_t gid,
  1764. prid_t prid,
  1765. uint flags,
  1766. struct xfs_dquot **O_udqpp,
  1767. struct xfs_dquot **O_gdqpp)
  1768. {
  1769. struct xfs_mount *mp = ip->i_mount;
  1770. struct xfs_dquot *uq, *gq;
  1771. int error;
  1772. uint lockflags;
  1773. if (!XFS_IS_QUOTA_RUNNING(mp) || !XFS_IS_QUOTA_ON(mp))
  1774. return 0;
  1775. lockflags = XFS_ILOCK_EXCL;
  1776. xfs_ilock(ip, lockflags);
  1777. if ((flags & XFS_QMOPT_INHERIT) && XFS_INHERIT_GID(ip))
  1778. gid = ip->i_d.di_gid;
  1779. /*
  1780. * Attach the dquot(s) to this inode, doing a dquot allocation
  1781. * if necessary. The dquot(s) will not be locked.
  1782. */
  1783. if (XFS_NOT_DQATTACHED(mp, ip)) {
  1784. error = xfs_qm_dqattach_locked(ip, XFS_QMOPT_DQALLOC);
  1785. if (error) {
  1786. xfs_iunlock(ip, lockflags);
  1787. return error;
  1788. }
  1789. }
  1790. uq = gq = NULL;
  1791. if ((flags & XFS_QMOPT_UQUOTA) && XFS_IS_UQUOTA_ON(mp)) {
  1792. if (ip->i_d.di_uid != uid) {
  1793. /*
  1794. * What we need is the dquot that has this uid, and
  1795. * if we send the inode to dqget, the uid of the inode
  1796. * takes priority over what's sent in the uid argument.
  1797. * We must unlock inode here before calling dqget if
  1798. * we're not sending the inode, because otherwise
  1799. * we'll deadlock by doing trans_reserve while
  1800. * holding ilock.
  1801. */
  1802. xfs_iunlock(ip, lockflags);
  1803. if ((error = xfs_qm_dqget(mp, NULL, (xfs_dqid_t) uid,
  1804. XFS_DQ_USER,
  1805. XFS_QMOPT_DQALLOC |
  1806. XFS_QMOPT_DOWARN,
  1807. &uq))) {
  1808. ASSERT(error != ENOENT);
  1809. return error;
  1810. }
  1811. /*
  1812. * Get the ilock in the right order.
  1813. */
  1814. xfs_dqunlock(uq);
  1815. lockflags = XFS_ILOCK_SHARED;
  1816. xfs_ilock(ip, lockflags);
  1817. } else {
  1818. /*
  1819. * Take an extra reference, because we'll return
  1820. * this to caller
  1821. */
  1822. ASSERT(ip->i_udquot);
  1823. uq = ip->i_udquot;
  1824. xfs_dqlock(uq);
  1825. XFS_DQHOLD(uq);
  1826. xfs_dqunlock(uq);
  1827. }
  1828. }
  1829. if ((flags & XFS_QMOPT_GQUOTA) && XFS_IS_GQUOTA_ON(mp)) {
  1830. if (ip->i_d.di_gid != gid) {
  1831. xfs_iunlock(ip, lockflags);
  1832. if ((error = xfs_qm_dqget(mp, NULL, (xfs_dqid_t)gid,
  1833. XFS_DQ_GROUP,
  1834. XFS_QMOPT_DQALLOC |
  1835. XFS_QMOPT_DOWARN,
  1836. &gq))) {
  1837. if (uq)
  1838. xfs_qm_dqrele(uq);
  1839. ASSERT(error != ENOENT);
  1840. return error;
  1841. }
  1842. xfs_dqunlock(gq);
  1843. lockflags = XFS_ILOCK_SHARED;
  1844. xfs_ilock(ip, lockflags);
  1845. } else {
  1846. ASSERT(ip->i_gdquot);
  1847. gq = ip->i_gdquot;
  1848. xfs_dqlock(gq);
  1849. XFS_DQHOLD(gq);
  1850. xfs_dqunlock(gq);
  1851. }
  1852. } else if ((flags & XFS_QMOPT_PQUOTA) && XFS_IS_PQUOTA_ON(mp)) {
  1853. if (xfs_get_projid(ip) != prid) {
  1854. xfs_iunlock(ip, lockflags);
  1855. if ((error = xfs_qm_dqget(mp, NULL, (xfs_dqid_t)prid,
  1856. XFS_DQ_PROJ,
  1857. XFS_QMOPT_DQALLOC |
  1858. XFS_QMOPT_DOWARN,
  1859. &gq))) {
  1860. if (uq)
  1861. xfs_qm_dqrele(uq);
  1862. ASSERT(error != ENOENT);
  1863. return (error);
  1864. }
  1865. xfs_dqunlock(gq);
  1866. lockflags = XFS_ILOCK_SHARED;
  1867. xfs_ilock(ip, lockflags);
  1868. } else {
  1869. ASSERT(ip->i_gdquot);
  1870. gq = ip->i_gdquot;
  1871. xfs_dqlock(gq);
  1872. XFS_DQHOLD(gq);
  1873. xfs_dqunlock(gq);
  1874. }
  1875. }
  1876. if (uq)
  1877. trace_xfs_dquot_dqalloc(ip);
  1878. xfs_iunlock(ip, lockflags);
  1879. if (O_udqpp)
  1880. *O_udqpp = uq;
  1881. else if (uq)
  1882. xfs_qm_dqrele(uq);
  1883. if (O_gdqpp)
  1884. *O_gdqpp = gq;
  1885. else if (gq)
  1886. xfs_qm_dqrele(gq);
  1887. return 0;
  1888. }
  1889. /*
  1890. * Actually transfer ownership, and do dquot modifications.
  1891. * These were already reserved.
  1892. */
  1893. xfs_dquot_t *
  1894. xfs_qm_vop_chown(
  1895. xfs_trans_t *tp,
  1896. xfs_inode_t *ip,
  1897. xfs_dquot_t **IO_olddq,
  1898. xfs_dquot_t *newdq)
  1899. {
  1900. xfs_dquot_t *prevdq;
  1901. uint bfield = XFS_IS_REALTIME_INODE(ip) ?
  1902. XFS_TRANS_DQ_RTBCOUNT : XFS_TRANS_DQ_BCOUNT;
  1903. ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
  1904. ASSERT(XFS_IS_QUOTA_RUNNING(ip->i_mount));
  1905. /* old dquot */
  1906. prevdq = *IO_olddq;
  1907. ASSERT(prevdq);
  1908. ASSERT(prevdq != newdq);
  1909. xfs_trans_mod_dquot(tp, prevdq, bfield, -(ip->i_d.di_nblocks));
  1910. xfs_trans_mod_dquot(tp, prevdq, XFS_TRANS_DQ_ICOUNT, -1);
  1911. /* the sparkling new dquot */
  1912. xfs_trans_mod_dquot(tp, newdq, bfield, ip->i_d.di_nblocks);
  1913. xfs_trans_mod_dquot(tp, newdq, XFS_TRANS_DQ_ICOUNT, 1);
  1914. /*
  1915. * Take an extra reference, because the inode
  1916. * is going to keep this dquot pointer even
  1917. * after the trans_commit.
  1918. */
  1919. xfs_dqlock(newdq);
  1920. XFS_DQHOLD(newdq);
  1921. xfs_dqunlock(newdq);
  1922. *IO_olddq = newdq;
  1923. return prevdq;
  1924. }
  1925. /*
  1926. * Quota reservations for setattr(AT_UID|AT_GID|AT_PROJID).
  1927. */
  1928. int
  1929. xfs_qm_vop_chown_reserve(
  1930. xfs_trans_t *tp,
  1931. xfs_inode_t *ip,
  1932. xfs_dquot_t *udqp,
  1933. xfs_dquot_t *gdqp,
  1934. uint flags)
  1935. {
  1936. xfs_mount_t *mp = ip->i_mount;
  1937. uint delblks, blkflags, prjflags = 0;
  1938. xfs_dquot_t *unresudq, *unresgdq, *delblksudq, *delblksgdq;
  1939. int error;
  1940. ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL|XFS_ILOCK_SHARED));
  1941. ASSERT(XFS_IS_QUOTA_RUNNING(mp));
  1942. delblks = ip->i_delayed_blks;
  1943. delblksudq = delblksgdq = unresudq = unresgdq = NULL;
  1944. blkflags = XFS_IS_REALTIME_INODE(ip) ?
  1945. XFS_QMOPT_RES_RTBLKS : XFS_QMOPT_RES_REGBLKS;
  1946. if (XFS_IS_UQUOTA_ON(mp) && udqp &&
  1947. ip->i_d.di_uid != (uid_t)be32_to_cpu(udqp->q_core.d_id)) {
  1948. delblksudq = udqp;
  1949. /*
  1950. * If there are delayed allocation blocks, then we have to
  1951. * unreserve those from the old dquot, and add them to the
  1952. * new dquot.
  1953. */
  1954. if (delblks) {
  1955. ASSERT(ip->i_udquot);
  1956. unresudq = ip->i_udquot;
  1957. }
  1958. }
  1959. if (XFS_IS_OQUOTA_ON(ip->i_mount) && gdqp) {
  1960. if (XFS_IS_PQUOTA_ON(ip->i_mount) &&
  1961. xfs_get_projid(ip) != be32_to_cpu(gdqp->q_core.d_id))
  1962. prjflags = XFS_QMOPT_ENOSPC;
  1963. if (prjflags ||
  1964. (XFS_IS_GQUOTA_ON(ip->i_mount) &&
  1965. ip->i_d.di_gid != be32_to_cpu(gdqp->q_core.d_id))) {
  1966. delblksgdq = gdqp;
  1967. if (delblks) {
  1968. ASSERT(ip->i_gdquot);
  1969. unresgdq = ip->i_gdquot;
  1970. }
  1971. }
  1972. }
  1973. if ((error = xfs_trans_reserve_quota_bydquots(tp, ip->i_mount,
  1974. delblksudq, delblksgdq, ip->i_d.di_nblocks, 1,
  1975. flags | blkflags | prjflags)))
  1976. return (error);
  1977. /*
  1978. * Do the delayed blks reservations/unreservations now. Since, these
  1979. * are done without the help of a transaction, if a reservation fails
  1980. * its previous reservations won't be automatically undone by trans
  1981. * code. So, we have to do it manually here.
  1982. */
  1983. if (delblks) {
  1984. /*
  1985. * Do the reservations first. Unreservation can't fail.
  1986. */
  1987. ASSERT(delblksudq || delblksgdq);
  1988. ASSERT(unresudq || unresgdq);
  1989. if ((error = xfs_trans_reserve_quota_bydquots(NULL, ip->i_mount,
  1990. delblksudq, delblksgdq, (xfs_qcnt_t)delblks, 0,
  1991. flags | blkflags | prjflags)))
  1992. return (error);
  1993. xfs_trans_reserve_quota_bydquots(NULL, ip->i_mount,
  1994. unresudq, unresgdq, -((xfs_qcnt_t)delblks), 0,
  1995. blkflags);
  1996. }
  1997. return (0);
  1998. }
  1999. int
  2000. xfs_qm_vop_rename_dqattach(
  2001. struct xfs_inode **i_tab)
  2002. {
  2003. struct xfs_mount *mp = i_tab[0]->i_mount;
  2004. int i;
  2005. if (!XFS_IS_QUOTA_RUNNING(mp) || !XFS_IS_QUOTA_ON(mp))
  2006. return 0;
  2007. for (i = 0; (i < 4 && i_tab[i]); i++) {
  2008. struct xfs_inode *ip = i_tab[i];
  2009. int error;
  2010. /*
  2011. * Watch out for duplicate entries in the table.
  2012. */
  2013. if (i == 0 || ip != i_tab[i-1]) {
  2014. if (XFS_NOT_DQATTACHED(mp, ip)) {
  2015. error = xfs_qm_dqattach(ip, 0);
  2016. if (error)
  2017. return error;
  2018. }
  2019. }
  2020. }
  2021. return 0;
  2022. }
  2023. void
  2024. xfs_qm_vop_create_dqattach(
  2025. struct xfs_trans *tp,
  2026. struct xfs_inode *ip,
  2027. struct xfs_dquot *udqp,
  2028. struct xfs_dquot *gdqp)
  2029. {
  2030. struct xfs_mount *mp = tp->t_mountp;
  2031. if (!XFS_IS_QUOTA_RUNNING(mp) || !XFS_IS_QUOTA_ON(mp))
  2032. return;
  2033. ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
  2034. ASSERT(XFS_IS_QUOTA_RUNNING(mp));
  2035. if (udqp) {
  2036. xfs_dqlock(udqp);
  2037. XFS_DQHOLD(udqp);
  2038. xfs_dqunlock(udqp);
  2039. ASSERT(ip->i_udquot == NULL);
  2040. ip->i_udquot = udqp;
  2041. ASSERT(XFS_IS_UQUOTA_ON(mp));
  2042. ASSERT(ip->i_d.di_uid == be32_to_cpu(udqp->q_core.d_id));
  2043. xfs_trans_mod_dquot(tp, udqp, XFS_TRANS_DQ_ICOUNT, 1);
  2044. }
  2045. if (gdqp) {
  2046. xfs_dqlock(gdqp);
  2047. XFS_DQHOLD(gdqp);
  2048. xfs_dqunlock(gdqp);
  2049. ASSERT(ip->i_gdquot == NULL);
  2050. ip->i_gdquot = gdqp;
  2051. ASSERT(XFS_IS_OQUOTA_ON(mp));
  2052. ASSERT((XFS_IS_GQUOTA_ON(mp) ?
  2053. ip->i_d.di_gid : xfs_get_projid(ip)) ==
  2054. be32_to_cpu(gdqp->q_core.d_id));
  2055. xfs_trans_mod_dquot(tp, gdqp, XFS_TRANS_DQ_ICOUNT, 1);
  2056. }
  2057. }