xfs_dquot_item.c 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701
  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_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_dir.h"
  27. #include "xfs_dir2.h"
  28. #include "xfs_alloc.h"
  29. #include "xfs_dmapi.h"
  30. #include "xfs_quota.h"
  31. #include "xfs_mount.h"
  32. #include "xfs_bmap_btree.h"
  33. #include "xfs_alloc_btree.h"
  34. #include "xfs_ialloc_btree.h"
  35. #include "xfs_dir_sf.h"
  36. #include "xfs_dir2_sf.h"
  37. #include "xfs_attr_sf.h"
  38. #include "xfs_dinode.h"
  39. #include "xfs_inode.h"
  40. #include "xfs_bmap.h"
  41. #include "xfs_btree.h"
  42. #include "xfs_ialloc.h"
  43. #include "xfs_rtalloc.h"
  44. #include "xfs_error.h"
  45. #include "xfs_itable.h"
  46. #include "xfs_rw.h"
  47. #include "xfs_acl.h"
  48. #include "xfs_cap.h"
  49. #include "xfs_mac.h"
  50. #include "xfs_attr.h"
  51. #include "xfs_buf_item.h"
  52. #include "xfs_trans_priv.h"
  53. #include "xfs_qm.h"
  54. /*
  55. * returns the number of iovecs needed to log the given dquot item.
  56. */
  57. /* ARGSUSED */
  58. STATIC uint
  59. xfs_qm_dquot_logitem_size(
  60. xfs_dq_logitem_t *logitem)
  61. {
  62. /*
  63. * we need only two iovecs, one for the format, one for the real thing
  64. */
  65. return (2);
  66. }
  67. /*
  68. * fills in the vector of log iovecs for the given dquot log item.
  69. */
  70. STATIC void
  71. xfs_qm_dquot_logitem_format(
  72. xfs_dq_logitem_t *logitem,
  73. xfs_log_iovec_t *logvec)
  74. {
  75. ASSERT(logitem);
  76. ASSERT(logitem->qli_dquot);
  77. logvec->i_addr = (xfs_caddr_t)&logitem->qli_format;
  78. logvec->i_len = sizeof(xfs_dq_logformat_t);
  79. XLOG_VEC_SET_TYPE(logvec, XLOG_REG_TYPE_QFORMAT);
  80. logvec++;
  81. logvec->i_addr = (xfs_caddr_t)&logitem->qli_dquot->q_core;
  82. logvec->i_len = sizeof(xfs_disk_dquot_t);
  83. XLOG_VEC_SET_TYPE(logvec, XLOG_REG_TYPE_DQUOT);
  84. ASSERT(2 == logitem->qli_item.li_desc->lid_size);
  85. logitem->qli_format.qlf_size = 2;
  86. }
  87. /*
  88. * Increment the pin count of the given dquot.
  89. * This value is protected by pinlock spinlock in the xQM structure.
  90. */
  91. STATIC void
  92. xfs_qm_dquot_logitem_pin(
  93. xfs_dq_logitem_t *logitem)
  94. {
  95. unsigned long s;
  96. xfs_dquot_t *dqp;
  97. dqp = logitem->qli_dquot;
  98. ASSERT(XFS_DQ_IS_LOCKED(dqp));
  99. s = XFS_DQ_PINLOCK(dqp);
  100. dqp->q_pincount++;
  101. XFS_DQ_PINUNLOCK(dqp, s);
  102. }
  103. /*
  104. * Decrement the pin count of the given dquot, and wake up
  105. * anyone in xfs_dqwait_unpin() if the count goes to 0. The
  106. * dquot must have been previously pinned with a call to xfs_dqpin().
  107. */
  108. /* ARGSUSED */
  109. STATIC void
  110. xfs_qm_dquot_logitem_unpin(
  111. xfs_dq_logitem_t *logitem,
  112. int stale)
  113. {
  114. unsigned long s;
  115. xfs_dquot_t *dqp;
  116. dqp = logitem->qli_dquot;
  117. ASSERT(dqp->q_pincount > 0);
  118. s = XFS_DQ_PINLOCK(dqp);
  119. dqp->q_pincount--;
  120. if (dqp->q_pincount == 0) {
  121. sv_broadcast(&dqp->q_pinwait);
  122. }
  123. XFS_DQ_PINUNLOCK(dqp, s);
  124. }
  125. /* ARGSUSED */
  126. STATIC void
  127. xfs_qm_dquot_logitem_unpin_remove(
  128. xfs_dq_logitem_t *logitem,
  129. xfs_trans_t *tp)
  130. {
  131. xfs_qm_dquot_logitem_unpin(logitem, 0);
  132. }
  133. /*
  134. * Given the logitem, this writes the corresponding dquot entry to disk
  135. * asynchronously. This is called with the dquot entry securely locked;
  136. * we simply get xfs_qm_dqflush() to do the work, and unlock the dquot
  137. * at the end.
  138. */
  139. STATIC void
  140. xfs_qm_dquot_logitem_push(
  141. xfs_dq_logitem_t *logitem)
  142. {
  143. xfs_dquot_t *dqp;
  144. dqp = logitem->qli_dquot;
  145. ASSERT(XFS_DQ_IS_LOCKED(dqp));
  146. ASSERT(XFS_DQ_IS_FLUSH_LOCKED(dqp));
  147. /*
  148. * Since we were able to lock the dquot's flush lock and
  149. * we found it on the AIL, the dquot must be dirty. This
  150. * is because the dquot is removed from the AIL while still
  151. * holding the flush lock in xfs_dqflush_done(). Thus, if
  152. * we found it in the AIL and were able to obtain the flush
  153. * lock without sleeping, then there must not have been
  154. * anyone in the process of flushing the dquot.
  155. */
  156. xfs_qm_dqflush(dqp, XFS_B_DELWRI);
  157. xfs_dqunlock(dqp);
  158. }
  159. /*ARGSUSED*/
  160. STATIC xfs_lsn_t
  161. xfs_qm_dquot_logitem_committed(
  162. xfs_dq_logitem_t *l,
  163. xfs_lsn_t lsn)
  164. {
  165. /*
  166. * We always re-log the entire dquot when it becomes dirty,
  167. * so, the latest copy _is_ the only one that matters.
  168. */
  169. return (lsn);
  170. }
  171. /*
  172. * This is called to wait for the given dquot to be unpinned.
  173. * Most of these pin/unpin routines are plagiarized from inode code.
  174. */
  175. void
  176. xfs_qm_dqunpin_wait(
  177. xfs_dquot_t *dqp)
  178. {
  179. SPLDECL(s);
  180. ASSERT(XFS_DQ_IS_LOCKED(dqp));
  181. if (dqp->q_pincount == 0) {
  182. return;
  183. }
  184. /*
  185. * Give the log a push so we don't wait here too long.
  186. */
  187. xfs_log_force(dqp->q_mount, (xfs_lsn_t)0, XFS_LOG_FORCE);
  188. s = XFS_DQ_PINLOCK(dqp);
  189. if (dqp->q_pincount == 0) {
  190. XFS_DQ_PINUNLOCK(dqp, s);
  191. return;
  192. }
  193. sv_wait(&(dqp->q_pinwait), PINOD,
  194. &(XFS_DQ_TO_QINF(dqp)->qi_pinlock), s);
  195. }
  196. /*
  197. * This is called when IOP_TRYLOCK returns XFS_ITEM_PUSHBUF to indicate that
  198. * the dquot is locked by us, but the flush lock isn't. So, here we are
  199. * going to see if the relevant dquot buffer is incore, waiting on DELWRI.
  200. * If so, we want to push it out to help us take this item off the AIL as soon
  201. * as possible.
  202. *
  203. * We must not be holding the AIL_LOCK at this point. Calling incore() to
  204. * search the buffer cache can be a time consuming thing, and AIL_LOCK is a
  205. * spinlock.
  206. */
  207. STATIC void
  208. xfs_qm_dquot_logitem_pushbuf(
  209. xfs_dq_logitem_t *qip)
  210. {
  211. xfs_dquot_t *dqp;
  212. xfs_mount_t *mp;
  213. xfs_buf_t *bp;
  214. uint dopush;
  215. dqp = qip->qli_dquot;
  216. ASSERT(XFS_DQ_IS_LOCKED(dqp));
  217. /*
  218. * The qli_pushbuf_flag keeps others from
  219. * trying to duplicate our effort.
  220. */
  221. ASSERT(qip->qli_pushbuf_flag != 0);
  222. ASSERT(qip->qli_push_owner == current_pid());
  223. /*
  224. * If flushlock isn't locked anymore, chances are that the
  225. * inode flush completed and the inode was taken off the AIL.
  226. * So, just get out.
  227. */
  228. if ((valusema(&(dqp->q_flock)) > 0) ||
  229. ((qip->qli_item.li_flags & XFS_LI_IN_AIL) == 0)) {
  230. qip->qli_pushbuf_flag = 0;
  231. xfs_dqunlock(dqp);
  232. return;
  233. }
  234. mp = dqp->q_mount;
  235. bp = xfs_incore(mp->m_ddev_targp, qip->qli_format.qlf_blkno,
  236. XFS_QI_DQCHUNKLEN(mp),
  237. XFS_INCORE_TRYLOCK);
  238. if (bp != NULL) {
  239. if (XFS_BUF_ISDELAYWRITE(bp)) {
  240. dopush = ((qip->qli_item.li_flags & XFS_LI_IN_AIL) &&
  241. (valusema(&(dqp->q_flock)) <= 0));
  242. qip->qli_pushbuf_flag = 0;
  243. xfs_dqunlock(dqp);
  244. if (XFS_BUF_ISPINNED(bp)) {
  245. xfs_log_force(mp, (xfs_lsn_t)0,
  246. XFS_LOG_FORCE);
  247. }
  248. if (dopush) {
  249. #ifdef XFSRACEDEBUG
  250. delay_for_intr();
  251. delay(300);
  252. #endif
  253. xfs_bawrite(mp, bp);
  254. } else {
  255. xfs_buf_relse(bp);
  256. }
  257. } else {
  258. qip->qli_pushbuf_flag = 0;
  259. xfs_dqunlock(dqp);
  260. xfs_buf_relse(bp);
  261. }
  262. return;
  263. }
  264. qip->qli_pushbuf_flag = 0;
  265. xfs_dqunlock(dqp);
  266. }
  267. /*
  268. * This is called to attempt to lock the dquot associated with this
  269. * dquot log item. Don't sleep on the dquot lock or the flush lock.
  270. * If the flush lock is already held, indicating that the dquot has
  271. * been or is in the process of being flushed, then see if we can
  272. * find the dquot's buffer in the buffer cache without sleeping. If
  273. * we can and it is marked delayed write, then we want to send it out.
  274. * We delay doing so until the push routine, though, to avoid sleeping
  275. * in any device strategy routines.
  276. */
  277. STATIC uint
  278. xfs_qm_dquot_logitem_trylock(
  279. xfs_dq_logitem_t *qip)
  280. {
  281. xfs_dquot_t *dqp;
  282. uint retval;
  283. dqp = qip->qli_dquot;
  284. if (dqp->q_pincount > 0)
  285. return (XFS_ITEM_PINNED);
  286. if (! xfs_qm_dqlock_nowait(dqp))
  287. return (XFS_ITEM_LOCKED);
  288. retval = XFS_ITEM_SUCCESS;
  289. if (! xfs_qm_dqflock_nowait(dqp)) {
  290. /*
  291. * The dquot is already being flushed. It may have been
  292. * flushed delayed write, however, and we don't want to
  293. * get stuck waiting for that to complete. So, we want to check
  294. * to see if we can lock the dquot's buffer without sleeping.
  295. * If we can and it is marked for delayed write, then we
  296. * hold it and send it out from the push routine. We don't
  297. * want to do that now since we might sleep in the device
  298. * strategy routine. We also don't want to grab the buffer lock
  299. * here because we'd like not to call into the buffer cache
  300. * while holding the AIL_LOCK.
  301. * Make sure to only return PUSHBUF if we set pushbuf_flag
  302. * ourselves. If someone else is doing it then we don't
  303. * want to go to the push routine and duplicate their efforts.
  304. */
  305. if (qip->qli_pushbuf_flag == 0) {
  306. qip->qli_pushbuf_flag = 1;
  307. ASSERT(qip->qli_format.qlf_blkno == dqp->q_blkno);
  308. #ifdef DEBUG
  309. qip->qli_push_owner = current_pid();
  310. #endif
  311. /*
  312. * The dquot is left locked.
  313. */
  314. retval = XFS_ITEM_PUSHBUF;
  315. } else {
  316. retval = XFS_ITEM_FLUSHING;
  317. xfs_dqunlock_nonotify(dqp);
  318. }
  319. }
  320. ASSERT(qip->qli_item.li_flags & XFS_LI_IN_AIL);
  321. return (retval);
  322. }
  323. /*
  324. * Unlock the dquot associated with the log item.
  325. * Clear the fields of the dquot and dquot log item that
  326. * are specific to the current transaction. If the
  327. * hold flags is set, do not unlock the dquot.
  328. */
  329. STATIC void
  330. xfs_qm_dquot_logitem_unlock(
  331. xfs_dq_logitem_t *ql)
  332. {
  333. xfs_dquot_t *dqp;
  334. ASSERT(ql != NULL);
  335. dqp = ql->qli_dquot;
  336. ASSERT(XFS_DQ_IS_LOCKED(dqp));
  337. /*
  338. * Clear the transaction pointer in the dquot
  339. */
  340. dqp->q_transp = NULL;
  341. /*
  342. * dquots are never 'held' from getting unlocked at the end of
  343. * a transaction. Their locking and unlocking is hidden inside the
  344. * transaction layer, within trans_commit. Hence, no LI_HOLD flag
  345. * for the logitem.
  346. */
  347. xfs_dqunlock(dqp);
  348. }
  349. /*
  350. * The transaction with the dquot locked has aborted. The dquot
  351. * must not be dirty within the transaction. We simply unlock just
  352. * as if the transaction had been cancelled.
  353. */
  354. STATIC void
  355. xfs_qm_dquot_logitem_abort(
  356. xfs_dq_logitem_t *ql)
  357. {
  358. xfs_qm_dquot_logitem_unlock(ql);
  359. }
  360. /*
  361. * this needs to stamp an lsn into the dquot, I think.
  362. * rpc's that look at user dquot's would then have to
  363. * push on the dependency recorded in the dquot
  364. */
  365. /* ARGSUSED */
  366. STATIC void
  367. xfs_qm_dquot_logitem_committing(
  368. xfs_dq_logitem_t *l,
  369. xfs_lsn_t lsn)
  370. {
  371. return;
  372. }
  373. /*
  374. * This is the ops vector for dquots
  375. */
  376. STATIC struct xfs_item_ops xfs_dquot_item_ops = {
  377. .iop_size = (uint(*)(xfs_log_item_t*))xfs_qm_dquot_logitem_size,
  378. .iop_format = (void(*)(xfs_log_item_t*, xfs_log_iovec_t*))
  379. xfs_qm_dquot_logitem_format,
  380. .iop_pin = (void(*)(xfs_log_item_t*))xfs_qm_dquot_logitem_pin,
  381. .iop_unpin = (void(*)(xfs_log_item_t*, int))
  382. xfs_qm_dquot_logitem_unpin,
  383. .iop_unpin_remove = (void(*)(xfs_log_item_t*, xfs_trans_t*))
  384. xfs_qm_dquot_logitem_unpin_remove,
  385. .iop_trylock = (uint(*)(xfs_log_item_t*))
  386. xfs_qm_dquot_logitem_trylock,
  387. .iop_unlock = (void(*)(xfs_log_item_t*))xfs_qm_dquot_logitem_unlock,
  388. .iop_committed = (xfs_lsn_t(*)(xfs_log_item_t*, xfs_lsn_t))
  389. xfs_qm_dquot_logitem_committed,
  390. .iop_push = (void(*)(xfs_log_item_t*))xfs_qm_dquot_logitem_push,
  391. .iop_abort = (void(*)(xfs_log_item_t*))xfs_qm_dquot_logitem_abort,
  392. .iop_pushbuf = (void(*)(xfs_log_item_t*))
  393. xfs_qm_dquot_logitem_pushbuf,
  394. .iop_committing = (void(*)(xfs_log_item_t*, xfs_lsn_t))
  395. xfs_qm_dquot_logitem_committing
  396. };
  397. /*
  398. * Initialize the dquot log item for a newly allocated dquot.
  399. * The dquot isn't locked at this point, but it isn't on any of the lists
  400. * either, so we don't care.
  401. */
  402. void
  403. xfs_qm_dquot_logitem_init(
  404. struct xfs_dquot *dqp)
  405. {
  406. xfs_dq_logitem_t *lp;
  407. lp = &dqp->q_logitem;
  408. lp->qli_item.li_type = XFS_LI_DQUOT;
  409. lp->qli_item.li_ops = &xfs_dquot_item_ops;
  410. lp->qli_item.li_mountp = dqp->q_mount;
  411. lp->qli_dquot = dqp;
  412. lp->qli_format.qlf_type = XFS_LI_DQUOT;
  413. lp->qli_format.qlf_id = be32_to_cpu(dqp->q_core.d_id);
  414. lp->qli_format.qlf_blkno = dqp->q_blkno;
  415. lp->qli_format.qlf_len = 1;
  416. /*
  417. * This is just the offset of this dquot within its buffer
  418. * (which is currently 1 FSB and probably won't change).
  419. * Hence 32 bits for this offset should be just fine.
  420. * Alternatively, we can store (bufoffset / sizeof(xfs_dqblk_t))
  421. * here, and recompute it at recovery time.
  422. */
  423. lp->qli_format.qlf_boffset = (__uint32_t)dqp->q_bufoffset;
  424. }
  425. /*------------------ QUOTAOFF LOG ITEMS -------------------*/
  426. /*
  427. * This returns the number of iovecs needed to log the given quotaoff item.
  428. * We only need 1 iovec for an quotaoff item. It just logs the
  429. * quotaoff_log_format structure.
  430. */
  431. /*ARGSUSED*/
  432. STATIC uint
  433. xfs_qm_qoff_logitem_size(xfs_qoff_logitem_t *qf)
  434. {
  435. return (1);
  436. }
  437. /*
  438. * This is called to fill in the vector of log iovecs for the
  439. * given quotaoff log item. We use only 1 iovec, and we point that
  440. * at the quotaoff_log_format structure embedded in the quotaoff item.
  441. * It is at this point that we assert that all of the extent
  442. * slots in the quotaoff item have been filled.
  443. */
  444. STATIC void
  445. xfs_qm_qoff_logitem_format(xfs_qoff_logitem_t *qf,
  446. xfs_log_iovec_t *log_vector)
  447. {
  448. ASSERT(qf->qql_format.qf_type == XFS_LI_QUOTAOFF);
  449. log_vector->i_addr = (xfs_caddr_t)&(qf->qql_format);
  450. log_vector->i_len = sizeof(xfs_qoff_logitem_t);
  451. XLOG_VEC_SET_TYPE(log_vector, XLOG_REG_TYPE_QUOTAOFF);
  452. qf->qql_format.qf_size = 1;
  453. }
  454. /*
  455. * Pinning has no meaning for an quotaoff item, so just return.
  456. */
  457. /*ARGSUSED*/
  458. STATIC void
  459. xfs_qm_qoff_logitem_pin(xfs_qoff_logitem_t *qf)
  460. {
  461. return;
  462. }
  463. /*
  464. * Since pinning has no meaning for an quotaoff item, unpinning does
  465. * not either.
  466. */
  467. /*ARGSUSED*/
  468. STATIC void
  469. xfs_qm_qoff_logitem_unpin(xfs_qoff_logitem_t *qf, int stale)
  470. {
  471. return;
  472. }
  473. /*ARGSUSED*/
  474. STATIC void
  475. xfs_qm_qoff_logitem_unpin_remove(xfs_qoff_logitem_t *qf, xfs_trans_t *tp)
  476. {
  477. return;
  478. }
  479. /*
  480. * Quotaoff items have no locking, so just return success.
  481. */
  482. /*ARGSUSED*/
  483. STATIC uint
  484. xfs_qm_qoff_logitem_trylock(xfs_qoff_logitem_t *qf)
  485. {
  486. return XFS_ITEM_LOCKED;
  487. }
  488. /*
  489. * Quotaoff items have no locking or pushing, so return failure
  490. * so that the caller doesn't bother with us.
  491. */
  492. /*ARGSUSED*/
  493. STATIC void
  494. xfs_qm_qoff_logitem_unlock(xfs_qoff_logitem_t *qf)
  495. {
  496. return;
  497. }
  498. /*
  499. * The quotaoff-start-item is logged only once and cannot be moved in the log,
  500. * so simply return the lsn at which it's been logged.
  501. */
  502. /*ARGSUSED*/
  503. STATIC xfs_lsn_t
  504. xfs_qm_qoff_logitem_committed(xfs_qoff_logitem_t *qf, xfs_lsn_t lsn)
  505. {
  506. return (lsn);
  507. }
  508. /*
  509. * The transaction of which this QUOTAOFF is a part has been aborted.
  510. * Just clean up after ourselves.
  511. * Shouldn't this never happen in the case of qoffend logitems? XXX
  512. */
  513. STATIC void
  514. xfs_qm_qoff_logitem_abort(xfs_qoff_logitem_t *qf)
  515. {
  516. kmem_free(qf, sizeof(xfs_qoff_logitem_t));
  517. }
  518. /*
  519. * There isn't much you can do to push on an quotaoff item. It is simply
  520. * stuck waiting for the log to be flushed to disk.
  521. */
  522. /*ARGSUSED*/
  523. STATIC void
  524. xfs_qm_qoff_logitem_push(xfs_qoff_logitem_t *qf)
  525. {
  526. return;
  527. }
  528. /*ARGSUSED*/
  529. STATIC xfs_lsn_t
  530. xfs_qm_qoffend_logitem_committed(
  531. xfs_qoff_logitem_t *qfe,
  532. xfs_lsn_t lsn)
  533. {
  534. xfs_qoff_logitem_t *qfs;
  535. SPLDECL(s);
  536. qfs = qfe->qql_start_lip;
  537. AIL_LOCK(qfs->qql_item.li_mountp,s);
  538. /*
  539. * Delete the qoff-start logitem from the AIL.
  540. * xfs_trans_delete_ail() drops the AIL lock.
  541. */
  542. xfs_trans_delete_ail(qfs->qql_item.li_mountp, (xfs_log_item_t *)qfs, s);
  543. kmem_free(qfs, sizeof(xfs_qoff_logitem_t));
  544. kmem_free(qfe, sizeof(xfs_qoff_logitem_t));
  545. return (xfs_lsn_t)-1;
  546. }
  547. /*
  548. * XXX rcc - don't know quite what to do with this. I think we can
  549. * just ignore it. The only time that isn't the case is if we allow
  550. * the client to somehow see that quotas have been turned off in which
  551. * we can't allow that to get back until the quotaoff hits the disk.
  552. * So how would that happen? Also, do we need different routines for
  553. * quotaoff start and quotaoff end? I suspect the answer is yes but
  554. * to be sure, I need to look at the recovery code and see how quota off
  555. * recovery is handled (do we roll forward or back or do something else).
  556. * If we roll forwards or backwards, then we need two separate routines,
  557. * one that does nothing and one that stamps in the lsn that matters
  558. * (truly makes the quotaoff irrevocable). If we do something else,
  559. * then maybe we don't need two.
  560. */
  561. /* ARGSUSED */
  562. STATIC void
  563. xfs_qm_qoff_logitem_committing(xfs_qoff_logitem_t *qip, xfs_lsn_t commit_lsn)
  564. {
  565. return;
  566. }
  567. /* ARGSUSED */
  568. STATIC void
  569. xfs_qm_qoffend_logitem_committing(xfs_qoff_logitem_t *qip, xfs_lsn_t commit_lsn)
  570. {
  571. return;
  572. }
  573. STATIC struct xfs_item_ops xfs_qm_qoffend_logitem_ops = {
  574. .iop_size = (uint(*)(xfs_log_item_t*))xfs_qm_qoff_logitem_size,
  575. .iop_format = (void(*)(xfs_log_item_t*, xfs_log_iovec_t*))
  576. xfs_qm_qoff_logitem_format,
  577. .iop_pin = (void(*)(xfs_log_item_t*))xfs_qm_qoff_logitem_pin,
  578. .iop_unpin = (void(*)(xfs_log_item_t* ,int))
  579. xfs_qm_qoff_logitem_unpin,
  580. .iop_unpin_remove = (void(*)(xfs_log_item_t*,xfs_trans_t*))
  581. xfs_qm_qoff_logitem_unpin_remove,
  582. .iop_trylock = (uint(*)(xfs_log_item_t*))xfs_qm_qoff_logitem_trylock,
  583. .iop_unlock = (void(*)(xfs_log_item_t*))xfs_qm_qoff_logitem_unlock,
  584. .iop_committed = (xfs_lsn_t(*)(xfs_log_item_t*, xfs_lsn_t))
  585. xfs_qm_qoffend_logitem_committed,
  586. .iop_push = (void(*)(xfs_log_item_t*))xfs_qm_qoff_logitem_push,
  587. .iop_abort = (void(*)(xfs_log_item_t*))xfs_qm_qoff_logitem_abort,
  588. .iop_pushbuf = NULL,
  589. .iop_committing = (void(*)(xfs_log_item_t*, xfs_lsn_t))
  590. xfs_qm_qoffend_logitem_committing
  591. };
  592. /*
  593. * This is the ops vector shared by all quotaoff-start log items.
  594. */
  595. STATIC struct xfs_item_ops xfs_qm_qoff_logitem_ops = {
  596. .iop_size = (uint(*)(xfs_log_item_t*))xfs_qm_qoff_logitem_size,
  597. .iop_format = (void(*)(xfs_log_item_t*, xfs_log_iovec_t*))
  598. xfs_qm_qoff_logitem_format,
  599. .iop_pin = (void(*)(xfs_log_item_t*))xfs_qm_qoff_logitem_pin,
  600. .iop_unpin = (void(*)(xfs_log_item_t*, int))
  601. xfs_qm_qoff_logitem_unpin,
  602. .iop_unpin_remove = (void(*)(xfs_log_item_t*,xfs_trans_t*))
  603. xfs_qm_qoff_logitem_unpin_remove,
  604. .iop_trylock = (uint(*)(xfs_log_item_t*))xfs_qm_qoff_logitem_trylock,
  605. .iop_unlock = (void(*)(xfs_log_item_t*))xfs_qm_qoff_logitem_unlock,
  606. .iop_committed = (xfs_lsn_t(*)(xfs_log_item_t*, xfs_lsn_t))
  607. xfs_qm_qoff_logitem_committed,
  608. .iop_push = (void(*)(xfs_log_item_t*))xfs_qm_qoff_logitem_push,
  609. .iop_abort = (void(*)(xfs_log_item_t*))xfs_qm_qoff_logitem_abort,
  610. .iop_pushbuf = NULL,
  611. .iop_committing = (void(*)(xfs_log_item_t*, xfs_lsn_t))
  612. xfs_qm_qoff_logitem_committing
  613. };
  614. /*
  615. * Allocate and initialize an quotaoff item of the correct quota type(s).
  616. */
  617. xfs_qoff_logitem_t *
  618. xfs_qm_qoff_logitem_init(
  619. struct xfs_mount *mp,
  620. xfs_qoff_logitem_t *start,
  621. uint flags)
  622. {
  623. xfs_qoff_logitem_t *qf;
  624. qf = (xfs_qoff_logitem_t*) kmem_zalloc(sizeof(xfs_qoff_logitem_t), KM_SLEEP);
  625. qf->qql_item.li_type = XFS_LI_QUOTAOFF;
  626. if (start)
  627. qf->qql_item.li_ops = &xfs_qm_qoffend_logitem_ops;
  628. else
  629. qf->qql_item.li_ops = &xfs_qm_qoff_logitem_ops;
  630. qf->qql_item.li_mountp = mp;
  631. qf->qql_format.qf_type = XFS_LI_QUOTAOFF;
  632. qf->qql_format.qf_flags = flags;
  633. qf->qql_start_lip = start;
  634. return (qf);
  635. }