Lines Matching defs:lr
284 char *lr = (char *)(zilc + 1);
292 *begin = lr;
293 *end = lr + zilc->zc_nused - sizeof (*zilc);
297 char *lr = (*abuf)->b_data;
298 zil_chain_t *zilc = (zil_chain_t *)(lr + size) - 1;
305 *begin = lr;
306 *end = lr + zilc->zc_nused;
319 zil_read_log_data(zilog_t *zilog, const lr_write_t *lr, void *wbuf)
322 const blkptr_t *bp = &lr->lr_blkptr;
330 memset(wbuf, 0, MAX(BP_GET_LSIZE(bp), lr->lr_length));
346 SET_BOOKMARK(&zb, dmu_objset_id(zilog->zl_os), lr->lr_foid,
347 ZB_ZIL_LEVEL, lr->lr_offset / BP_GET_LSIZE(bp));
529 lr_t *lr = (lr_t *)lrp;
535 if ((char *)(lr + 1) > end) {
541 reclen = lr->lrc_reclen;
550 if (lr->lrc_seq > claim_lr_seq) {
555 error = parse_lr_func(zilog, lr, arg, txg);
560 ASSERT3U(max_lr_seq, <, lr->lrc_seq);
561 max_lr_seq = lr->lrc_seq;
629 lr_write_t *lr = (lr_write_t *)lrc;
632 ASSERT3U(lrc->lrc_reclen, >=, sizeof (*lr));
642 if (BP_GET_LOGICAL_BIRTH(&lr->lr_blkptr) >= first_txg) {
643 error = zil_read_log_data(zilog, lr, NULL);
648 return (zil_claim_log_block(zilog, &lr->lr_blkptr, tx, first_txg));
655 const lr_clone_range_t *lr = (const lr_clone_range_t *)lrc;
660 ASSERT3U(lrc->lrc_reclen, >=, sizeof (*lr));
662 lr_bps[lr->lr_nbps]));
669 * XXX: Do we need to byteswap lr?
672 for (ii = 0; ii < lr->lr_nbps; ii++) {
673 bp = &lr->lr_bps[ii];
698 for (ii = 0; ii < lr->lr_nbps; ii++) {
699 bp = &lr->lr_bps[ii];
736 lr_write_t *lr = (lr_write_t *)lrc;
737 blkptr_t *bp = &lr->lr_blkptr;
739 ASSERT3U(lrc->lrc_reclen, >=, sizeof (*lr));
755 const lr_clone_range_t *lr = (const lr_clone_range_t *)lrc;
760 ASSERT3U(lrc->lrc_reclen, >=, sizeof (*lr));
762 lr_bps[lr->lr_nbps]));
770 for (ii = 0; ii < lr->lr_nbps; ii++) {
771 bp = &lr->lr_bps[ii];
2103 lr_t *lr = &itx->itx_lr;
2105 if (lr->lrc_txtype == TX_COMMIT)
2107 ASSERT3U(lr->lrc_reclen, >=, sizeof (lr_t));
2108 return (lr->lrc_reclen);
2114 lr_t *lr = &itx->itx_lr;
2115 lr_write_t *lrw = (lr_write_t *)lr;
2117 if (lr->lrc_txtype == TX_WRITE && itx->itx_wr_state == WR_NEED_COPY) {
2118 ASSERT3U(lr->lrc_reclen, ==, sizeof (lr_write_t));
2128 lr_t *lr = &itx->itx_lr;
2130 if (lr->lrc_txtype == TX_COMMIT)
2132 ASSERT3U(lr->lrc_reclen, >=, sizeof (lr_t));
2133 return (lr->lrc_reclen + zil_itx_data_size(itx));
2146 lr_t *lr, *clr;
2156 lr = &itx->itx_lr;
2157 lrw = (lr_write_t *)lr;
2171 if (lr->lrc_txtype == TX_COMMIT) {
2177 reclen = lr->lrc_reclen;
2213 ASSERT3U(lr->lrc_txtype, ==, TX_WRITE);
2224 clr = lr;
2239 zil_lwb_add_txg(lwb, lr->lrc_txg);
2246 if (lr->lrc_txtype == TX_WRITE &&
2247 lr->lrc_txg > spa_freeze_txg(zilog->zl_spa))
2248 txg_wait_synced(zilog->zl_dmu_pool, lr->lrc_txg);
2260 lr_t *lr, *lrb;
2265 lr = &itx->itx_lr;
2266 lrw = (lr_write_t *)lr;
2268 if (lr->lrc_txtype == TX_COMMIT)
2271 reclen = lr->lrc_reclen;
2276 memcpy(lr_buf, lr, reclen);
2277 lrb = (lr_t *)lr_buf; /* Like lr, but inside lwb. */
2285 if (lr->lrc_txtype == TX_WRITE) {
2357 lr->lrc_txg);
4192 zil_replay_error(zilog_t *zilog, const lr_t *lr, int error)
4202 (u_longlong_t)lr->lrc_seq,
4203 (u_longlong_t)(lr->lrc_txtype & ~TX_CI),
4204 (lr->lrc_txtype & TX_CI) ? "CI" : "");
4210 zil_replay_log_record(zilog_t *zilog, const lr_t *lr, void *zra,
4215 uint64_t reclen = lr->lrc_reclen;
4216 uint64_t txtype = lr->lrc_txtype;
4219 zilog->zl_replaying_seq = lr->lrc_seq;
4221 if (lr->lrc_seq <= zh->zh_replay_seq) /* already replayed */
4224 if (lr->lrc_txg < claim_txg) /* already committed */
4231 return (zil_replay_error(zilog, lr, EINVAL));
4239 LR_FOID_GET_OBJ(((lr_ooo_t *)lr)->lr_foid), NULL);
4247 memcpy(zr->zr_lr, lr, reclen);
4253 error = zil_read_log_data(zilog, (lr_write_t *)lr,
4256 return (zil_replay_error(zilog, lr, error));
4260 * The log block containing this lr may have been byteswapped
4264 * the lr was byteswapped, undo it before invoking the replay vector.
4287 return (zil_replay_error(zilog, lr, error));