diff options
Diffstat (limited to 'fs/xfs/xfs_log.c')
| -rw-r--r-- | fs/xfs/xfs_log.c | 106 | 
1 files changed, 52 insertions, 54 deletions
| diff --git a/fs/xfs/xfs_log.c b/fs/xfs/xfs_log.c index 4f16be4b6ee5..e8fba92d7cd9 100644 --- a/fs/xfs/xfs_log.c +++ b/fs/xfs/xfs_log.c | |||
| @@ -60,7 +60,7 @@ STATIC int xlog_space_left(xlog_t *log, int cycle, int bytes); | |||
| 60 | STATIC int xlog_sync(xlog_t *log, xlog_in_core_t *iclog); | 60 | STATIC int xlog_sync(xlog_t *log, xlog_in_core_t *iclog); | 
| 61 | STATIC void xlog_dealloc_log(xlog_t *log); | 61 | STATIC void xlog_dealloc_log(xlog_t *log); | 
| 62 | STATIC int xlog_write(xfs_mount_t *mp, xfs_log_iovec_t region[], | 62 | STATIC int xlog_write(xfs_mount_t *mp, xfs_log_iovec_t region[], | 
| 63 | int nentries, xfs_log_ticket_t tic, | 63 | int nentries, struct xlog_ticket *tic, | 
| 64 | xfs_lsn_t *start_lsn, | 64 | xfs_lsn_t *start_lsn, | 
| 65 | xlog_in_core_t **commit_iclog, | 65 | xlog_in_core_t **commit_iclog, | 
| 66 | uint flags); | 66 | uint flags); | 
| @@ -243,14 +243,14 @@ xlog_tic_add_region(xlog_ticket_t *tic, uint len, uint type) | |||
| 243 | * out when the next write occurs. | 243 | * out when the next write occurs. | 
| 244 | */ | 244 | */ | 
| 245 | xfs_lsn_t | 245 | xfs_lsn_t | 
| 246 | xfs_log_done(xfs_mount_t *mp, | 246 | xfs_log_done( | 
| 247 | xfs_log_ticket_t xtic, | 247 | struct xfs_mount *mp, | 
| 248 | void **iclog, | 248 | struct xlog_ticket *ticket, | 
| 249 | uint flags) | 249 | struct xlog_in_core **iclog, | 
| 250 | uint flags) | ||
| 250 | { | 251 | { | 
| 251 | xlog_t *log = mp->m_log; | 252 | struct log *log = mp->m_log; | 
| 252 | xlog_ticket_t *ticket = (xfs_log_ticket_t) xtic; | 253 | xfs_lsn_t lsn = 0; | 
| 253 | xfs_lsn_t lsn = 0; | ||
| 254 | 254 | ||
| 255 | if (XLOG_FORCED_SHUTDOWN(log) || | 255 | if (XLOG_FORCED_SHUTDOWN(log) || | 
| 256 | /* | 256 | /* | 
| @@ -258,8 +258,7 @@ xfs_log_done(xfs_mount_t *mp, | |||
| 258 | * If we get an error, just continue and give back the log ticket. | 258 | * If we get an error, just continue and give back the log ticket. | 
| 259 | */ | 259 | */ | 
| 260 | (((ticket->t_flags & XLOG_TIC_INITED) == 0) && | 260 | (((ticket->t_flags & XLOG_TIC_INITED) == 0) && | 
| 261 | (xlog_commit_record(mp, ticket, | 261 | (xlog_commit_record(mp, ticket, iclog, &lsn)))) { | 
| 262 | (xlog_in_core_t **)iclog, &lsn)))) { | ||
| 263 | lsn = (xfs_lsn_t) -1; | 262 | lsn = (xfs_lsn_t) -1; | 
| 264 | if (ticket->t_flags & XLOG_TIC_PERM_RESERV) { | 263 | if (ticket->t_flags & XLOG_TIC_PERM_RESERV) { | 
| 265 | flags |= XFS_LOG_REL_PERM_RESERV; | 264 | flags |= XFS_LOG_REL_PERM_RESERV; | 
| @@ -289,7 +288,7 @@ xfs_log_done(xfs_mount_t *mp, | |||
| 289 | } | 288 | } | 
| 290 | 289 | ||
| 291 | return lsn; | 290 | return lsn; | 
| 292 | } /* xfs_log_done */ | 291 | } | 
| 293 | 292 | ||
| 294 | /* | 293 | /* | 
| 295 | * Attaches a new iclog I/O completion callback routine during | 294 | * Attaches a new iclog I/O completion callback routine during | 
| @@ -298,11 +297,11 @@ xfs_log_done(xfs_mount_t *mp, | |||
| 298 | * executing the callback at an appropriate time. | 297 | * executing the callback at an appropriate time. | 
| 299 | */ | 298 | */ | 
| 300 | int | 299 | int | 
| 301 | xfs_log_notify(xfs_mount_t *mp, /* mount of partition */ | 300 | xfs_log_notify( | 
| 302 | void *iclog_hndl, /* iclog to hang callback off */ | 301 | struct xfs_mount *mp, | 
| 303 | xfs_log_callback_t *cb) | 302 | struct xlog_in_core *iclog, | 
| 303 | xfs_log_callback_t *cb) | ||
| 304 | { | 304 | { | 
| 305 | xlog_in_core_t *iclog = (xlog_in_core_t *)iclog_hndl; | ||
| 306 | int abortflg; | 305 | int abortflg; | 
| 307 | 306 | ||
| 308 | spin_lock(&iclog->ic_callback_lock); | 307 | spin_lock(&iclog->ic_callback_lock); | 
| @@ -316,16 +315,14 @@ xfs_log_notify(xfs_mount_t *mp, /* mount of partition */ | |||
| 316 | } | 315 | } | 
| 317 | spin_unlock(&iclog->ic_callback_lock); | 316 | spin_unlock(&iclog->ic_callback_lock); | 
| 318 | return abortflg; | 317 | return abortflg; | 
| 319 | } /* xfs_log_notify */ | 318 | } | 
| 320 | 319 | ||
| 321 | int | 320 | int | 
| 322 | xfs_log_release_iclog(xfs_mount_t *mp, | 321 | xfs_log_release_iclog( | 
| 323 | void *iclog_hndl) | 322 | struct xfs_mount *mp, | 
| 323 | struct xlog_in_core *iclog) | ||
| 324 | { | 324 | { | 
| 325 | xlog_t *log = mp->m_log; | 325 | if (xlog_state_release_iclog(mp->m_log, iclog)) { | 
| 326 | xlog_in_core_t *iclog = (xlog_in_core_t *)iclog_hndl; | ||
| 327 | |||
| 328 | if (xlog_state_release_iclog(log, iclog)) { | ||
| 329 | xfs_force_shutdown(mp, SHUTDOWN_LOG_IO_ERROR); | 326 | xfs_force_shutdown(mp, SHUTDOWN_LOG_IO_ERROR); | 
| 330 | return EIO; | 327 | return EIO; | 
| 331 | } | 328 | } | 
| @@ -344,17 +341,18 @@ xfs_log_release_iclog(xfs_mount_t *mp, | |||
| 344 | * reservation, we prevent over allocation problems. | 341 | * reservation, we prevent over allocation problems. | 
| 345 | */ | 342 | */ | 
| 346 | int | 343 | int | 
| 347 | xfs_log_reserve(xfs_mount_t *mp, | 344 | xfs_log_reserve( | 
| 348 | int unit_bytes, | 345 | struct xfs_mount *mp, | 
| 349 | int cnt, | 346 | int unit_bytes, | 
| 350 | xfs_log_ticket_t *ticket, | 347 | int cnt, | 
| 351 | __uint8_t client, | 348 | struct xlog_ticket **ticket, | 
| 352 | uint flags, | 349 | __uint8_t client, | 
| 353 | uint t_type) | 350 | uint flags, | 
| 351 | uint t_type) | ||
| 354 | { | 352 | { | 
| 355 | xlog_t *log = mp->m_log; | 353 | struct log *log = mp->m_log; | 
| 356 | xlog_ticket_t *internal_ticket; | 354 | struct xlog_ticket *internal_ticket; | 
| 357 | int retval = 0; | 355 | int retval = 0; | 
| 358 | 356 | ||
| 359 | ASSERT(client == XFS_TRANSACTION || client == XFS_LOG); | 357 | ASSERT(client == XFS_TRANSACTION || client == XFS_LOG); | 
| 360 | ASSERT((flags & XFS_LOG_NOSLEEP) == 0); | 358 | ASSERT((flags & XFS_LOG_NOSLEEP) == 0); | 
| @@ -367,7 +365,7 @@ xfs_log_reserve(xfs_mount_t *mp, | |||
| 367 | 365 | ||
| 368 | if (*ticket != NULL) { | 366 | if (*ticket != NULL) { | 
| 369 | ASSERT(flags & XFS_LOG_PERM_RESERV); | 367 | ASSERT(flags & XFS_LOG_PERM_RESERV); | 
| 370 | internal_ticket = (xlog_ticket_t *)*ticket; | 368 | internal_ticket = *ticket; | 
| 371 | 369 | ||
| 372 | trace_xfs_log_reserve(log, internal_ticket); | 370 | trace_xfs_log_reserve(log, internal_ticket); | 
| 373 | 371 | ||
| @@ -519,7 +517,7 @@ xfs_log_unmount_write(xfs_mount_t *mp) | |||
| 519 | xlog_in_core_t *first_iclog; | 517 | xlog_in_core_t *first_iclog; | 
| 520 | #endif | 518 | #endif | 
| 521 | xfs_log_iovec_t reg[1]; | 519 | xfs_log_iovec_t reg[1]; | 
| 522 | xfs_log_ticket_t tic = NULL; | 520 | xlog_ticket_t *tic = NULL; | 
| 523 | xfs_lsn_t lsn; | 521 | xfs_lsn_t lsn; | 
| 524 | int error; | 522 | int error; | 
| 525 | 523 | ||
| @@ -656,24 +654,24 @@ xfs_log_unmount(xfs_mount_t *mp) | |||
| 656 | * transaction occur with one call to xfs_log_write(). | 654 | * transaction occur with one call to xfs_log_write(). | 
| 657 | */ | 655 | */ | 
| 658 | int | 656 | int | 
| 659 | xfs_log_write(xfs_mount_t * mp, | 657 | xfs_log_write( | 
| 660 | xfs_log_iovec_t reg[], | 658 | struct xfs_mount *mp, | 
| 661 | int nentries, | 659 | struct xfs_log_iovec reg[], | 
| 662 | xfs_log_ticket_t tic, | 660 | int nentries, | 
| 663 | xfs_lsn_t *start_lsn) | 661 | struct xlog_ticket *tic, | 
| 662 | xfs_lsn_t *start_lsn) | ||
| 664 | { | 663 | { | 
| 665 | int error; | 664 | struct log *log = mp->m_log; | 
| 666 | xlog_t *log = mp->m_log; | 665 | int error; | 
| 667 | 666 | ||
| 668 | if (XLOG_FORCED_SHUTDOWN(log)) | 667 | if (XLOG_FORCED_SHUTDOWN(log)) | 
| 669 | return XFS_ERROR(EIO); | 668 | return XFS_ERROR(EIO); | 
| 670 | 669 | ||
| 671 | if ((error = xlog_write(mp, reg, nentries, tic, start_lsn, NULL, 0))) { | 670 | error = xlog_write(mp, reg, nentries, tic, start_lsn, NULL, 0); | 
| 671 | if (error) | ||
| 672 | xfs_force_shutdown(mp, SHUTDOWN_LOG_IO_ERROR); | 672 | xfs_force_shutdown(mp, SHUTDOWN_LOG_IO_ERROR); | 
| 673 | } | ||
| 674 | return error; | 673 | return error; | 
| 675 | } /* xfs_log_write */ | 674 | } | 
| 676 | |||
| 677 | 675 | ||
| 678 | void | 676 | void | 
| 679 | xfs_log_move_tail(xfs_mount_t *mp, | 677 | xfs_log_move_tail(xfs_mount_t *mp, | 
| @@ -1642,16 +1640,16 @@ xlog_print_tic_res(xfs_mount_t *mp, xlog_ticket_t *ticket) | |||
| 1642 | * bytes have been written out. | 1640 | * bytes have been written out. | 
| 1643 | */ | 1641 | */ | 
| 1644 | STATIC int | 1642 | STATIC int | 
| 1645 | xlog_write(xfs_mount_t * mp, | 1643 | xlog_write( | 
| 1646 | xfs_log_iovec_t reg[], | 1644 | struct xfs_mount *mp, | 
| 1647 | int nentries, | 1645 | struct xfs_log_iovec reg[], | 
| 1648 | xfs_log_ticket_t tic, | 1646 | int nentries, | 
| 1649 | xfs_lsn_t *start_lsn, | 1647 | struct xlog_ticket *ticket, | 
| 1650 | xlog_in_core_t **commit_iclog, | 1648 | xfs_lsn_t *start_lsn, | 
| 1651 | uint flags) | 1649 | struct xlog_in_core **commit_iclog, | 
| 1650 | uint flags) | ||
| 1652 | { | 1651 | { | 
| 1653 | xlog_t *log = mp->m_log; | 1652 | xlog_t *log = mp->m_log; | 
| 1654 | xlog_ticket_t *ticket = (xlog_ticket_t *)tic; | ||
| 1655 | xlog_in_core_t *iclog = NULL; /* ptr to current in-core log */ | 1653 | xlog_in_core_t *iclog = NULL; /* ptr to current in-core log */ | 
| 1656 | xlog_op_header_t *logop_head; /* ptr to log operation header */ | 1654 | xlog_op_header_t *logop_head; /* ptr to log operation header */ | 
| 1657 | __psint_t ptr; /* copy address into data region */ | 1655 | __psint_t ptr; /* copy address into data region */ | 
| @@ -1765,7 +1763,7 @@ xlog_write(xfs_mount_t * mp, | |||
| 1765 | default: | 1763 | default: | 
| 1766 | xfs_fs_cmn_err(CE_WARN, mp, | 1764 | xfs_fs_cmn_err(CE_WARN, mp, | 
| 1767 | "Bad XFS transaction clientid 0x%x in ticket 0x%p", | 1765 | "Bad XFS transaction clientid 0x%x in ticket 0x%p", | 
| 1768 | logop_head->oh_clientid, tic); | 1766 | logop_head->oh_clientid, ticket); | 
| 1769 | return XFS_ERROR(EIO); | 1767 | return XFS_ERROR(EIO); | 
| 1770 | } | 1768 | } | 
| 1771 | 1769 | ||
