Lines Matching refs:sci
237 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_transaction_commit() local
240 nilfs_segctor_start_timer(sci); in nilfs_transaction_commit()
241 if (atomic_read(&nilfs->ns_ndirtyblks) > sci->sc_watermark) in nilfs_transaction_commit()
242 nilfs_segctor_do_flush(sci, 0); in nilfs_transaction_commit()
276 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_relax_pressure_in_lock() local
278 if (!sci || !sci->sc_flush_request) in nilfs_relax_pressure_in_lock()
281 set_bit(NILFS_SC_PRIOR_FLUSH, &sci->sc_flags); in nilfs_relax_pressure_in_lock()
285 if (sci->sc_flush_request && in nilfs_relax_pressure_in_lock()
286 test_bit(NILFS_SC_PRIOR_FLUSH, &sci->sc_flags)) { in nilfs_relax_pressure_in_lock()
290 nilfs_segctor_do_immediate_flush(sci); in nilfs_relax_pressure_in_lock()
302 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_transaction_lock() local
313 if (!test_bit(NILFS_SC_PRIOR_FLUSH, &sci->sc_flags)) in nilfs_transaction_lock()
316 nilfs_segctor_do_immediate_flush(sci); in nilfs_transaction_lock()
337 static void *nilfs_segctor_map_segsum_entry(struct nilfs_sc_info *sci, in nilfs_segctor_map_segsum_entry() argument
341 struct nilfs_segment_buffer *segbuf = sci->sc_curseg; in nilfs_segctor_map_segsum_entry()
342 unsigned blocksize = sci->sc_super->s_blocksize; in nilfs_segctor_map_segsum_entry()
360 static int nilfs_segctor_reset_segment_buffer(struct nilfs_sc_info *sci) in nilfs_segctor_reset_segment_buffer() argument
362 struct nilfs_segment_buffer *segbuf = sci->sc_curseg; in nilfs_segctor_reset_segment_buffer()
370 err = nilfs_segbuf_reset(segbuf, flags, sci->sc_seg_ctime, sci->sc_cno); in nilfs_segctor_reset_segment_buffer()
376 sci->sc_finfo_ptr.bh = sumbh; sci->sc_finfo_ptr.offset = sumbytes; in nilfs_segctor_reset_segment_buffer()
377 sci->sc_binfo_ptr.bh = sumbh; sci->sc_binfo_ptr.offset = sumbytes; in nilfs_segctor_reset_segment_buffer()
378 sci->sc_blk_cnt = sci->sc_datablk_cnt = 0; in nilfs_segctor_reset_segment_buffer()
382 static int nilfs_segctor_feed_segment(struct nilfs_sc_info *sci) in nilfs_segctor_feed_segment() argument
384 sci->sc_nblk_this_inc += sci->sc_curseg->sb_sum.nblocks; in nilfs_segctor_feed_segment()
385 if (NILFS_SEGBUF_IS_LAST(sci->sc_curseg, &sci->sc_segbufs)) in nilfs_segctor_feed_segment()
388 sci->sc_curseg = NILFS_NEXT_SEGBUF(sci->sc_curseg); in nilfs_segctor_feed_segment()
389 return nilfs_segctor_reset_segment_buffer(sci); in nilfs_segctor_feed_segment()
392 static int nilfs_segctor_add_super_root(struct nilfs_sc_info *sci) in nilfs_segctor_add_super_root() argument
394 struct nilfs_segment_buffer *segbuf = sci->sc_curseg; in nilfs_segctor_add_super_root()
398 err = nilfs_segctor_feed_segment(sci); in nilfs_segctor_add_super_root()
401 segbuf = sci->sc_curseg; in nilfs_segctor_add_super_root()
413 struct nilfs_sc_info *sci, const struct nilfs_segsum_pointer *ssp, in nilfs_segctor_segsum_block_required() argument
416 unsigned blocksize = sci->sc_super->s_blocksize; in nilfs_segctor_segsum_block_required()
420 (!sci->sc_blk_cnt ? sizeof(struct nilfs_finfo) : 0) > in nilfs_segctor_segsum_block_required()
424 static void nilfs_segctor_begin_finfo(struct nilfs_sc_info *sci, in nilfs_segctor_begin_finfo() argument
427 sci->sc_curseg->sb_sum.nfinfo++; in nilfs_segctor_begin_finfo()
428 sci->sc_binfo_ptr = sci->sc_finfo_ptr; in nilfs_segctor_begin_finfo()
430 sci, &sci->sc_binfo_ptr, sizeof(struct nilfs_finfo)); in nilfs_segctor_begin_finfo()
433 !test_bit(NILFS_SC_HAVE_DELTA, &sci->sc_flags)) in nilfs_segctor_begin_finfo()
434 set_bit(NILFS_SC_HAVE_DELTA, &sci->sc_flags); in nilfs_segctor_begin_finfo()
438 static void nilfs_segctor_end_finfo(struct nilfs_sc_info *sci, in nilfs_segctor_end_finfo() argument
446 if (sci->sc_blk_cnt == 0) in nilfs_segctor_end_finfo()
456 cno = sci->sc_cno; in nilfs_segctor_end_finfo()
458 finfo = nilfs_segctor_map_segsum_entry(sci, &sci->sc_finfo_ptr, in nilfs_segctor_end_finfo()
461 finfo->fi_nblocks = cpu_to_le32(sci->sc_blk_cnt); in nilfs_segctor_end_finfo()
462 finfo->fi_ndatablk = cpu_to_le32(sci->sc_datablk_cnt); in nilfs_segctor_end_finfo()
465 segbuf = sci->sc_curseg; in nilfs_segctor_end_finfo()
466 segbuf->sb_sum.sumbytes = sci->sc_binfo_ptr.offset + in nilfs_segctor_end_finfo()
467 sci->sc_super->s_blocksize * (segbuf->sb_sum.nsumblk - 1); in nilfs_segctor_end_finfo()
468 sci->sc_finfo_ptr = sci->sc_binfo_ptr; in nilfs_segctor_end_finfo()
469 sci->sc_blk_cnt = sci->sc_datablk_cnt = 0; in nilfs_segctor_end_finfo()
472 static int nilfs_segctor_add_file_block(struct nilfs_sc_info *sci, in nilfs_segctor_add_file_block() argument
481 segbuf = sci->sc_curseg; in nilfs_segctor_add_file_block()
483 sci, &sci->sc_binfo_ptr, binfo_size); in nilfs_segctor_add_file_block()
485 nilfs_segctor_end_finfo(sci, inode); in nilfs_segctor_add_file_block()
486 err = nilfs_segctor_feed_segment(sci); in nilfs_segctor_add_file_block()
496 if (sci->sc_blk_cnt == 0) in nilfs_segctor_add_file_block()
497 nilfs_segctor_begin_finfo(sci, inode); in nilfs_segctor_add_file_block()
499 nilfs_segctor_map_segsum_entry(sci, &sci->sc_binfo_ptr, binfo_size); in nilfs_segctor_add_file_block()
502 sci->sc_blk_cnt++; in nilfs_segctor_add_file_block()
510 static int nilfs_collect_file_data(struct nilfs_sc_info *sci, in nilfs_collect_file_data() argument
519 err = nilfs_segctor_add_file_block(sci, bh, inode, in nilfs_collect_file_data()
522 sci->sc_datablk_cnt++; in nilfs_collect_file_data()
526 static int nilfs_collect_file_node(struct nilfs_sc_info *sci, in nilfs_collect_file_node() argument
533 static int nilfs_collect_file_bmap(struct nilfs_sc_info *sci, in nilfs_collect_file_bmap() argument
538 return nilfs_segctor_add_file_block(sci, bh, inode, sizeof(__le64)); in nilfs_collect_file_bmap()
541 static void nilfs_write_file_data_binfo(struct nilfs_sc_info *sci, in nilfs_write_file_data_binfo() argument
546 sci, ssp, sizeof(*binfo_v)); in nilfs_write_file_data_binfo()
550 static void nilfs_write_file_node_binfo(struct nilfs_sc_info *sci, in nilfs_write_file_node_binfo() argument
555 sci, ssp, sizeof(*vblocknr)); in nilfs_write_file_node_binfo()
567 static int nilfs_collect_dat_data(struct nilfs_sc_info *sci, in nilfs_collect_dat_data() argument
576 err = nilfs_segctor_add_file_block(sci, bh, inode, sizeof(__le64)); in nilfs_collect_dat_data()
578 sci->sc_datablk_cnt++; in nilfs_collect_dat_data()
582 static int nilfs_collect_dat_bmap(struct nilfs_sc_info *sci, in nilfs_collect_dat_bmap() argument
586 return nilfs_segctor_add_file_block(sci, bh, inode, in nilfs_collect_dat_bmap()
590 static void nilfs_write_dat_data_binfo(struct nilfs_sc_info *sci, in nilfs_write_dat_data_binfo() argument
594 __le64 *blkoff = nilfs_segctor_map_segsum_entry(sci, ssp, in nilfs_write_dat_data_binfo()
599 static void nilfs_write_dat_node_binfo(struct nilfs_sc_info *sci, in nilfs_write_dat_node_binfo() argument
604 nilfs_segctor_map_segsum_entry(sci, ssp, sizeof(*binfo_dat)); in nilfs_write_dat_node_binfo()
749 struct nilfs_sc_info *sci = container_of(work, struct nilfs_sc_info, in nilfs_iput_work_func() local
751 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_iput_work_func()
753 nilfs_dispose_list(nilfs, &sci->sc_iput_queue, 0); in nilfs_iput_work_func()
772 static int nilfs_segctor_clean(struct nilfs_sc_info *sci) in nilfs_segctor_clean() argument
774 return list_empty(&sci->sc_dirty_files) && in nilfs_segctor_clean()
775 !test_bit(NILFS_SC_DIRTY, &sci->sc_flags) && in nilfs_segctor_clean()
776 sci->sc_nfreesegs == 0 && in nilfs_segctor_clean()
777 (!nilfs_doing_gc() || list_empty(&sci->sc_gc_inodes)); in nilfs_segctor_clean()
780 static int nilfs_segctor_confirm(struct nilfs_sc_info *sci) in nilfs_segctor_confirm() argument
782 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_confirm()
785 if (nilfs_test_metadata_dirty(nilfs, sci->sc_root)) in nilfs_segctor_confirm()
786 set_bit(NILFS_SC_DIRTY, &sci->sc_flags); in nilfs_segctor_confirm()
789 if (list_empty(&nilfs->ns_dirty_files) && nilfs_segctor_clean(sci)) in nilfs_segctor_confirm()
796 static void nilfs_segctor_clear_metadata_dirty(struct nilfs_sc_info *sci) in nilfs_segctor_clear_metadata_dirty() argument
798 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_clear_metadata_dirty()
800 nilfs_mdt_clear_dirty(sci->sc_root->ifile); in nilfs_segctor_clear_metadata_dirty()
806 static int nilfs_segctor_create_checkpoint(struct nilfs_sc_info *sci) in nilfs_segctor_create_checkpoint() argument
808 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_create_checkpoint()
830 static int nilfs_segctor_fill_in_checkpoint(struct nilfs_sc_info *sci) in nilfs_segctor_fill_in_checkpoint() argument
832 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_fill_in_checkpoint()
846 cpu_to_le64(atomic64_read(&sci->sc_root->inodes_count)); in nilfs_segctor_fill_in_checkpoint()
848 cpu_to_le64(atomic64_read(&sci->sc_root->blocks_count)); in nilfs_segctor_fill_in_checkpoint()
850 cpu_to_le64(sci->sc_nblk_inc + sci->sc_nblk_this_inc); in nilfs_segctor_fill_in_checkpoint()
851 raw_cp->cp_create = cpu_to_le64(sci->sc_seg_ctime); in nilfs_segctor_fill_in_checkpoint()
854 if (test_bit(NILFS_SC_HAVE_DELTA, &sci->sc_flags)) in nilfs_segctor_fill_in_checkpoint()
859 nilfs_write_inode_common(sci->sc_root->ifile, in nilfs_segctor_fill_in_checkpoint()
885 static void nilfs_segctor_fill_in_file_bmap(struct nilfs_sc_info *sci) in nilfs_segctor_fill_in_file_bmap() argument
889 list_for_each_entry(ii, &sci->sc_dirty_files, i_dirty) { in nilfs_segctor_fill_in_file_bmap()
890 nilfs_fill_in_file_bmap(sci->sc_root->ifile, ii); in nilfs_segctor_fill_in_file_bmap()
895 static void nilfs_segctor_fill_in_super_root(struct nilfs_sc_info *sci, in nilfs_segctor_fill_in_super_root() argument
902 bh_sr = NILFS_LAST_SEGBUF(&sci->sc_segbufs)->sb_super_root; in nilfs_segctor_fill_in_super_root()
910 nilfs->ns_nongc_ctime : sci->sc_seg_ctime); in nilfs_segctor_fill_in_super_root()
945 static int nilfs_segctor_apply_buffers(struct nilfs_sc_info *sci, in nilfs_segctor_apply_buffers() argument
958 err = collect(sci, bh, inode); in nilfs_segctor_apply_buffers()
976 static size_t nilfs_segctor_buffer_rest(struct nilfs_sc_info *sci) in nilfs_segctor_buffer_rest() argument
979 return sci->sc_segbuf_nblocks - in nilfs_segctor_buffer_rest()
980 (sci->sc_nblk_this_inc + sci->sc_curseg->sb_sum.nblocks); in nilfs_segctor_buffer_rest()
983 static int nilfs_segctor_scan_file(struct nilfs_sc_info *sci, in nilfs_segctor_scan_file() argument
991 if (!(sci->sc_stage.flags & NILFS_CF_NODE)) { in nilfs_segctor_scan_file()
992 size_t n, rest = nilfs_segctor_buffer_rest(sci); in nilfs_segctor_scan_file()
998 sci, inode, &data_buffers, in nilfs_segctor_scan_file()
1006 if (!(sci->sc_stage.flags & NILFS_CF_NODE)) { in nilfs_segctor_scan_file()
1008 sci, inode, &data_buffers, sc_ops->collect_data); in nilfs_segctor_scan_file()
1012 sci, inode, &node_buffers, NULL); in nilfs_segctor_scan_file()
1015 sci->sc_stage.flags |= NILFS_CF_NODE; in nilfs_segctor_scan_file()
1019 sci, inode, &node_buffers, sc_ops->collect_node); in nilfs_segctor_scan_file()
1025 sci, inode, &node_buffers, sc_ops->collect_bmap); in nilfs_segctor_scan_file()
1029 nilfs_segctor_end_finfo(sci, inode); in nilfs_segctor_scan_file()
1030 sci->sc_stage.flags &= ~NILFS_CF_NODE; in nilfs_segctor_scan_file()
1036 static int nilfs_segctor_scan_file_dsync(struct nilfs_sc_info *sci, in nilfs_segctor_scan_file_dsync() argument
1040 size_t n, rest = nilfs_segctor_buffer_rest(sci); in nilfs_segctor_scan_file_dsync()
1044 sci->sc_dsync_start, in nilfs_segctor_scan_file_dsync()
1045 sci->sc_dsync_end); in nilfs_segctor_scan_file_dsync()
1047 err = nilfs_segctor_apply_buffers(sci, inode, &data_buffers, in nilfs_segctor_scan_file_dsync()
1050 nilfs_segctor_end_finfo(sci, inode); in nilfs_segctor_scan_file_dsync()
1057 static int nilfs_segctor_collect_blocks(struct nilfs_sc_info *sci, int mode) in nilfs_segctor_collect_blocks() argument
1059 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_collect_blocks()
1065 switch (sci->sc_stage.scnt) { in nilfs_segctor_collect_blocks()
1068 sci->sc_stage.flags = 0; in nilfs_segctor_collect_blocks()
1070 if (!test_bit(NILFS_SC_UNCLOSED, &sci->sc_flags)) { in nilfs_segctor_collect_blocks()
1071 sci->sc_nblk_inc = 0; in nilfs_segctor_collect_blocks()
1072 sci->sc_curseg->sb_sum.flags = NILFS_SS_LOGBGN; in nilfs_segctor_collect_blocks()
1074 sci->sc_stage.scnt = NILFS_ST_DSYNC; in nilfs_segctor_collect_blocks()
1079 sci->sc_stage.dirty_file_ptr = NULL; in nilfs_segctor_collect_blocks()
1080 sci->sc_stage.gc_inode_ptr = NULL; in nilfs_segctor_collect_blocks()
1082 sci->sc_stage.scnt = NILFS_ST_DAT; in nilfs_segctor_collect_blocks()
1085 sci->sc_stage.scnt++; /* Fall through */ in nilfs_segctor_collect_blocks()
1088 head = &sci->sc_gc_inodes; in nilfs_segctor_collect_blocks()
1089 ii = list_prepare_entry(sci->sc_stage.gc_inode_ptr, in nilfs_segctor_collect_blocks()
1093 sci, &ii->vfs_inode, in nilfs_segctor_collect_blocks()
1096 sci->sc_stage.gc_inode_ptr = list_entry( in nilfs_segctor_collect_blocks()
1104 sci->sc_stage.gc_inode_ptr = NULL; in nilfs_segctor_collect_blocks()
1106 sci->sc_stage.scnt++; /* Fall through */ in nilfs_segctor_collect_blocks()
1108 head = &sci->sc_dirty_files; in nilfs_segctor_collect_blocks()
1109 ii = list_prepare_entry(sci->sc_stage.dirty_file_ptr, head, in nilfs_segctor_collect_blocks()
1114 err = nilfs_segctor_scan_file(sci, &ii->vfs_inode, in nilfs_segctor_collect_blocks()
1117 sci->sc_stage.dirty_file_ptr = in nilfs_segctor_collect_blocks()
1126 sci->sc_stage.dirty_file_ptr = NULL; in nilfs_segctor_collect_blocks()
1128 sci->sc_stage.scnt = NILFS_ST_DONE; in nilfs_segctor_collect_blocks()
1131 sci->sc_stage.scnt++; in nilfs_segctor_collect_blocks()
1132 sci->sc_stage.flags |= NILFS_CF_IFILE_STARTED; in nilfs_segctor_collect_blocks()
1135 err = nilfs_segctor_scan_file(sci, sci->sc_root->ifile, in nilfs_segctor_collect_blocks()
1139 sci->sc_stage.scnt++; in nilfs_segctor_collect_blocks()
1141 err = nilfs_segctor_create_checkpoint(sci); in nilfs_segctor_collect_blocks()
1146 err = nilfs_segctor_scan_file(sci, nilfs->ns_cpfile, in nilfs_segctor_collect_blocks()
1150 sci->sc_stage.scnt++; /* Fall through */ in nilfs_segctor_collect_blocks()
1152 err = nilfs_sufile_freev(nilfs->ns_sufile, sci->sc_freesegs, in nilfs_segctor_collect_blocks()
1153 sci->sc_nfreesegs, &ndone); in nilfs_segctor_collect_blocks()
1156 sci->sc_freesegs, ndone, in nilfs_segctor_collect_blocks()
1160 sci->sc_stage.flags |= NILFS_CF_SUFREED; in nilfs_segctor_collect_blocks()
1162 err = nilfs_segctor_scan_file(sci, nilfs->ns_sufile, in nilfs_segctor_collect_blocks()
1166 sci->sc_stage.scnt++; /* Fall through */ in nilfs_segctor_collect_blocks()
1169 err = nilfs_segctor_scan_file(sci, nilfs->ns_dat, in nilfs_segctor_collect_blocks()
1174 sci->sc_stage.scnt = NILFS_ST_DONE; in nilfs_segctor_collect_blocks()
1177 sci->sc_stage.scnt++; /* Fall through */ in nilfs_segctor_collect_blocks()
1181 err = nilfs_segctor_add_super_root(sci); in nilfs_segctor_collect_blocks()
1186 sci->sc_curseg->sb_sum.flags |= NILFS_SS_LOGEND; in nilfs_segctor_collect_blocks()
1187 sci->sc_stage.scnt = NILFS_ST_DONE; in nilfs_segctor_collect_blocks()
1191 sci->sc_curseg->sb_sum.flags |= NILFS_SS_SYNDT; in nilfs_segctor_collect_blocks()
1192 ii = sci->sc_dsync_inode; in nilfs_segctor_collect_blocks()
1196 err = nilfs_segctor_scan_file_dsync(sci, &ii->vfs_inode); in nilfs_segctor_collect_blocks()
1199 sci->sc_curseg->sb_sum.flags |= NILFS_SS_LOGEND; in nilfs_segctor_collect_blocks()
1200 sci->sc_stage.scnt = NILFS_ST_DONE; in nilfs_segctor_collect_blocks()
1217 static int nilfs_segctor_begin_construction(struct nilfs_sc_info *sci, in nilfs_segctor_begin_construction() argument
1224 segbuf = nilfs_segbuf_new(sci->sc_super); in nilfs_segctor_begin_construction()
1228 if (list_empty(&sci->sc_write_logs)) { in nilfs_segctor_begin_construction()
1244 prev = NILFS_LAST_SEGBUF(&sci->sc_write_logs); in nilfs_segctor_begin_construction()
1267 BUG_ON(!list_empty(&sci->sc_segbufs)); in nilfs_segctor_begin_construction()
1268 list_add_tail(&segbuf->sb_list, &sci->sc_segbufs); in nilfs_segctor_begin_construction()
1269 sci->sc_segbuf_nblocks = segbuf->sb_rest_blocks; in nilfs_segctor_begin_construction()
1277 static int nilfs_segctor_extend_segments(struct nilfs_sc_info *sci, in nilfs_segctor_extend_segments() argument
1286 prev = NILFS_LAST_SEGBUF(&sci->sc_segbufs); in nilfs_segctor_extend_segments()
1300 segbuf = nilfs_segbuf_new(sci->sc_super); in nilfs_segctor_extend_segments()
1306 sci->sc_segbuf_nblocks += segbuf->sb_rest_blocks; in nilfs_segctor_extend_segments()
1319 list_splice_tail(&list, &sci->sc_segbufs); in nilfs_segctor_extend_segments()
1370 static void nilfs_segctor_update_segusage(struct nilfs_sc_info *sci, in nilfs_segctor_update_segusage() argument
1377 list_for_each_entry(segbuf, &sci->sc_segbufs, sb_list) { in nilfs_segctor_update_segusage()
1382 sci->sc_seg_ctime); in nilfs_segctor_update_segusage()
1405 static void nilfs_segctor_truncate_segments(struct nilfs_sc_info *sci, in nilfs_segctor_truncate_segments() argument
1412 list_for_each_entry_continue(segbuf, &sci->sc_segbufs, sb_list) { in nilfs_segctor_truncate_segments()
1413 sci->sc_segbuf_nblocks -= segbuf->sb_rest_blocks; in nilfs_segctor_truncate_segments()
1417 nilfs_truncate_logs(&sci->sc_segbufs, last); in nilfs_segctor_truncate_segments()
1421 static int nilfs_segctor_collect(struct nilfs_sc_info *sci, in nilfs_segctor_collect() argument
1424 struct nilfs_cstage prev_stage = sci->sc_stage; in nilfs_segctor_collect()
1429 sci->sc_nblk_this_inc = 0; in nilfs_segctor_collect()
1430 sci->sc_curseg = NILFS_FIRST_SEGBUF(&sci->sc_segbufs); in nilfs_segctor_collect()
1432 err = nilfs_segctor_reset_segment_buffer(sci); in nilfs_segctor_collect()
1436 err = nilfs_segctor_collect_blocks(sci, mode); in nilfs_segctor_collect()
1437 sci->sc_nblk_this_inc += sci->sc_curseg->sb_sum.nblocks; in nilfs_segctor_collect()
1445 if (mode != SC_LSEG_SR || sci->sc_stage.scnt < NILFS_ST_CPFILE) in nilfs_segctor_collect()
1448 nilfs_clear_logs(&sci->sc_segbufs); in nilfs_segctor_collect()
1450 if (sci->sc_stage.flags & NILFS_CF_SUFREED) { in nilfs_segctor_collect()
1452 sci->sc_freesegs, in nilfs_segctor_collect()
1453 sci->sc_nfreesegs, in nilfs_segctor_collect()
1456 sci->sc_stage.flags &= ~NILFS_CF_SUFREED; in nilfs_segctor_collect()
1459 err = nilfs_segctor_extend_segments(sci, nilfs, nadd); in nilfs_segctor_collect()
1464 sci->sc_stage = prev_stage; in nilfs_segctor_collect()
1466 nilfs_segctor_truncate_segments(sci, sci->sc_curseg, nilfs->ns_sufile); in nilfs_segctor_collect()
1483 nilfs_segctor_update_payload_blocknr(struct nilfs_sc_info *sci, in nilfs_segctor_update_payload_blocknr() argument
1511 sci, &ssp, sizeof(*finfo)); in nilfs_segctor_update_payload_blocknr()
1536 sc_op->write_data_binfo(sci, &ssp, &binfo); in nilfs_segctor_update_payload_blocknr()
1538 sc_op->write_node_binfo(sci, &ssp, &binfo); in nilfs_segctor_update_payload_blocknr()
1555 static int nilfs_segctor_assign(struct nilfs_sc_info *sci, int mode) in nilfs_segctor_assign() argument
1560 list_for_each_entry(segbuf, &sci->sc_segbufs, sb_list) { in nilfs_segctor_assign()
1561 err = nilfs_segctor_update_payload_blocknr(sci, segbuf, mode); in nilfs_segctor_assign()
1582 static void nilfs_segctor_prepare_write(struct nilfs_sc_info *sci) in nilfs_segctor_prepare_write() argument
1587 list_for_each_entry(segbuf, &sci->sc_segbufs, sb_list) { in nilfs_segctor_prepare_write()
1631 static int nilfs_segctor_write(struct nilfs_sc_info *sci, in nilfs_segctor_write() argument
1636 ret = nilfs_write_logs(&sci->sc_segbufs, nilfs); in nilfs_segctor_write()
1637 list_splice_tail_init(&sci->sc_segbufs, &sci->sc_write_logs); in nilfs_segctor_write()
1720 static void nilfs_segctor_abort_construction(struct nilfs_sc_info *sci, in nilfs_segctor_abort_construction() argument
1726 list_splice_tail_init(&sci->sc_write_logs, &logs); in nilfs_segctor_abort_construction()
1730 list_splice_tail_init(&sci->sc_segbufs, &logs); in nilfs_segctor_abort_construction()
1734 if (sci->sc_stage.flags & NILFS_CF_SUFREED) { in nilfs_segctor_abort_construction()
1736 sci->sc_freesegs, in nilfs_segctor_abort_construction()
1737 sci->sc_nfreesegs, in nilfs_segctor_abort_construction()
1756 static void nilfs_segctor_complete_write(struct nilfs_sc_info *sci) in nilfs_segctor_complete_write() argument
1760 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_complete_write()
1763 list_for_each_entry(segbuf, &sci->sc_write_logs, sb_list) { in nilfs_segctor_complete_write()
1812 set_bit(NILFS_SC_UNCLOSED, &sci->sc_flags); in nilfs_segctor_complete_write()
1813 sci->sc_lseg_stime = jiffies; in nilfs_segctor_complete_write()
1816 clear_bit(NILFS_SC_UNCLOSED, &sci->sc_flags); in nilfs_segctor_complete_write()
1828 nilfs_drop_collected_inodes(&sci->sc_dirty_files); in nilfs_segctor_complete_write()
1831 nilfs_drop_collected_inodes(&sci->sc_gc_inodes); in nilfs_segctor_complete_write()
1833 nilfs->ns_nongc_ctime = sci->sc_seg_ctime; in nilfs_segctor_complete_write()
1835 sci->sc_nblk_inc += sci->sc_nblk_this_inc; in nilfs_segctor_complete_write()
1837 segbuf = NILFS_LAST_SEGBUF(&sci->sc_write_logs); in nilfs_segctor_complete_write()
1845 clear_bit(NILFS_SC_HAVE_DELTA, &sci->sc_flags); in nilfs_segctor_complete_write()
1846 clear_bit(NILFS_SC_DIRTY, &sci->sc_flags); in nilfs_segctor_complete_write()
1847 set_bit(NILFS_SC_SUPER_ROOT, &sci->sc_flags); in nilfs_segctor_complete_write()
1848 nilfs_segctor_clear_metadata_dirty(sci); in nilfs_segctor_complete_write()
1850 clear_bit(NILFS_SC_SUPER_ROOT, &sci->sc_flags); in nilfs_segctor_complete_write()
1853 static int nilfs_segctor_wait(struct nilfs_sc_info *sci) in nilfs_segctor_wait() argument
1857 ret = nilfs_wait_on_logs(&sci->sc_write_logs); in nilfs_segctor_wait()
1859 nilfs_segctor_complete_write(sci); in nilfs_segctor_wait()
1860 nilfs_destroy_logs(&sci->sc_write_logs); in nilfs_segctor_wait()
1865 static int nilfs_segctor_collect_dirty_files(struct nilfs_sc_info *sci, in nilfs_segctor_collect_dirty_files() argument
1869 struct inode *ifile = sci->sc_root->ifile; in nilfs_segctor_collect_dirty_files()
1882 nilfs_warning(sci->sc_super, __func__, in nilfs_segctor_collect_dirty_files()
1898 list_move_tail(&ii->i_dirty, &sci->sc_dirty_files); in nilfs_segctor_collect_dirty_files()
1905 static void nilfs_segctor_drop_written_files(struct nilfs_sc_info *sci, in nilfs_segctor_drop_written_files() argument
1909 int during_mount = !(sci->sc_super->s_flags & MS_ACTIVE); in nilfs_segctor_drop_written_files()
1913 list_for_each_entry_safe(ii, n, &sci->sc_dirty_files, i_dirty) { in nilfs_segctor_drop_written_files()
1927 list_add_tail(&ii->i_dirty, &sci->sc_iput_queue); in nilfs_segctor_drop_written_files()
1938 schedule_work(&sci->sc_iput_work); in nilfs_segctor_drop_written_files()
1944 static int nilfs_segctor_do_construct(struct nilfs_sc_info *sci, int mode) in nilfs_segctor_do_construct() argument
1946 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_do_construct()
1949 sci->sc_stage.scnt = NILFS_ST_INIT; in nilfs_segctor_do_construct()
1950 sci->sc_cno = nilfs->ns_cno; in nilfs_segctor_do_construct()
1952 err = nilfs_segctor_collect_dirty_files(sci, nilfs); in nilfs_segctor_do_construct()
1956 if (nilfs_test_metadata_dirty(nilfs, sci->sc_root)) in nilfs_segctor_do_construct()
1957 set_bit(NILFS_SC_DIRTY, &sci->sc_flags); in nilfs_segctor_do_construct()
1959 if (nilfs_segctor_clean(sci)) in nilfs_segctor_do_construct()
1963 sci->sc_stage.flags &= ~NILFS_CF_HISTORY_MASK; in nilfs_segctor_do_construct()
1965 err = nilfs_segctor_begin_construction(sci, nilfs); in nilfs_segctor_do_construct()
1970 sci->sc_seg_ctime = get_seconds(); in nilfs_segctor_do_construct()
1972 err = nilfs_segctor_collect(sci, nilfs, mode); in nilfs_segctor_do_construct()
1977 if (sci->sc_stage.scnt == NILFS_ST_DONE && in nilfs_segctor_do_construct()
1978 nilfs_segbuf_empty(sci->sc_curseg)) { in nilfs_segctor_do_construct()
1979 nilfs_segctor_abort_construction(sci, nilfs, 1); in nilfs_segctor_do_construct()
1983 err = nilfs_segctor_assign(sci, mode); in nilfs_segctor_do_construct()
1987 if (sci->sc_stage.flags & NILFS_CF_IFILE_STARTED) in nilfs_segctor_do_construct()
1988 nilfs_segctor_fill_in_file_bmap(sci); in nilfs_segctor_do_construct()
1991 sci->sc_stage.scnt >= NILFS_ST_CPFILE) { in nilfs_segctor_do_construct()
1992 err = nilfs_segctor_fill_in_checkpoint(sci); in nilfs_segctor_do_construct()
1996 nilfs_segctor_fill_in_super_root(sci, nilfs); in nilfs_segctor_do_construct()
1998 nilfs_segctor_update_segusage(sci, nilfs->ns_sufile); in nilfs_segctor_do_construct()
2001 nilfs_segctor_prepare_write(sci); in nilfs_segctor_do_construct()
2003 nilfs_add_checksums_on_logs(&sci->sc_segbufs, in nilfs_segctor_do_construct()
2006 err = nilfs_segctor_write(sci, nilfs); in nilfs_segctor_do_construct()
2010 if (sci->sc_stage.scnt == NILFS_ST_DONE || in nilfs_segctor_do_construct()
2019 err = nilfs_segctor_wait(sci); in nilfs_segctor_do_construct()
2023 } while (sci->sc_stage.scnt != NILFS_ST_DONE); in nilfs_segctor_do_construct()
2026 nilfs_segctor_drop_written_files(sci, nilfs); in nilfs_segctor_do_construct()
2030 if (sci->sc_stage.flags & NILFS_CF_IFILE_STARTED) in nilfs_segctor_do_construct()
2031 nilfs_redirty_inodes(&sci->sc_dirty_files); in nilfs_segctor_do_construct()
2035 nilfs_redirty_inodes(&sci->sc_gc_inodes); in nilfs_segctor_do_construct()
2036 nilfs_segctor_abort_construction(sci, nilfs, err); in nilfs_segctor_do_construct()
2048 static void nilfs_segctor_start_timer(struct nilfs_sc_info *sci) in nilfs_segctor_start_timer() argument
2050 spin_lock(&sci->sc_state_lock); in nilfs_segctor_start_timer()
2051 if (!(sci->sc_state & NILFS_SEGCTOR_COMMIT)) { in nilfs_segctor_start_timer()
2052 sci->sc_timer.expires = jiffies + sci->sc_interval; in nilfs_segctor_start_timer()
2053 add_timer(&sci->sc_timer); in nilfs_segctor_start_timer()
2054 sci->sc_state |= NILFS_SEGCTOR_COMMIT; in nilfs_segctor_start_timer()
2056 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_start_timer()
2059 static void nilfs_segctor_do_flush(struct nilfs_sc_info *sci, int bn) in nilfs_segctor_do_flush() argument
2061 spin_lock(&sci->sc_state_lock); in nilfs_segctor_do_flush()
2062 if (!(sci->sc_flush_request & (1 << bn))) { in nilfs_segctor_do_flush()
2063 unsigned long prev_req = sci->sc_flush_request; in nilfs_segctor_do_flush()
2065 sci->sc_flush_request |= (1 << bn); in nilfs_segctor_do_flush()
2067 wake_up(&sci->sc_wait_daemon); in nilfs_segctor_do_flush()
2069 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_do_flush()
2080 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_flush_segment() local
2082 if (!sci || nilfs_doing_construction()) in nilfs_flush_segment()
2084 nilfs_segctor_do_flush(sci, NILFS_MDT_INODE(sb, ino) ? ino : 0); in nilfs_flush_segment()
2095 static int nilfs_segctor_sync(struct nilfs_sc_info *sci) in nilfs_segctor_sync() argument
2100 spin_lock(&sci->sc_state_lock); in nilfs_segctor_sync()
2104 wait_req.seq = ++sci->sc_seq_request; in nilfs_segctor_sync()
2105 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_sync()
2108 add_wait_queue(&sci->sc_wait_request, &wait_req.wq); in nilfs_segctor_sync()
2110 wake_up(&sci->sc_wait_daemon); in nilfs_segctor_sync()
2124 finish_wait(&sci->sc_wait_request, &wait_req.wq); in nilfs_segctor_sync()
2128 static void nilfs_segctor_wakeup(struct nilfs_sc_info *sci, int err) in nilfs_segctor_wakeup() argument
2133 spin_lock_irqsave(&sci->sc_wait_request.lock, flags); in nilfs_segctor_wakeup()
2134 list_for_each_entry_safe(wrq, n, &sci->sc_wait_request.task_list, in nilfs_segctor_wakeup()
2137 nilfs_cnt32_ge(sci->sc_seq_done, wrq->seq)) { in nilfs_segctor_wakeup()
2147 spin_unlock_irqrestore(&sci->sc_wait_request.lock, flags); in nilfs_segctor_wakeup()
2170 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_construct_segment() local
2174 if (!sci) in nilfs_construct_segment()
2180 err = nilfs_segctor_sync(sci); in nilfs_construct_segment()
2208 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_construct_dsync_segment() local
2213 if (!sci) in nilfs_construct_dsync_segment()
2221 test_bit(NILFS_SC_UNCLOSED, &sci->sc_flags) || in nilfs_construct_dsync_segment()
2224 err = nilfs_segctor_sync(sci); in nilfs_construct_dsync_segment()
2236 sci->sc_dsync_inode = ii; in nilfs_construct_dsync_segment()
2237 sci->sc_dsync_start = start; in nilfs_construct_dsync_segment()
2238 sci->sc_dsync_end = end; in nilfs_construct_dsync_segment()
2240 err = nilfs_segctor_do_construct(sci, SC_LSEG_DSYNC); in nilfs_construct_dsync_segment()
2255 static void nilfs_segctor_accept(struct nilfs_sc_info *sci) in nilfs_segctor_accept() argument
2257 spin_lock(&sci->sc_state_lock); in nilfs_segctor_accept()
2258 sci->sc_seq_accepted = sci->sc_seq_request; in nilfs_segctor_accept()
2259 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_accept()
2260 del_timer_sync(&sci->sc_timer); in nilfs_segctor_accept()
2269 static void nilfs_segctor_notify(struct nilfs_sc_info *sci, int mode, int err) in nilfs_segctor_notify() argument
2272 spin_lock(&sci->sc_state_lock); in nilfs_segctor_notify()
2275 sci->sc_state &= ~NILFS_SEGCTOR_COMMIT; in nilfs_segctor_notify()
2276 sci->sc_seq_done = sci->sc_seq_accepted; in nilfs_segctor_notify()
2277 nilfs_segctor_wakeup(sci, err); in nilfs_segctor_notify()
2278 sci->sc_flush_request = 0; in nilfs_segctor_notify()
2281 sci->sc_flush_request &= ~FLUSH_FILE_BIT; in nilfs_segctor_notify()
2283 sci->sc_flush_request &= ~FLUSH_DAT_BIT; in nilfs_segctor_notify()
2286 if ((sci->sc_state & NILFS_SEGCTOR_COMMIT) && in nilfs_segctor_notify()
2287 time_before(jiffies, sci->sc_timer.expires)) in nilfs_segctor_notify()
2288 add_timer(&sci->sc_timer); in nilfs_segctor_notify()
2290 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_notify()
2298 static int nilfs_segctor_construct(struct nilfs_sc_info *sci, int mode) in nilfs_segctor_construct() argument
2300 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_construct()
2304 nilfs_segctor_accept(sci); in nilfs_segctor_construct()
2308 if (!nilfs_segctor_confirm(sci)) in nilfs_segctor_construct()
2309 err = nilfs_segctor_do_construct(sci, mode); in nilfs_segctor_construct()
2314 if (test_bit(NILFS_SC_SUPER_ROOT, &sci->sc_flags) && in nilfs_segctor_construct()
2318 sbp = nilfs_prepare_super(sci->sc_super, in nilfs_segctor_construct()
2322 err = nilfs_commit_super(sci->sc_super, in nilfs_segctor_construct()
2329 nilfs_segctor_notify(sci, mode, err); in nilfs_segctor_construct()
2358 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_clean_segments() local
2362 if (unlikely(!sci)) in nilfs_clean_segments()
2377 sci->sc_freesegs = kbufs[4]; in nilfs_clean_segments()
2378 sci->sc_nfreesegs = argv[4].v_nmembs; in nilfs_clean_segments()
2379 list_splice_tail_init(&nilfs->ns_gc_inodes, &sci->sc_gc_inodes); in nilfs_clean_segments()
2382 err = nilfs_segctor_construct(sci, SC_LSEG_SR); in nilfs_clean_segments()
2383 nilfs_remove_written_gcinodes(nilfs, &sci->sc_gc_inodes); in nilfs_clean_segments()
2391 schedule_timeout(sci->sc_interval); in nilfs_clean_segments()
2394 int ret = nilfs_discard_segments(nilfs, sci->sc_freesegs, in nilfs_clean_segments()
2395 sci->sc_nfreesegs); in nilfs_clean_segments()
2405 sci->sc_freesegs = NULL; in nilfs_clean_segments()
2406 sci->sc_nfreesegs = 0; in nilfs_clean_segments()
2412 static void nilfs_segctor_thread_construct(struct nilfs_sc_info *sci, int mode) in nilfs_segctor_thread_construct() argument
2416 nilfs_transaction_lock(sci->sc_super, &ti, 0); in nilfs_segctor_thread_construct()
2417 nilfs_segctor_construct(sci, mode); in nilfs_segctor_thread_construct()
2424 if (test_bit(NILFS_SC_UNCLOSED, &sci->sc_flags)) in nilfs_segctor_thread_construct()
2425 nilfs_segctor_start_timer(sci); in nilfs_segctor_thread_construct()
2427 nilfs_transaction_unlock(sci->sc_super); in nilfs_segctor_thread_construct()
2430 static void nilfs_segctor_do_immediate_flush(struct nilfs_sc_info *sci) in nilfs_segctor_do_immediate_flush() argument
2435 spin_lock(&sci->sc_state_lock); in nilfs_segctor_do_immediate_flush()
2436 mode = (sci->sc_flush_request & FLUSH_DAT_BIT) ? in nilfs_segctor_do_immediate_flush()
2438 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_do_immediate_flush()
2441 err = nilfs_segctor_do_construct(sci, mode); in nilfs_segctor_do_immediate_flush()
2443 spin_lock(&sci->sc_state_lock); in nilfs_segctor_do_immediate_flush()
2444 sci->sc_flush_request &= (mode == SC_FLUSH_FILE) ? in nilfs_segctor_do_immediate_flush()
2446 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_do_immediate_flush()
2448 clear_bit(NILFS_SC_PRIOR_FLUSH, &sci->sc_flags); in nilfs_segctor_do_immediate_flush()
2451 static int nilfs_segctor_flush_mode(struct nilfs_sc_info *sci) in nilfs_segctor_flush_mode() argument
2453 if (!test_bit(NILFS_SC_UNCLOSED, &sci->sc_flags) || in nilfs_segctor_flush_mode()
2454 time_before(jiffies, sci->sc_lseg_stime + sci->sc_mjcp_freq)) { in nilfs_segctor_flush_mode()
2455 if (!(sci->sc_flush_request & ~FLUSH_FILE_BIT)) in nilfs_segctor_flush_mode()
2457 else if (!(sci->sc_flush_request & ~FLUSH_DAT_BIT)) in nilfs_segctor_flush_mode()
2472 struct nilfs_sc_info *sci = (struct nilfs_sc_info *)arg; in nilfs_segctor_thread() local
2473 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_thread()
2476 sci->sc_timer.data = (unsigned long)current; in nilfs_segctor_thread()
2477 sci->sc_timer.function = nilfs_construction_timeout; in nilfs_segctor_thread()
2480 sci->sc_task = current; in nilfs_segctor_thread()
2481 wake_up(&sci->sc_wait_task); /* for nilfs_segctor_start_thread() */ in nilfs_segctor_thread()
2485 sci->sc_interval / HZ, sci->sc_mjcp_freq / HZ); in nilfs_segctor_thread()
2487 spin_lock(&sci->sc_state_lock); in nilfs_segctor_thread()
2492 if (sci->sc_state & NILFS_SEGCTOR_QUIT) in nilfs_segctor_thread()
2495 if (timeout || sci->sc_seq_request != sci->sc_seq_done) in nilfs_segctor_thread()
2497 else if (!sci->sc_flush_request) in nilfs_segctor_thread()
2500 mode = nilfs_segctor_flush_mode(sci); in nilfs_segctor_thread()
2502 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_thread()
2503 nilfs_segctor_thread_construct(sci, mode); in nilfs_segctor_thread()
2504 spin_lock(&sci->sc_state_lock); in nilfs_segctor_thread()
2510 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_thread()
2512 spin_lock(&sci->sc_state_lock); in nilfs_segctor_thread()
2517 prepare_to_wait(&sci->sc_wait_daemon, &wait, in nilfs_segctor_thread()
2520 if (sci->sc_seq_request != sci->sc_seq_done) in nilfs_segctor_thread()
2522 else if (sci->sc_flush_request) in nilfs_segctor_thread()
2524 else if (sci->sc_state & NILFS_SEGCTOR_COMMIT) in nilfs_segctor_thread()
2526 sci->sc_timer.expires); in nilfs_segctor_thread()
2529 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_thread()
2531 spin_lock(&sci->sc_state_lock); in nilfs_segctor_thread()
2533 finish_wait(&sci->sc_wait_daemon, &wait); in nilfs_segctor_thread()
2534 timeout = ((sci->sc_state & NILFS_SEGCTOR_COMMIT) && in nilfs_segctor_thread()
2535 time_after_eq(jiffies, sci->sc_timer.expires)); in nilfs_segctor_thread()
2543 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_thread()
2546 sci->sc_task = NULL; in nilfs_segctor_thread()
2547 wake_up(&sci->sc_wait_task); /* for nilfs_segctor_kill_thread() */ in nilfs_segctor_thread()
2551 static int nilfs_segctor_start_thread(struct nilfs_sc_info *sci) in nilfs_segctor_start_thread() argument
2555 t = kthread_run(nilfs_segctor_thread, sci, "segctord"); in nilfs_segctor_start_thread()
2563 wait_event(sci->sc_wait_task, sci->sc_task != NULL); in nilfs_segctor_start_thread()
2567 static void nilfs_segctor_kill_thread(struct nilfs_sc_info *sci) in nilfs_segctor_kill_thread() argument
2568 __acquires(&sci->sc_state_lock) in nilfs_segctor_kill_thread()
2569 __releases(&sci->sc_state_lock) in nilfs_segctor_kill_thread()
2571 sci->sc_state |= NILFS_SEGCTOR_QUIT; in nilfs_segctor_kill_thread()
2573 while (sci->sc_task) { in nilfs_segctor_kill_thread()
2574 wake_up(&sci->sc_wait_daemon); in nilfs_segctor_kill_thread()
2575 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_kill_thread()
2576 wait_event(sci->sc_wait_task, sci->sc_task == NULL); in nilfs_segctor_kill_thread()
2577 spin_lock(&sci->sc_state_lock); in nilfs_segctor_kill_thread()
2588 struct nilfs_sc_info *sci; in nilfs_segctor_new() local
2590 sci = kzalloc(sizeof(*sci), GFP_KERNEL); in nilfs_segctor_new()
2591 if (!sci) in nilfs_segctor_new()
2594 sci->sc_super = sb; in nilfs_segctor_new()
2597 sci->sc_root = root; in nilfs_segctor_new()
2599 init_waitqueue_head(&sci->sc_wait_request); in nilfs_segctor_new()
2600 init_waitqueue_head(&sci->sc_wait_daemon); in nilfs_segctor_new()
2601 init_waitqueue_head(&sci->sc_wait_task); in nilfs_segctor_new()
2602 spin_lock_init(&sci->sc_state_lock); in nilfs_segctor_new()
2603 INIT_LIST_HEAD(&sci->sc_dirty_files); in nilfs_segctor_new()
2604 INIT_LIST_HEAD(&sci->sc_segbufs); in nilfs_segctor_new()
2605 INIT_LIST_HEAD(&sci->sc_write_logs); in nilfs_segctor_new()
2606 INIT_LIST_HEAD(&sci->sc_gc_inodes); in nilfs_segctor_new()
2607 INIT_LIST_HEAD(&sci->sc_iput_queue); in nilfs_segctor_new()
2608 INIT_WORK(&sci->sc_iput_work, nilfs_iput_work_func); in nilfs_segctor_new()
2609 init_timer(&sci->sc_timer); in nilfs_segctor_new()
2611 sci->sc_interval = HZ * NILFS_SC_DEFAULT_TIMEOUT; in nilfs_segctor_new()
2612 sci->sc_mjcp_freq = HZ * NILFS_SC_DEFAULT_SR_FREQ; in nilfs_segctor_new()
2613 sci->sc_watermark = NILFS_SC_DEFAULT_WATERMARK; in nilfs_segctor_new()
2616 sci->sc_interval = HZ * nilfs->ns_interval; in nilfs_segctor_new()
2618 sci->sc_watermark = nilfs->ns_watermark; in nilfs_segctor_new()
2619 return sci; in nilfs_segctor_new()
2622 static void nilfs_segctor_write_out(struct nilfs_sc_info *sci) in nilfs_segctor_write_out() argument
2631 nilfs_transaction_lock(sci->sc_super, &ti, 0); in nilfs_segctor_write_out()
2632 ret = nilfs_segctor_construct(sci, SC_LSEG_SR); in nilfs_segctor_write_out()
2633 nilfs_transaction_unlock(sci->sc_super); in nilfs_segctor_write_out()
2635 flush_work(&sci->sc_iput_work); in nilfs_segctor_write_out()
2648 static void nilfs_segctor_destroy(struct nilfs_sc_info *sci) in nilfs_segctor_destroy() argument
2650 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_destroy()
2655 spin_lock(&sci->sc_state_lock); in nilfs_segctor_destroy()
2656 nilfs_segctor_kill_thread(sci); in nilfs_segctor_destroy()
2657 flag = ((sci->sc_state & NILFS_SEGCTOR_COMMIT) || sci->sc_flush_request in nilfs_segctor_destroy()
2658 || sci->sc_seq_request != sci->sc_seq_done); in nilfs_segctor_destroy()
2659 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_destroy()
2661 if (flush_work(&sci->sc_iput_work)) in nilfs_segctor_destroy()
2664 if (flag || !nilfs_segctor_confirm(sci)) in nilfs_segctor_destroy()
2665 nilfs_segctor_write_out(sci); in nilfs_segctor_destroy()
2667 if (!list_empty(&sci->sc_dirty_files)) { in nilfs_segctor_destroy()
2668 nilfs_warning(sci->sc_super, __func__, in nilfs_segctor_destroy()
2670 nilfs_dispose_list(nilfs, &sci->sc_dirty_files, 1); in nilfs_segctor_destroy()
2673 if (!list_empty(&sci->sc_iput_queue)) { in nilfs_segctor_destroy()
2674 nilfs_warning(sci->sc_super, __func__, in nilfs_segctor_destroy()
2676 nilfs_dispose_list(nilfs, &sci->sc_iput_queue, 1); in nilfs_segctor_destroy()
2679 WARN_ON(!list_empty(&sci->sc_segbufs)); in nilfs_segctor_destroy()
2680 WARN_ON(!list_empty(&sci->sc_write_logs)); in nilfs_segctor_destroy()
2682 nilfs_put_root(sci->sc_root); in nilfs_segctor_destroy()
2686 del_timer_sync(&sci->sc_timer); in nilfs_segctor_destroy()
2687 kfree(sci); in nilfs_segctor_destroy()