xfs_dquot_item.c 11 KB

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