xfs_dquot_item.c 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460
  1. /*
  2. * Copyright (c) 2000-2003 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_format.h"
  21. #include "xfs_log_format.h"
  22. #include "xfs_trans_resv.h"
  23. #include "xfs_sb.h"
  24. #include "xfs_ag.h"
  25. #include "xfs_mount.h"
  26. #include "xfs_inode.h"
  27. #include "xfs_quota.h"
  28. #include "xfs_error.h"
  29. #include "xfs_trans.h"
  30. #include "xfs_buf_item.h"
  31. #include "xfs_trans_priv.h"
  32. #include "xfs_qm.h"
  33. #include "xfs_log.h"
  34. static inline struct xfs_dq_logitem *DQUOT_ITEM(struct xfs_log_item *lip)
  35. {
  36. return container_of(lip, struct xfs_dq_logitem, qli_item);
  37. }
  38. /*
  39. * returns the number of iovecs needed to log the given dquot item.
  40. */
  41. STATIC void
  42. xfs_qm_dquot_logitem_size(
  43. struct xfs_log_item *lip,
  44. int *nvecs,
  45. int *nbytes)
  46. {
  47. *nvecs += 2;
  48. *nbytes += sizeof(struct xfs_dq_logformat) +
  49. sizeof(struct xfs_disk_dquot);
  50. }
  51. /*
  52. * fills in the vector of log iovecs for the given dquot log item.
  53. */
  54. STATIC void
  55. xfs_qm_dquot_logitem_format(
  56. struct xfs_log_item *lip,
  57. struct xfs_log_iovec *logvec)
  58. {
  59. struct xfs_dq_logitem *qlip = DQUOT_ITEM(lip);
  60. logvec->i_addr = &qlip->qli_format;
  61. logvec->i_len = sizeof(xfs_dq_logformat_t);
  62. logvec->i_type = XLOG_REG_TYPE_QFORMAT;
  63. logvec++;
  64. logvec->i_addr = &qlip->qli_dquot->q_core;
  65. logvec->i_len = sizeof(xfs_disk_dquot_t);
  66. logvec->i_type = XLOG_REG_TYPE_DQUOT;
  67. qlip->qli_format.qlf_size = 2;
  68. }
  69. /*
  70. * Increment the pin count of the given dquot.
  71. */
  72. STATIC void
  73. xfs_qm_dquot_logitem_pin(
  74. struct xfs_log_item *lip)
  75. {
  76. struct xfs_dquot *dqp = DQUOT_ITEM(lip)->qli_dquot;
  77. ASSERT(XFS_DQ_IS_LOCKED(dqp));
  78. atomic_inc(&dqp->q_pincount);
  79. }
  80. /*
  81. * Decrement the pin count of the given dquot, and wake up
  82. * anyone in xfs_dqwait_unpin() if the count goes to 0. The
  83. * dquot must have been previously pinned with a call to
  84. * xfs_qm_dquot_logitem_pin().
  85. */
  86. STATIC void
  87. xfs_qm_dquot_logitem_unpin(
  88. struct xfs_log_item *lip,
  89. int remove)
  90. {
  91. struct xfs_dquot *dqp = DQUOT_ITEM(lip)->qli_dquot;
  92. ASSERT(atomic_read(&dqp->q_pincount) > 0);
  93. if (atomic_dec_and_test(&dqp->q_pincount))
  94. wake_up(&dqp->q_pinwait);
  95. }
  96. STATIC xfs_lsn_t
  97. xfs_qm_dquot_logitem_committed(
  98. struct xfs_log_item *lip,
  99. xfs_lsn_t lsn)
  100. {
  101. /*
  102. * We always re-log the entire dquot when it becomes dirty,
  103. * so, the latest copy _is_ the only one that matters.
  104. */
  105. return lsn;
  106. }
  107. /*
  108. * This is called to wait for the given dquot to be unpinned.
  109. * Most of these pin/unpin routines are plagiarized from inode code.
  110. */
  111. void
  112. xfs_qm_dqunpin_wait(
  113. struct xfs_dquot *dqp)
  114. {
  115. ASSERT(XFS_DQ_IS_LOCKED(dqp));
  116. if (atomic_read(&dqp->q_pincount) == 0)
  117. return;
  118. /*
  119. * Give the log a push so we don't wait here too long.
  120. */
  121. xfs_log_force(dqp->q_mount, 0);
  122. wait_event(dqp->q_pinwait, (atomic_read(&dqp->q_pincount) == 0));
  123. }
  124. STATIC uint
  125. xfs_qm_dquot_logitem_push(
  126. struct xfs_log_item *lip,
  127. struct list_head *buffer_list) __releases(&lip->li_ailp->xa_lock)
  128. __acquires(&lip->li_ailp->xa_lock)
  129. {
  130. struct xfs_dquot *dqp = DQUOT_ITEM(lip)->qli_dquot;
  131. struct xfs_buf *bp = NULL;
  132. uint rval = XFS_ITEM_SUCCESS;
  133. int error;
  134. if (atomic_read(&dqp->q_pincount) > 0)
  135. return XFS_ITEM_PINNED;
  136. if (!xfs_dqlock_nowait(dqp))
  137. return XFS_ITEM_LOCKED;
  138. /*
  139. * Re-check the pincount now that we stabilized the value by
  140. * taking the quota lock.
  141. */
  142. if (atomic_read(&dqp->q_pincount) > 0) {
  143. rval = XFS_ITEM_PINNED;
  144. goto out_unlock;
  145. }
  146. /*
  147. * Someone else is already flushing the dquot. Nothing we can do
  148. * here but wait for the flush to finish and remove the item from
  149. * the AIL.
  150. */
  151. if (!xfs_dqflock_nowait(dqp)) {
  152. rval = XFS_ITEM_FLUSHING;
  153. goto out_unlock;
  154. }
  155. spin_unlock(&lip->li_ailp->xa_lock);
  156. error = xfs_qm_dqflush(dqp, &bp);
  157. if (error) {
  158. xfs_warn(dqp->q_mount, "%s: push error %d on dqp %p",
  159. __func__, error, dqp);
  160. } else {
  161. if (!xfs_buf_delwri_queue(bp, buffer_list))
  162. rval = XFS_ITEM_FLUSHING;
  163. xfs_buf_relse(bp);
  164. }
  165. spin_lock(&lip->li_ailp->xa_lock);
  166. out_unlock:
  167. xfs_dqunlock(dqp);
  168. return rval;
  169. }
  170. /*
  171. * Unlock the dquot associated with the log item.
  172. * Clear the fields of the dquot and dquot log item that
  173. * are specific to the current transaction. If the
  174. * hold flags is set, do not unlock the dquot.
  175. */
  176. STATIC void
  177. xfs_qm_dquot_logitem_unlock(
  178. struct xfs_log_item *lip)
  179. {
  180. struct xfs_dquot *dqp = DQUOT_ITEM(lip)->qli_dquot;
  181. ASSERT(XFS_DQ_IS_LOCKED(dqp));
  182. /*
  183. * Clear the transaction pointer in the dquot
  184. */
  185. dqp->q_transp = NULL;
  186. /*
  187. * dquots are never 'held' from getting unlocked at the end of
  188. * a transaction. Their locking and unlocking is hidden inside the
  189. * transaction layer, within trans_commit. Hence, no LI_HOLD flag
  190. * for the logitem.
  191. */
  192. xfs_dqunlock(dqp);
  193. }
  194. /*
  195. * this needs to stamp an lsn into the dquot, I think.
  196. * rpc's that look at user dquot's would then have to
  197. * push on the dependency recorded in the dquot
  198. */
  199. STATIC void
  200. xfs_qm_dquot_logitem_committing(
  201. struct xfs_log_item *lip,
  202. xfs_lsn_t lsn)
  203. {
  204. }
  205. /*
  206. * This is the ops vector for dquots
  207. */
  208. static const struct xfs_item_ops xfs_dquot_item_ops = {
  209. .iop_size = xfs_qm_dquot_logitem_size,
  210. .iop_format = xfs_qm_dquot_logitem_format,
  211. .iop_pin = xfs_qm_dquot_logitem_pin,
  212. .iop_unpin = xfs_qm_dquot_logitem_unpin,
  213. .iop_unlock = xfs_qm_dquot_logitem_unlock,
  214. .iop_committed = xfs_qm_dquot_logitem_committed,
  215. .iop_push = xfs_qm_dquot_logitem_push,
  216. .iop_committing = xfs_qm_dquot_logitem_committing
  217. };
  218. /*
  219. * Initialize the dquot log item for a newly allocated dquot.
  220. * The dquot isn't locked at this point, but it isn't on any of the lists
  221. * either, so we don't care.
  222. */
  223. void
  224. xfs_qm_dquot_logitem_init(
  225. struct xfs_dquot *dqp)
  226. {
  227. struct xfs_dq_logitem *lp = &dqp->q_logitem;
  228. xfs_log_item_init(dqp->q_mount, &lp->qli_item, XFS_LI_DQUOT,
  229. &xfs_dquot_item_ops);
  230. lp->qli_dquot = dqp;
  231. lp->qli_format.qlf_type = XFS_LI_DQUOT;
  232. lp->qli_format.qlf_id = be32_to_cpu(dqp->q_core.d_id);
  233. lp->qli_format.qlf_blkno = dqp->q_blkno;
  234. lp->qli_format.qlf_len = 1;
  235. /*
  236. * This is just the offset of this dquot within its buffer
  237. * (which is currently 1 FSB and probably won't change).
  238. * Hence 32 bits for this offset should be just fine.
  239. * Alternatively, we can store (bufoffset / sizeof(xfs_dqblk_t))
  240. * here, and recompute it at recovery time.
  241. */
  242. lp->qli_format.qlf_boffset = (__uint32_t)dqp->q_bufoffset;
  243. }
  244. /*------------------ QUOTAOFF LOG ITEMS -------------------*/
  245. static inline struct xfs_qoff_logitem *QOFF_ITEM(struct xfs_log_item *lip)
  246. {
  247. return container_of(lip, struct xfs_qoff_logitem, qql_item);
  248. }
  249. /*
  250. * This returns the number of iovecs needed to log the given quotaoff item.
  251. * We only need 1 iovec for an quotaoff item. It just logs the
  252. * quotaoff_log_format structure.
  253. */
  254. STATIC void
  255. xfs_qm_qoff_logitem_size(
  256. struct xfs_log_item *lip,
  257. int *nvecs,
  258. int *nbytes)
  259. {
  260. *nvecs += 1;
  261. *nbytes += sizeof(struct xfs_qoff_logitem);
  262. }
  263. /*
  264. * This is called to fill in the vector of log iovecs for the
  265. * given quotaoff log item. We use only 1 iovec, and we point that
  266. * at the quotaoff_log_format structure embedded in the quotaoff item.
  267. * It is at this point that we assert that all of the extent
  268. * slots in the quotaoff item have been filled.
  269. */
  270. STATIC void
  271. xfs_qm_qoff_logitem_format(
  272. struct xfs_log_item *lip,
  273. struct xfs_log_iovec *log_vector)
  274. {
  275. struct xfs_qoff_logitem *qflip = QOFF_ITEM(lip);
  276. ASSERT(qflip->qql_format.qf_type == XFS_LI_QUOTAOFF);
  277. log_vector->i_addr = &qflip->qql_format;
  278. log_vector->i_len = sizeof(xfs_qoff_logitem_t);
  279. log_vector->i_type = XLOG_REG_TYPE_QUOTAOFF;
  280. qflip->qql_format.qf_size = 1;
  281. }
  282. /*
  283. * Pinning has no meaning for an quotaoff item, so just return.
  284. */
  285. STATIC void
  286. xfs_qm_qoff_logitem_pin(
  287. struct xfs_log_item *lip)
  288. {
  289. }
  290. /*
  291. * Since pinning has no meaning for an quotaoff item, unpinning does
  292. * not either.
  293. */
  294. STATIC void
  295. xfs_qm_qoff_logitem_unpin(
  296. struct xfs_log_item *lip,
  297. int remove)
  298. {
  299. }
  300. /*
  301. * There isn't much you can do to push a quotaoff item. It is simply
  302. * stuck waiting for the log to be flushed to disk.
  303. */
  304. STATIC uint
  305. xfs_qm_qoff_logitem_push(
  306. struct xfs_log_item *lip,
  307. struct list_head *buffer_list)
  308. {
  309. return XFS_ITEM_LOCKED;
  310. }
  311. /*
  312. * Quotaoff items have no locking or pushing, so return failure
  313. * so that the caller doesn't bother with us.
  314. */
  315. STATIC void
  316. xfs_qm_qoff_logitem_unlock(
  317. struct xfs_log_item *lip)
  318. {
  319. }
  320. /*
  321. * The quotaoff-start-item is logged only once and cannot be moved in the log,
  322. * so simply return the lsn at which it's been logged.
  323. */
  324. STATIC xfs_lsn_t
  325. xfs_qm_qoff_logitem_committed(
  326. struct xfs_log_item *lip,
  327. xfs_lsn_t lsn)
  328. {
  329. return lsn;
  330. }
  331. STATIC xfs_lsn_t
  332. xfs_qm_qoffend_logitem_committed(
  333. struct xfs_log_item *lip,
  334. xfs_lsn_t lsn)
  335. {
  336. struct xfs_qoff_logitem *qfe = QOFF_ITEM(lip);
  337. struct xfs_qoff_logitem *qfs = qfe->qql_start_lip;
  338. struct xfs_ail *ailp = qfs->qql_item.li_ailp;
  339. /*
  340. * Delete the qoff-start logitem from the AIL.
  341. * xfs_trans_ail_delete() drops the AIL lock.
  342. */
  343. spin_lock(&ailp->xa_lock);
  344. xfs_trans_ail_delete(ailp, &qfs->qql_item, SHUTDOWN_LOG_IO_ERROR);
  345. kmem_free(qfs);
  346. kmem_free(qfe);
  347. return (xfs_lsn_t)-1;
  348. }
  349. /*
  350. * XXX rcc - don't know quite what to do with this. I think we can
  351. * just ignore it. The only time that isn't the case is if we allow
  352. * the client to somehow see that quotas have been turned off in which
  353. * we can't allow that to get back until the quotaoff hits the disk.
  354. * So how would that happen? Also, do we need different routines for
  355. * quotaoff start and quotaoff end? I suspect the answer is yes but
  356. * to be sure, I need to look at the recovery code and see how quota off
  357. * recovery is handled (do we roll forward or back or do something else).
  358. * If we roll forwards or backwards, then we need two separate routines,
  359. * one that does nothing and one that stamps in the lsn that matters
  360. * (truly makes the quotaoff irrevocable). If we do something else,
  361. * then maybe we don't need two.
  362. */
  363. STATIC void
  364. xfs_qm_qoff_logitem_committing(
  365. struct xfs_log_item *lip,
  366. xfs_lsn_t commit_lsn)
  367. {
  368. }
  369. static const struct xfs_item_ops xfs_qm_qoffend_logitem_ops = {
  370. .iop_size = xfs_qm_qoff_logitem_size,
  371. .iop_format = xfs_qm_qoff_logitem_format,
  372. .iop_pin = xfs_qm_qoff_logitem_pin,
  373. .iop_unpin = xfs_qm_qoff_logitem_unpin,
  374. .iop_unlock = xfs_qm_qoff_logitem_unlock,
  375. .iop_committed = xfs_qm_qoffend_logitem_committed,
  376. .iop_push = xfs_qm_qoff_logitem_push,
  377. .iop_committing = xfs_qm_qoff_logitem_committing
  378. };
  379. /*
  380. * This is the ops vector shared by all quotaoff-start log items.
  381. */
  382. static const struct xfs_item_ops xfs_qm_qoff_logitem_ops = {
  383. .iop_size = xfs_qm_qoff_logitem_size,
  384. .iop_format = xfs_qm_qoff_logitem_format,
  385. .iop_pin = xfs_qm_qoff_logitem_pin,
  386. .iop_unpin = xfs_qm_qoff_logitem_unpin,
  387. .iop_unlock = xfs_qm_qoff_logitem_unlock,
  388. .iop_committed = xfs_qm_qoff_logitem_committed,
  389. .iop_push = xfs_qm_qoff_logitem_push,
  390. .iop_committing = xfs_qm_qoff_logitem_committing
  391. };
  392. /*
  393. * Allocate and initialize an quotaoff item of the correct quota type(s).
  394. */
  395. struct xfs_qoff_logitem *
  396. xfs_qm_qoff_logitem_init(
  397. struct xfs_mount *mp,
  398. struct xfs_qoff_logitem *start,
  399. uint flags)
  400. {
  401. struct xfs_qoff_logitem *qf;
  402. qf = kmem_zalloc(sizeof(struct xfs_qoff_logitem), KM_SLEEP);
  403. xfs_log_item_init(mp, &qf->qql_item, XFS_LI_QUOTAOFF, start ?
  404. &xfs_qm_qoffend_logitem_ops : &xfs_qm_qoff_logitem_ops);
  405. qf->qql_item.li_mountp = mp;
  406. qf->qql_format.qf_type = XFS_LI_QUOTAOFF;
  407. qf->qql_format.qf_flags = flags;
  408. qf->qql_start_lip = start;
  409. return qf;
  410. }