^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 1) // SPDX-License-Identifier: GPL-2.0+
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 2) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 3) * segbuf.c - NILFS segment buffer
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 4) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 5) * Copyright (C) 2005-2008 Nippon Telegraph and Telephone Corporation.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 6) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 7) * Written by Ryusuke Konishi.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 8) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 9) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 10)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 11) #include <linux/buffer_head.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 12) #include <linux/writeback.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 13) #include <linux/crc32.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 14) #include <linux/backing-dev.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 15) #include <linux/slab.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 16) #include "page.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 17) #include "segbuf.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 18)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 19)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 20) struct nilfs_write_info {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 21) struct the_nilfs *nilfs;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 22) struct bio *bio;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 23) int start, end; /* The region to be submitted */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 24) int rest_blocks;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 25) int max_pages;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 26) int nr_vecs;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 27) sector_t blocknr;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 28) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 29)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 30) static int nilfs_segbuf_write(struct nilfs_segment_buffer *segbuf,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 31) struct the_nilfs *nilfs);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 32) static int nilfs_segbuf_wait(struct nilfs_segment_buffer *segbuf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 33)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 34) struct nilfs_segment_buffer *nilfs_segbuf_new(struct super_block *sb)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 35) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 36) struct nilfs_segment_buffer *segbuf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 37)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 38) segbuf = kmem_cache_alloc(nilfs_segbuf_cachep, GFP_NOFS);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 39) if (unlikely(!segbuf))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 40) return NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 41)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 42) segbuf->sb_super = sb;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 43) INIT_LIST_HEAD(&segbuf->sb_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 44) INIT_LIST_HEAD(&segbuf->sb_segsum_buffers);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 45) INIT_LIST_HEAD(&segbuf->sb_payload_buffers);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 46) segbuf->sb_super_root = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 47)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 48) init_completion(&segbuf->sb_bio_event);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 49) atomic_set(&segbuf->sb_err, 0);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 50) segbuf->sb_nbio = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 51)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 52) return segbuf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 53) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 54)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 55) void nilfs_segbuf_free(struct nilfs_segment_buffer *segbuf)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 56) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 57) kmem_cache_free(nilfs_segbuf_cachep, segbuf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 58) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 59)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 60) void nilfs_segbuf_map(struct nilfs_segment_buffer *segbuf, __u64 segnum,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 61) unsigned long offset, struct the_nilfs *nilfs)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 62) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 63) segbuf->sb_segnum = segnum;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 64) nilfs_get_segment_range(nilfs, segnum, &segbuf->sb_fseg_start,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 65) &segbuf->sb_fseg_end);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 66)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 67) segbuf->sb_pseg_start = segbuf->sb_fseg_start + offset;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 68) segbuf->sb_rest_blocks =
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 69) segbuf->sb_fseg_end - segbuf->sb_pseg_start + 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 70) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 71)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 72) /**
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 73) * nilfs_segbuf_map_cont - map a new log behind a given log
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 74) * @segbuf: new segment buffer
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 75) * @prev: segment buffer containing a log to be continued
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 76) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 77) void nilfs_segbuf_map_cont(struct nilfs_segment_buffer *segbuf,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 78) struct nilfs_segment_buffer *prev)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 79) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 80) segbuf->sb_segnum = prev->sb_segnum;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 81) segbuf->sb_fseg_start = prev->sb_fseg_start;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 82) segbuf->sb_fseg_end = prev->sb_fseg_end;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 83) segbuf->sb_pseg_start = prev->sb_pseg_start + prev->sb_sum.nblocks;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 84) segbuf->sb_rest_blocks =
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 85) segbuf->sb_fseg_end - segbuf->sb_pseg_start + 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 86) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 87)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 88) void nilfs_segbuf_set_next_segnum(struct nilfs_segment_buffer *segbuf,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 89) __u64 nextnum, struct the_nilfs *nilfs)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 90) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 91) segbuf->sb_nextnum = nextnum;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 92) segbuf->sb_sum.next = nilfs_get_segment_start_blocknr(nilfs, nextnum);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 93) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 94)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 95) int nilfs_segbuf_extend_segsum(struct nilfs_segment_buffer *segbuf)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 96) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 97) struct buffer_head *bh;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 98)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 99) bh = sb_getblk(segbuf->sb_super,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 100) segbuf->sb_pseg_start + segbuf->sb_sum.nsumblk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 101) if (unlikely(!bh))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 102) return -ENOMEM;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 103)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 104) nilfs_segbuf_add_segsum_buffer(segbuf, bh);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 105) return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 106) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 107)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 108) int nilfs_segbuf_extend_payload(struct nilfs_segment_buffer *segbuf,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 109) struct buffer_head **bhp)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 110) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 111) struct buffer_head *bh;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 112)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 113) bh = sb_getblk(segbuf->sb_super,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 114) segbuf->sb_pseg_start + segbuf->sb_sum.nblocks);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 115) if (unlikely(!bh))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 116) return -ENOMEM;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 117)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 118) nilfs_segbuf_add_payload_buffer(segbuf, bh);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 119) *bhp = bh;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 120) return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 121) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 122)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 123) int nilfs_segbuf_reset(struct nilfs_segment_buffer *segbuf, unsigned int flags,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 124) time64_t ctime, __u64 cno)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 125) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 126) int err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 127)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 128) segbuf->sb_sum.nblocks = segbuf->sb_sum.nsumblk = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 129) err = nilfs_segbuf_extend_segsum(segbuf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 130) if (unlikely(err))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 131) return err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 132)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 133) segbuf->sb_sum.flags = flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 134) segbuf->sb_sum.sumbytes = sizeof(struct nilfs_segment_summary);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 135) segbuf->sb_sum.nfinfo = segbuf->sb_sum.nfileblk = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 136) segbuf->sb_sum.ctime = ctime;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 137) segbuf->sb_sum.cno = cno;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 138) return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 139) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 140)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 141) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 142) * Setup segment summary
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 143) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 144) void nilfs_segbuf_fill_in_segsum(struct nilfs_segment_buffer *segbuf)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 145) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 146) struct nilfs_segment_summary *raw_sum;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 147) struct buffer_head *bh_sum;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 148)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 149) bh_sum = list_entry(segbuf->sb_segsum_buffers.next,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 150) struct buffer_head, b_assoc_buffers);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 151) raw_sum = (struct nilfs_segment_summary *)bh_sum->b_data;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 152)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 153) raw_sum->ss_magic = cpu_to_le32(NILFS_SEGSUM_MAGIC);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 154) raw_sum->ss_bytes = cpu_to_le16(sizeof(*raw_sum));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 155) raw_sum->ss_flags = cpu_to_le16(segbuf->sb_sum.flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 156) raw_sum->ss_seq = cpu_to_le64(segbuf->sb_sum.seg_seq);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 157) raw_sum->ss_create = cpu_to_le64(segbuf->sb_sum.ctime);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 158) raw_sum->ss_next = cpu_to_le64(segbuf->sb_sum.next);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 159) raw_sum->ss_nblocks = cpu_to_le32(segbuf->sb_sum.nblocks);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 160) raw_sum->ss_nfinfo = cpu_to_le32(segbuf->sb_sum.nfinfo);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 161) raw_sum->ss_sumbytes = cpu_to_le32(segbuf->sb_sum.sumbytes);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 162) raw_sum->ss_pad = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 163) raw_sum->ss_cno = cpu_to_le64(segbuf->sb_sum.cno);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 164) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 165)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 166) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 167) * CRC calculation routines
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 168) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 169) static void
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 170) nilfs_segbuf_fill_in_segsum_crc(struct nilfs_segment_buffer *segbuf, u32 seed)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 171) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 172) struct buffer_head *bh;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 173) struct nilfs_segment_summary *raw_sum;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 174) unsigned long size, bytes = segbuf->sb_sum.sumbytes;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 175) u32 crc;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 176)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 177) bh = list_entry(segbuf->sb_segsum_buffers.next, struct buffer_head,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 178) b_assoc_buffers);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 179)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 180) raw_sum = (struct nilfs_segment_summary *)bh->b_data;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 181) size = min_t(unsigned long, bytes, bh->b_size);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 182) crc = crc32_le(seed,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 183) (unsigned char *)raw_sum +
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 184) sizeof(raw_sum->ss_datasum) + sizeof(raw_sum->ss_sumsum),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 185) size - (sizeof(raw_sum->ss_datasum) +
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 186) sizeof(raw_sum->ss_sumsum)));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 187)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 188) list_for_each_entry_continue(bh, &segbuf->sb_segsum_buffers,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 189) b_assoc_buffers) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 190) bytes -= size;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 191) size = min_t(unsigned long, bytes, bh->b_size);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 192) crc = crc32_le(crc, bh->b_data, size);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 193) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 194) raw_sum->ss_sumsum = cpu_to_le32(crc);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 195) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 196)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 197) static void nilfs_segbuf_fill_in_data_crc(struct nilfs_segment_buffer *segbuf,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 198) u32 seed)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 199) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 200) struct buffer_head *bh;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 201) struct nilfs_segment_summary *raw_sum;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 202) void *kaddr;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 203) u32 crc;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 204)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 205) bh = list_entry(segbuf->sb_segsum_buffers.next, struct buffer_head,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 206) b_assoc_buffers);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 207) raw_sum = (struct nilfs_segment_summary *)bh->b_data;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 208) crc = crc32_le(seed,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 209) (unsigned char *)raw_sum + sizeof(raw_sum->ss_datasum),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 210) bh->b_size - sizeof(raw_sum->ss_datasum));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 211)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 212) list_for_each_entry_continue(bh, &segbuf->sb_segsum_buffers,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 213) b_assoc_buffers) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 214) crc = crc32_le(crc, bh->b_data, bh->b_size);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 215) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 216) list_for_each_entry(bh, &segbuf->sb_payload_buffers, b_assoc_buffers) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 217) kaddr = kmap_atomic(bh->b_page);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 218) crc = crc32_le(crc, kaddr + bh_offset(bh), bh->b_size);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 219) kunmap_atomic(kaddr);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 220) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 221) raw_sum->ss_datasum = cpu_to_le32(crc);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 222) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 223)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 224) static void
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 225) nilfs_segbuf_fill_in_super_root_crc(struct nilfs_segment_buffer *segbuf,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 226) u32 seed)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 227) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 228) struct nilfs_super_root *raw_sr;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 229) struct the_nilfs *nilfs = segbuf->sb_super->s_fs_info;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 230) unsigned int srsize;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 231) u32 crc;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 232)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 233) raw_sr = (struct nilfs_super_root *)segbuf->sb_super_root->b_data;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 234) srsize = NILFS_SR_BYTES(nilfs->ns_inode_size);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 235) crc = crc32_le(seed,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 236) (unsigned char *)raw_sr + sizeof(raw_sr->sr_sum),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 237) srsize - sizeof(raw_sr->sr_sum));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 238) raw_sr->sr_sum = cpu_to_le32(crc);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 239) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 240)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 241) static void nilfs_release_buffers(struct list_head *list)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 242) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 243) struct buffer_head *bh, *n;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 244)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 245) list_for_each_entry_safe(bh, n, list, b_assoc_buffers) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 246) list_del_init(&bh->b_assoc_buffers);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 247) brelse(bh);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 248) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 249) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 250)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 251) static void nilfs_segbuf_clear(struct nilfs_segment_buffer *segbuf)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 252) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 253) nilfs_release_buffers(&segbuf->sb_segsum_buffers);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 254) nilfs_release_buffers(&segbuf->sb_payload_buffers);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 255) segbuf->sb_super_root = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 256) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 257)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 258) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 259) * Iterators for segment buffers
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 260) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 261) void nilfs_clear_logs(struct list_head *logs)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 262) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 263) struct nilfs_segment_buffer *segbuf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 264)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 265) list_for_each_entry(segbuf, logs, sb_list)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 266) nilfs_segbuf_clear(segbuf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 267) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 268)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 269) void nilfs_truncate_logs(struct list_head *logs,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 270) struct nilfs_segment_buffer *last)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 271) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 272) struct nilfs_segment_buffer *n, *segbuf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 273)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 274) segbuf = list_prepare_entry(last, logs, sb_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 275) list_for_each_entry_safe_continue(segbuf, n, logs, sb_list) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 276) list_del_init(&segbuf->sb_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 277) nilfs_segbuf_clear(segbuf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 278) nilfs_segbuf_free(segbuf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 279) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 280) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 281)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 282) int nilfs_write_logs(struct list_head *logs, struct the_nilfs *nilfs)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 283) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 284) struct nilfs_segment_buffer *segbuf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 285) int ret = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 286)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 287) list_for_each_entry(segbuf, logs, sb_list) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 288) ret = nilfs_segbuf_write(segbuf, nilfs);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 289) if (ret)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 290) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 291) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 292) return ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 293) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 294)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 295) int nilfs_wait_on_logs(struct list_head *logs)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 296) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 297) struct nilfs_segment_buffer *segbuf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 298) int err, ret = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 299)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 300) list_for_each_entry(segbuf, logs, sb_list) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 301) err = nilfs_segbuf_wait(segbuf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 302) if (err && !ret)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 303) ret = err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 304) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 305) return ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 306) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 307)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 308) /**
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 309) * nilfs_add_checksums_on_logs - add checksums on the logs
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 310) * @logs: list of segment buffers storing target logs
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 311) * @seed: checksum seed value
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 312) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 313) void nilfs_add_checksums_on_logs(struct list_head *logs, u32 seed)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 314) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 315) struct nilfs_segment_buffer *segbuf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 316)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 317) list_for_each_entry(segbuf, logs, sb_list) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 318) if (segbuf->sb_super_root)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 319) nilfs_segbuf_fill_in_super_root_crc(segbuf, seed);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 320) nilfs_segbuf_fill_in_segsum_crc(segbuf, seed);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 321) nilfs_segbuf_fill_in_data_crc(segbuf, seed);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 322) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 323) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 324)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 325) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 326) * BIO operations
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 327) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 328) static void nilfs_end_bio_write(struct bio *bio)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 329) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 330) struct nilfs_segment_buffer *segbuf = bio->bi_private;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 331)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 332) if (bio->bi_status)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 333) atomic_inc(&segbuf->sb_err);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 334)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 335) bio_put(bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 336) complete(&segbuf->sb_bio_event);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 337) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 338)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 339) static int nilfs_segbuf_submit_bio(struct nilfs_segment_buffer *segbuf,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 340) struct nilfs_write_info *wi, int mode,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 341) int mode_flags)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 342) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 343) struct bio *bio = wi->bio;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 344) int err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 345)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 346) if (segbuf->sb_nbio > 0 &&
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 347) bdi_write_congested(segbuf->sb_super->s_bdi)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 348) wait_for_completion(&segbuf->sb_bio_event);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 349) segbuf->sb_nbio--;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 350) if (unlikely(atomic_read(&segbuf->sb_err))) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 351) bio_put(bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 352) err = -EIO;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 353) goto failed;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 354) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 355) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 356)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 357) bio->bi_end_io = nilfs_end_bio_write;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 358) bio->bi_private = segbuf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 359) bio_set_op_attrs(bio, mode, mode_flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 360) submit_bio(bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 361) segbuf->sb_nbio++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 362)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 363) wi->bio = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 364) wi->rest_blocks -= wi->end - wi->start;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 365) wi->nr_vecs = min(wi->max_pages, wi->rest_blocks);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 366) wi->start = wi->end;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 367) return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 368)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 369) failed:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 370) wi->bio = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 371) return err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 372) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 373)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 374) /**
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 375) * nilfs_alloc_seg_bio - allocate a new bio for writing log
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 376) * @nilfs: nilfs object
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 377) * @start: start block number of the bio
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 378) * @nr_vecs: request size of page vector.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 379) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 380) * Return Value: On success, pointer to the struct bio is returned.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 381) * On error, NULL is returned.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 382) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 383) static struct bio *nilfs_alloc_seg_bio(struct the_nilfs *nilfs, sector_t start,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 384) int nr_vecs)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 385) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 386) struct bio *bio;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 387)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 388) bio = bio_alloc(GFP_NOIO, nr_vecs);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 389) if (bio == NULL) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 390) while (!bio && (nr_vecs >>= 1))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 391) bio = bio_alloc(GFP_NOIO, nr_vecs);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 392) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 393) if (likely(bio)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 394) bio_set_dev(bio, nilfs->ns_bdev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 395) bio->bi_iter.bi_sector =
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 396) start << (nilfs->ns_blocksize_bits - 9);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 397) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 398) return bio;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 399) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 400)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 401) static void nilfs_segbuf_prepare_write(struct nilfs_segment_buffer *segbuf,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 402) struct nilfs_write_info *wi)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 403) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 404) wi->bio = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 405) wi->rest_blocks = segbuf->sb_sum.nblocks;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 406) wi->max_pages = BIO_MAX_PAGES;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 407) wi->nr_vecs = min(wi->max_pages, wi->rest_blocks);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 408) wi->start = wi->end = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 409) wi->blocknr = segbuf->sb_pseg_start;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 410) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 411)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 412) static int nilfs_segbuf_submit_bh(struct nilfs_segment_buffer *segbuf,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 413) struct nilfs_write_info *wi,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 414) struct buffer_head *bh, int mode)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 415) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 416) int len, err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 417)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 418) BUG_ON(wi->nr_vecs <= 0);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 419) repeat:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 420) if (!wi->bio) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 421) wi->bio = nilfs_alloc_seg_bio(wi->nilfs, wi->blocknr + wi->end,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 422) wi->nr_vecs);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 423) if (unlikely(!wi->bio))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 424) return -ENOMEM;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 425) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 426)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 427) len = bio_add_page(wi->bio, bh->b_page, bh->b_size, bh_offset(bh));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 428) if (len == bh->b_size) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 429) wi->end++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 430) return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 431) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 432) /* bio is FULL */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 433) err = nilfs_segbuf_submit_bio(segbuf, wi, mode, 0);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 434) /* never submit current bh */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 435) if (likely(!err))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 436) goto repeat;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 437) return err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 438) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 439)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 440) /**
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 441) * nilfs_segbuf_write - submit write requests of a log
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 442) * @segbuf: buffer storing a log to be written
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 443) * @nilfs: nilfs object
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 444) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 445) * Return Value: On Success, 0 is returned. On Error, one of the following
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 446) * negative error code is returned.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 447) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 448) * %-EIO - I/O error
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 449) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 450) * %-ENOMEM - Insufficient memory available.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 451) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 452) static int nilfs_segbuf_write(struct nilfs_segment_buffer *segbuf,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 453) struct the_nilfs *nilfs)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 454) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 455) struct nilfs_write_info wi;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 456) struct buffer_head *bh;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 457) int res = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 458)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 459) wi.nilfs = nilfs;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 460) nilfs_segbuf_prepare_write(segbuf, &wi);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 461)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 462) list_for_each_entry(bh, &segbuf->sb_segsum_buffers, b_assoc_buffers) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 463) res = nilfs_segbuf_submit_bh(segbuf, &wi, bh, REQ_OP_WRITE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 464) if (unlikely(res))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 465) goto failed_bio;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 466) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 467)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 468) list_for_each_entry(bh, &segbuf->sb_payload_buffers, b_assoc_buffers) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 469) res = nilfs_segbuf_submit_bh(segbuf, &wi, bh, REQ_OP_WRITE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 470) if (unlikely(res))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 471) goto failed_bio;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 472) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 473)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 474) if (wi.bio) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 475) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 476) * Last BIO is always sent through the following
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 477) * submission.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 478) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 479) res = nilfs_segbuf_submit_bio(segbuf, &wi, REQ_OP_WRITE,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 480) REQ_SYNC);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 481) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 482)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 483) failed_bio:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 484) return res;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 485) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 486)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 487) /**
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 488) * nilfs_segbuf_wait - wait for completion of requested BIOs
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 489) * @segbuf: segment buffer
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 490) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 491) * Return Value: On Success, 0 is returned. On Error, one of the following
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 492) * negative error code is returned.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 493) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 494) * %-EIO - I/O error
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 495) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 496) static int nilfs_segbuf_wait(struct nilfs_segment_buffer *segbuf)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 497) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 498) int err = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 499)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 500) if (!segbuf->sb_nbio)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 501) return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 502)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 503) do {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 504) wait_for_completion(&segbuf->sb_bio_event);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 505) } while (--segbuf->sb_nbio > 0);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 506)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 507) if (unlikely(atomic_read(&segbuf->sb_err) > 0)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 508) nilfs_err(segbuf->sb_super,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 509) "I/O error writing log (start-blocknr=%llu, block-count=%lu) in segment %llu",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 510) (unsigned long long)segbuf->sb_pseg_start,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 511) segbuf->sb_sum.nblocks,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 512) (unsigned long long)segbuf->sb_segnum);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 513) err = -EIO;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 514) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 515) return err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 516) }