Lines Matching full:sci
90 static inline void nilfs_sc_cstage_inc(struct nilfs_sc_info *sci) in nilfs_sc_cstage_inc() argument
92 sci->sc_stage.scnt++; in nilfs_sc_cstage_inc()
93 trace_nilfs2_collection_stage_transition(sci); in nilfs_sc_cstage_inc()
96 static inline void nilfs_sc_cstage_set(struct nilfs_sc_info *sci, int next_scnt) in nilfs_sc_cstage_set() argument
98 sci->sc_stage.scnt = next_scnt; in nilfs_sc_cstage_set()
99 trace_nilfs2_collection_stage_transition(sci); in nilfs_sc_cstage_set()
102 static inline int nilfs_sc_cstage_get(struct nilfs_sc_info *sci) in nilfs_sc_cstage_get() argument
104 return sci->sc_stage.scnt; in nilfs_sc_cstage_get()
276 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_transaction_commit() local
279 nilfs_segctor_start_timer(sci); in nilfs_transaction_commit()
280 if (atomic_read(&nilfs->ns_ndirtyblks) > sci->sc_watermark) in nilfs_transaction_commit()
281 nilfs_segctor_do_flush(sci, 0); in nilfs_transaction_commit()
323 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_relax_pressure_in_lock() local
325 if (!sci || !sci->sc_flush_request) in nilfs_relax_pressure_in_lock()
328 set_bit(NILFS_SC_PRIOR_FLUSH, &sci->sc_flags); in nilfs_relax_pressure_in_lock()
332 if (sci->sc_flush_request && in nilfs_relax_pressure_in_lock()
333 test_bit(NILFS_SC_PRIOR_FLUSH, &sci->sc_flags)) { in nilfs_relax_pressure_in_lock()
337 nilfs_segctor_do_immediate_flush(sci); in nilfs_relax_pressure_in_lock()
349 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_transaction_lock() local
363 if (!test_bit(NILFS_SC_PRIOR_FLUSH, &sci->sc_flags)) in nilfs_transaction_lock()
366 nilfs_segctor_do_immediate_flush(sci); in nilfs_transaction_lock()
393 static void *nilfs_segctor_map_segsum_entry(struct nilfs_sc_info *sci, in nilfs_segctor_map_segsum_entry() argument
397 struct nilfs_segment_buffer *segbuf = sci->sc_curseg; in nilfs_segctor_map_segsum_entry()
398 unsigned int blocksize = sci->sc_super->s_blocksize; in nilfs_segctor_map_segsum_entry()
414 * @sci: nilfs_sc_info
416 static int nilfs_segctor_reset_segment_buffer(struct nilfs_sc_info *sci) in nilfs_segctor_reset_segment_buffer() argument
418 struct nilfs_segment_buffer *segbuf = sci->sc_curseg; in nilfs_segctor_reset_segment_buffer()
426 err = nilfs_segbuf_reset(segbuf, flags, sci->sc_seg_ctime, sci->sc_cno); in nilfs_segctor_reset_segment_buffer()
432 sci->sc_finfo_ptr.bh = sumbh; sci->sc_finfo_ptr.offset = sumbytes; in nilfs_segctor_reset_segment_buffer()
433 sci->sc_binfo_ptr.bh = sumbh; sci->sc_binfo_ptr.offset = sumbytes; in nilfs_segctor_reset_segment_buffer()
434 sci->sc_blk_cnt = sci->sc_datablk_cnt = 0; in nilfs_segctor_reset_segment_buffer()
438 static int nilfs_segctor_feed_segment(struct nilfs_sc_info *sci) in nilfs_segctor_feed_segment() argument
440 sci->sc_nblk_this_inc += sci->sc_curseg->sb_sum.nblocks; in nilfs_segctor_feed_segment()
441 if (NILFS_SEGBUF_IS_LAST(sci->sc_curseg, &sci->sc_segbufs)) in nilfs_segctor_feed_segment()
446 sci->sc_curseg = NILFS_NEXT_SEGBUF(sci->sc_curseg); in nilfs_segctor_feed_segment()
447 return nilfs_segctor_reset_segment_buffer(sci); in nilfs_segctor_feed_segment()
450 static int nilfs_segctor_add_super_root(struct nilfs_sc_info *sci) in nilfs_segctor_add_super_root() argument
452 struct nilfs_segment_buffer *segbuf = sci->sc_curseg; in nilfs_segctor_add_super_root()
456 err = nilfs_segctor_feed_segment(sci); in nilfs_segctor_add_super_root()
459 segbuf = sci->sc_curseg; in nilfs_segctor_add_super_root()
471 struct nilfs_sc_info *sci, const struct nilfs_segsum_pointer *ssp, in nilfs_segctor_segsum_block_required() argument
474 unsigned int blocksize = sci->sc_super->s_blocksize; in nilfs_segctor_segsum_block_required()
478 (!sci->sc_blk_cnt ? sizeof(struct nilfs_finfo) : 0) > in nilfs_segctor_segsum_block_required()
482 static void nilfs_segctor_begin_finfo(struct nilfs_sc_info *sci, in nilfs_segctor_begin_finfo() argument
485 sci->sc_curseg->sb_sum.nfinfo++; in nilfs_segctor_begin_finfo()
486 sci->sc_binfo_ptr = sci->sc_finfo_ptr; in nilfs_segctor_begin_finfo()
488 sci, &sci->sc_binfo_ptr, sizeof(struct nilfs_finfo)); in nilfs_segctor_begin_finfo()
491 !test_bit(NILFS_SC_HAVE_DELTA, &sci->sc_flags)) in nilfs_segctor_begin_finfo()
492 set_bit(NILFS_SC_HAVE_DELTA, &sci->sc_flags); in nilfs_segctor_begin_finfo()
496 static void nilfs_segctor_end_finfo(struct nilfs_sc_info *sci, in nilfs_segctor_end_finfo() argument
504 if (sci->sc_blk_cnt == 0) in nilfs_segctor_end_finfo()
514 cno = sci->sc_cno; in nilfs_segctor_end_finfo()
516 finfo = nilfs_segctor_map_segsum_entry(sci, &sci->sc_finfo_ptr, in nilfs_segctor_end_finfo()
519 finfo->fi_nblocks = cpu_to_le32(sci->sc_blk_cnt); in nilfs_segctor_end_finfo()
520 finfo->fi_ndatablk = cpu_to_le32(sci->sc_datablk_cnt); in nilfs_segctor_end_finfo()
523 segbuf = sci->sc_curseg; in nilfs_segctor_end_finfo()
524 segbuf->sb_sum.sumbytes = sci->sc_binfo_ptr.offset + in nilfs_segctor_end_finfo()
525 sci->sc_super->s_blocksize * (segbuf->sb_sum.nsumblk - 1); in nilfs_segctor_end_finfo()
526 sci->sc_finfo_ptr = sci->sc_binfo_ptr; in nilfs_segctor_end_finfo()
527 sci->sc_blk_cnt = sci->sc_datablk_cnt = 0; in nilfs_segctor_end_finfo()
530 static int nilfs_segctor_add_file_block(struct nilfs_sc_info *sci, in nilfs_segctor_add_file_block() argument
539 segbuf = sci->sc_curseg; in nilfs_segctor_add_file_block()
541 sci, &sci->sc_binfo_ptr, binfo_size); in nilfs_segctor_add_file_block()
543 nilfs_segctor_end_finfo(sci, inode); in nilfs_segctor_add_file_block()
544 err = nilfs_segctor_feed_segment(sci); in nilfs_segctor_add_file_block()
554 if (sci->sc_blk_cnt == 0) in nilfs_segctor_add_file_block()
555 nilfs_segctor_begin_finfo(sci, inode); in nilfs_segctor_add_file_block()
557 nilfs_segctor_map_segsum_entry(sci, &sci->sc_binfo_ptr, binfo_size); in nilfs_segctor_add_file_block()
560 sci->sc_blk_cnt++; in nilfs_segctor_add_file_block()
568 static int nilfs_collect_file_data(struct nilfs_sc_info *sci, in nilfs_collect_file_data() argument
577 err = nilfs_segctor_add_file_block(sci, bh, inode, in nilfs_collect_file_data()
580 sci->sc_datablk_cnt++; in nilfs_collect_file_data()
584 static int nilfs_collect_file_node(struct nilfs_sc_info *sci, in nilfs_collect_file_node() argument
591 static int nilfs_collect_file_bmap(struct nilfs_sc_info *sci, in nilfs_collect_file_bmap() argument
596 return nilfs_segctor_add_file_block(sci, bh, inode, sizeof(__le64)); in nilfs_collect_file_bmap()
599 static void nilfs_write_file_data_binfo(struct nilfs_sc_info *sci, in nilfs_write_file_data_binfo() argument
604 sci, ssp, sizeof(*binfo_v)); in nilfs_write_file_data_binfo()
608 static void nilfs_write_file_node_binfo(struct nilfs_sc_info *sci, in nilfs_write_file_node_binfo() argument
613 sci, ssp, sizeof(*vblocknr)); in nilfs_write_file_node_binfo()
625 static int nilfs_collect_dat_data(struct nilfs_sc_info *sci, in nilfs_collect_dat_data() argument
634 err = nilfs_segctor_add_file_block(sci, bh, inode, sizeof(__le64)); in nilfs_collect_dat_data()
636 sci->sc_datablk_cnt++; in nilfs_collect_dat_data()
640 static int nilfs_collect_dat_bmap(struct nilfs_sc_info *sci, in nilfs_collect_dat_bmap() argument
644 return nilfs_segctor_add_file_block(sci, bh, inode, in nilfs_collect_dat_bmap()
648 static void nilfs_write_dat_data_binfo(struct nilfs_sc_info *sci, in nilfs_write_dat_data_binfo() argument
652 __le64 *blkoff = nilfs_segctor_map_segsum_entry(sci, ssp, in nilfs_write_dat_data_binfo()
657 static void nilfs_write_dat_node_binfo(struct nilfs_sc_info *sci, in nilfs_write_dat_node_binfo() argument
662 nilfs_segctor_map_segsum_entry(sci, ssp, sizeof(*binfo_dat)); in nilfs_write_dat_node_binfo()
803 struct nilfs_sc_info *sci = container_of(work, struct nilfs_sc_info, in nilfs_iput_work_func() local
805 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_iput_work_func()
807 nilfs_dispose_list(nilfs, &sci->sc_iput_queue, 0); in nilfs_iput_work_func()
826 static int nilfs_segctor_clean(struct nilfs_sc_info *sci) in nilfs_segctor_clean() argument
828 return list_empty(&sci->sc_dirty_files) && in nilfs_segctor_clean()
829 !test_bit(NILFS_SC_DIRTY, &sci->sc_flags) && in nilfs_segctor_clean()
830 sci->sc_nfreesegs == 0 && in nilfs_segctor_clean()
831 (!nilfs_doing_gc() || list_empty(&sci->sc_gc_inodes)); in nilfs_segctor_clean()
834 static int nilfs_segctor_confirm(struct nilfs_sc_info *sci) in nilfs_segctor_confirm() argument
836 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_confirm()
839 if (nilfs_test_metadata_dirty(nilfs, sci->sc_root)) in nilfs_segctor_confirm()
840 set_bit(NILFS_SC_DIRTY, &sci->sc_flags); in nilfs_segctor_confirm()
843 if (list_empty(&nilfs->ns_dirty_files) && nilfs_segctor_clean(sci)) in nilfs_segctor_confirm()
850 static void nilfs_segctor_clear_metadata_dirty(struct nilfs_sc_info *sci) in nilfs_segctor_clear_metadata_dirty() argument
852 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_clear_metadata_dirty()
854 nilfs_mdt_clear_dirty(sci->sc_root->ifile); in nilfs_segctor_clear_metadata_dirty()
860 static int nilfs_segctor_create_checkpoint(struct nilfs_sc_info *sci) in nilfs_segctor_create_checkpoint() argument
862 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_create_checkpoint()
886 static int nilfs_segctor_fill_in_checkpoint(struct nilfs_sc_info *sci) in nilfs_segctor_fill_in_checkpoint() argument
888 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_fill_in_checkpoint()
902 cpu_to_le64(atomic64_read(&sci->sc_root->inodes_count)); in nilfs_segctor_fill_in_checkpoint()
904 cpu_to_le64(atomic64_read(&sci->sc_root->blocks_count)); in nilfs_segctor_fill_in_checkpoint()
906 cpu_to_le64(sci->sc_nblk_inc + sci->sc_nblk_this_inc); in nilfs_segctor_fill_in_checkpoint()
907 raw_cp->cp_create = cpu_to_le64(sci->sc_seg_ctime); in nilfs_segctor_fill_in_checkpoint()
910 if (test_bit(NILFS_SC_HAVE_DELTA, &sci->sc_flags)) in nilfs_segctor_fill_in_checkpoint()
915 nilfs_write_inode_common(sci->sc_root->ifile, in nilfs_segctor_fill_in_checkpoint()
941 static void nilfs_segctor_fill_in_file_bmap(struct nilfs_sc_info *sci) in nilfs_segctor_fill_in_file_bmap() argument
945 list_for_each_entry(ii, &sci->sc_dirty_files, i_dirty) { in nilfs_segctor_fill_in_file_bmap()
946 nilfs_fill_in_file_bmap(sci->sc_root->ifile, ii); in nilfs_segctor_fill_in_file_bmap()
951 static void nilfs_segctor_fill_in_super_root(struct nilfs_sc_info *sci, in nilfs_segctor_fill_in_super_root() argument
958 bh_sr = NILFS_LAST_SEGBUF(&sci->sc_segbufs)->sb_super_root; in nilfs_segctor_fill_in_super_root()
966 nilfs->ns_nongc_ctime : sci->sc_seg_ctime); in nilfs_segctor_fill_in_super_root()
1001 static int nilfs_segctor_apply_buffers(struct nilfs_sc_info *sci, in nilfs_segctor_apply_buffers() argument
1014 err = collect(sci, bh, inode); in nilfs_segctor_apply_buffers()
1032 static size_t nilfs_segctor_buffer_rest(struct nilfs_sc_info *sci) in nilfs_segctor_buffer_rest() argument
1035 return sci->sc_segbuf_nblocks - in nilfs_segctor_buffer_rest()
1036 (sci->sc_nblk_this_inc + sci->sc_curseg->sb_sum.nblocks); in nilfs_segctor_buffer_rest()
1039 static int nilfs_segctor_scan_file(struct nilfs_sc_info *sci, in nilfs_segctor_scan_file() argument
1047 if (!(sci->sc_stage.flags & NILFS_CF_NODE)) { in nilfs_segctor_scan_file()
1048 size_t n, rest = nilfs_segctor_buffer_rest(sci); in nilfs_segctor_scan_file()
1054 sci, inode, &data_buffers, in nilfs_segctor_scan_file()
1062 if (!(sci->sc_stage.flags & NILFS_CF_NODE)) { in nilfs_segctor_scan_file()
1064 sci, inode, &data_buffers, sc_ops->collect_data); in nilfs_segctor_scan_file()
1068 sci, inode, &node_buffers, NULL); in nilfs_segctor_scan_file()
1071 sci->sc_stage.flags |= NILFS_CF_NODE; in nilfs_segctor_scan_file()
1075 sci, inode, &node_buffers, sc_ops->collect_node); in nilfs_segctor_scan_file()
1081 sci, inode, &node_buffers, sc_ops->collect_bmap); in nilfs_segctor_scan_file()
1085 nilfs_segctor_end_finfo(sci, inode); in nilfs_segctor_scan_file()
1086 sci->sc_stage.flags &= ~NILFS_CF_NODE; in nilfs_segctor_scan_file()
1092 static int nilfs_segctor_scan_file_dsync(struct nilfs_sc_info *sci, in nilfs_segctor_scan_file_dsync() argument
1096 size_t n, rest = nilfs_segctor_buffer_rest(sci); in nilfs_segctor_scan_file_dsync()
1100 sci->sc_dsync_start, in nilfs_segctor_scan_file_dsync()
1101 sci->sc_dsync_end); in nilfs_segctor_scan_file_dsync()
1103 err = nilfs_segctor_apply_buffers(sci, inode, &data_buffers, in nilfs_segctor_scan_file_dsync()
1106 nilfs_segctor_end_finfo(sci, inode); in nilfs_segctor_scan_file_dsync()
1113 static int nilfs_segctor_collect_blocks(struct nilfs_sc_info *sci, int mode) in nilfs_segctor_collect_blocks() argument
1115 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_collect_blocks()
1121 switch (nilfs_sc_cstage_get(sci)) { in nilfs_segctor_collect_blocks()
1124 sci->sc_stage.flags = 0; in nilfs_segctor_collect_blocks()
1126 if (!test_bit(NILFS_SC_UNCLOSED, &sci->sc_flags)) { in nilfs_segctor_collect_blocks()
1127 sci->sc_nblk_inc = 0; in nilfs_segctor_collect_blocks()
1128 sci->sc_curseg->sb_sum.flags = NILFS_SS_LOGBGN; in nilfs_segctor_collect_blocks()
1130 nilfs_sc_cstage_set(sci, NILFS_ST_DSYNC); in nilfs_segctor_collect_blocks()
1135 sci->sc_stage.dirty_file_ptr = NULL; in nilfs_segctor_collect_blocks()
1136 sci->sc_stage.gc_inode_ptr = NULL; in nilfs_segctor_collect_blocks()
1138 nilfs_sc_cstage_set(sci, NILFS_ST_DAT); in nilfs_segctor_collect_blocks()
1141 nilfs_sc_cstage_inc(sci); in nilfs_segctor_collect_blocks()
1145 head = &sci->sc_gc_inodes; in nilfs_segctor_collect_blocks()
1146 ii = list_prepare_entry(sci->sc_stage.gc_inode_ptr, in nilfs_segctor_collect_blocks()
1150 sci, &ii->vfs_inode, in nilfs_segctor_collect_blocks()
1153 sci->sc_stage.gc_inode_ptr = list_entry( in nilfs_segctor_collect_blocks()
1161 sci->sc_stage.gc_inode_ptr = NULL; in nilfs_segctor_collect_blocks()
1163 nilfs_sc_cstage_inc(sci); in nilfs_segctor_collect_blocks()
1166 head = &sci->sc_dirty_files; in nilfs_segctor_collect_blocks()
1167 ii = list_prepare_entry(sci->sc_stage.dirty_file_ptr, head, in nilfs_segctor_collect_blocks()
1172 err = nilfs_segctor_scan_file(sci, &ii->vfs_inode, in nilfs_segctor_collect_blocks()
1175 sci->sc_stage.dirty_file_ptr = in nilfs_segctor_collect_blocks()
1181 /* sci->sc_stage.dirty_file_ptr = NILFS_I(inode); */ in nilfs_segctor_collect_blocks()
1184 sci->sc_stage.dirty_file_ptr = NULL; in nilfs_segctor_collect_blocks()
1186 nilfs_sc_cstage_set(sci, NILFS_ST_DONE); in nilfs_segctor_collect_blocks()
1189 nilfs_sc_cstage_inc(sci); in nilfs_segctor_collect_blocks()
1190 sci->sc_stage.flags |= NILFS_CF_IFILE_STARTED; in nilfs_segctor_collect_blocks()
1193 err = nilfs_segctor_scan_file(sci, sci->sc_root->ifile, in nilfs_segctor_collect_blocks()
1197 nilfs_sc_cstage_inc(sci); in nilfs_segctor_collect_blocks()
1199 err = nilfs_segctor_create_checkpoint(sci); in nilfs_segctor_collect_blocks()
1204 err = nilfs_segctor_scan_file(sci, nilfs->ns_cpfile, in nilfs_segctor_collect_blocks()
1208 nilfs_sc_cstage_inc(sci); in nilfs_segctor_collect_blocks()
1211 err = nilfs_sufile_freev(nilfs->ns_sufile, sci->sc_freesegs, in nilfs_segctor_collect_blocks()
1212 sci->sc_nfreesegs, &ndone); in nilfs_segctor_collect_blocks()
1215 sci->sc_freesegs, ndone, in nilfs_segctor_collect_blocks()
1219 sci->sc_stage.flags |= NILFS_CF_SUFREED; in nilfs_segctor_collect_blocks()
1221 err = nilfs_segctor_scan_file(sci, nilfs->ns_sufile, in nilfs_segctor_collect_blocks()
1225 nilfs_sc_cstage_inc(sci); in nilfs_segctor_collect_blocks()
1229 err = nilfs_segctor_scan_file(sci, nilfs->ns_dat, in nilfs_segctor_collect_blocks()
1234 nilfs_sc_cstage_set(sci, NILFS_ST_DONE); in nilfs_segctor_collect_blocks()
1237 nilfs_sc_cstage_inc(sci); in nilfs_segctor_collect_blocks()
1242 err = nilfs_segctor_add_super_root(sci); in nilfs_segctor_collect_blocks()
1247 sci->sc_curseg->sb_sum.flags |= NILFS_SS_LOGEND; in nilfs_segctor_collect_blocks()
1248 nilfs_sc_cstage_set(sci, NILFS_ST_DONE); in nilfs_segctor_collect_blocks()
1252 sci->sc_curseg->sb_sum.flags |= NILFS_SS_SYNDT; in nilfs_segctor_collect_blocks()
1253 ii = sci->sc_dsync_inode; in nilfs_segctor_collect_blocks()
1257 err = nilfs_segctor_scan_file_dsync(sci, &ii->vfs_inode); in nilfs_segctor_collect_blocks()
1260 sci->sc_curseg->sb_sum.flags |= NILFS_SS_LOGEND; in nilfs_segctor_collect_blocks()
1261 nilfs_sc_cstage_set(sci, NILFS_ST_DONE); in nilfs_segctor_collect_blocks()
1275 * @sci: nilfs_sc_info
1278 static int nilfs_segctor_begin_construction(struct nilfs_sc_info *sci, in nilfs_segctor_begin_construction() argument
1285 segbuf = nilfs_segbuf_new(sci->sc_super); in nilfs_segctor_begin_construction()
1289 if (list_empty(&sci->sc_write_logs)) { in nilfs_segctor_begin_construction()
1305 prev = NILFS_LAST_SEGBUF(&sci->sc_write_logs); in nilfs_segctor_begin_construction()
1328 BUG_ON(!list_empty(&sci->sc_segbufs)); in nilfs_segctor_begin_construction()
1329 list_add_tail(&segbuf->sb_list, &sci->sc_segbufs); in nilfs_segctor_begin_construction()
1330 sci->sc_segbuf_nblocks = segbuf->sb_rest_blocks; in nilfs_segctor_begin_construction()
1338 static int nilfs_segctor_extend_segments(struct nilfs_sc_info *sci, in nilfs_segctor_extend_segments() argument
1347 prev = NILFS_LAST_SEGBUF(&sci->sc_segbufs); in nilfs_segctor_extend_segments()
1361 segbuf = nilfs_segbuf_new(sci->sc_super); in nilfs_segctor_extend_segments()
1367 sci->sc_segbuf_nblocks += segbuf->sb_rest_blocks; in nilfs_segctor_extend_segments()
1380 list_splice_tail(&list, &sci->sc_segbufs); in nilfs_segctor_extend_segments()
1433 static void nilfs_segctor_update_segusage(struct nilfs_sc_info *sci, in nilfs_segctor_update_segusage() argument
1440 list_for_each_entry(segbuf, &sci->sc_segbufs, sb_list) { in nilfs_segctor_update_segusage()
1445 sci->sc_seg_ctime); in nilfs_segctor_update_segusage()
1468 static void nilfs_segctor_truncate_segments(struct nilfs_sc_info *sci, in nilfs_segctor_truncate_segments() argument
1475 list_for_each_entry_continue(segbuf, &sci->sc_segbufs, sb_list) { in nilfs_segctor_truncate_segments()
1476 sci->sc_segbuf_nblocks -= segbuf->sb_rest_blocks; in nilfs_segctor_truncate_segments()
1480 nilfs_truncate_logs(&sci->sc_segbufs, last); in nilfs_segctor_truncate_segments()
1484 static int nilfs_segctor_collect(struct nilfs_sc_info *sci, in nilfs_segctor_collect() argument
1487 struct nilfs_cstage prev_stage = sci->sc_stage; in nilfs_segctor_collect()
1492 sci->sc_nblk_this_inc = 0; in nilfs_segctor_collect()
1493 sci->sc_curseg = NILFS_FIRST_SEGBUF(&sci->sc_segbufs); in nilfs_segctor_collect()
1495 err = nilfs_segctor_reset_segment_buffer(sci); in nilfs_segctor_collect()
1499 err = nilfs_segctor_collect_blocks(sci, mode); in nilfs_segctor_collect()
1500 sci->sc_nblk_this_inc += sci->sc_curseg->sb_sum.nblocks; in nilfs_segctor_collect()
1509 nilfs_sc_cstage_get(sci) < NILFS_ST_CPFILE) in nilfs_segctor_collect()
1512 nilfs_clear_logs(&sci->sc_segbufs); in nilfs_segctor_collect()
1514 if (sci->sc_stage.flags & NILFS_CF_SUFREED) { in nilfs_segctor_collect()
1516 sci->sc_freesegs, in nilfs_segctor_collect()
1517 sci->sc_nfreesegs, in nilfs_segctor_collect()
1520 sci->sc_stage.flags &= ~NILFS_CF_SUFREED; in nilfs_segctor_collect()
1523 err = nilfs_segctor_extend_segments(sci, nilfs, nadd); in nilfs_segctor_collect()
1528 sci->sc_stage = prev_stage; in nilfs_segctor_collect()
1530 nilfs_segctor_truncate_segments(sci, sci->sc_curseg, nilfs->ns_sufile); in nilfs_segctor_collect()
1547 nilfs_segctor_update_payload_blocknr(struct nilfs_sc_info *sci, in nilfs_segctor_update_payload_blocknr() argument
1575 sci, &ssp, sizeof(*finfo)); in nilfs_segctor_update_payload_blocknr()
1600 sc_op->write_data_binfo(sci, &ssp, &binfo); in nilfs_segctor_update_payload_blocknr()
1602 sc_op->write_node_binfo(sci, &ssp, &binfo); in nilfs_segctor_update_payload_blocknr()
1619 static int nilfs_segctor_assign(struct nilfs_sc_info *sci, int mode) in nilfs_segctor_assign() argument
1624 list_for_each_entry(segbuf, &sci->sc_segbufs, sb_list) { in nilfs_segctor_assign()
1625 err = nilfs_segctor_update_payload_blocknr(sci, segbuf, mode); in nilfs_segctor_assign()
1648 static void nilfs_segctor_prepare_write(struct nilfs_sc_info *sci) in nilfs_segctor_prepare_write() argument
1653 list_for_each_entry(segbuf, &sci->sc_segbufs, sb_list) { in nilfs_segctor_prepare_write()
1697 static int nilfs_segctor_write(struct nilfs_sc_info *sci, in nilfs_segctor_write() argument
1702 ret = nilfs_write_logs(&sci->sc_segbufs, nilfs); in nilfs_segctor_write()
1703 list_splice_tail_init(&sci->sc_segbufs, &sci->sc_write_logs); in nilfs_segctor_write()
1786 static void nilfs_segctor_abort_construction(struct nilfs_sc_info *sci, in nilfs_segctor_abort_construction() argument
1792 list_splice_tail_init(&sci->sc_write_logs, &logs); in nilfs_segctor_abort_construction()
1796 list_splice_tail_init(&sci->sc_segbufs, &logs); in nilfs_segctor_abort_construction()
1800 if (sci->sc_stage.flags & NILFS_CF_SUFREED) { in nilfs_segctor_abort_construction()
1802 sci->sc_freesegs, in nilfs_segctor_abort_construction()
1803 sci->sc_nfreesegs, in nilfs_segctor_abort_construction()
1822 static void nilfs_segctor_complete_write(struct nilfs_sc_info *sci) in nilfs_segctor_complete_write() argument
1826 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_complete_write()
1829 list_for_each_entry(segbuf, &sci->sc_write_logs, sb_list) { in nilfs_segctor_complete_write()
1878 set_bit(NILFS_SC_UNCLOSED, &sci->sc_flags); in nilfs_segctor_complete_write()
1879 sci->sc_lseg_stime = jiffies; in nilfs_segctor_complete_write()
1882 clear_bit(NILFS_SC_UNCLOSED, &sci->sc_flags); in nilfs_segctor_complete_write()
1894 nilfs_drop_collected_inodes(&sci->sc_dirty_files); in nilfs_segctor_complete_write()
1897 nilfs_drop_collected_inodes(&sci->sc_gc_inodes); in nilfs_segctor_complete_write()
1899 nilfs->ns_nongc_ctime = sci->sc_seg_ctime; in nilfs_segctor_complete_write()
1901 sci->sc_nblk_inc += sci->sc_nblk_this_inc; in nilfs_segctor_complete_write()
1903 segbuf = NILFS_LAST_SEGBUF(&sci->sc_write_logs); in nilfs_segctor_complete_write()
1911 clear_bit(NILFS_SC_HAVE_DELTA, &sci->sc_flags); in nilfs_segctor_complete_write()
1912 clear_bit(NILFS_SC_DIRTY, &sci->sc_flags); in nilfs_segctor_complete_write()
1913 set_bit(NILFS_SC_SUPER_ROOT, &sci->sc_flags); in nilfs_segctor_complete_write()
1914 nilfs_segctor_clear_metadata_dirty(sci); in nilfs_segctor_complete_write()
1916 clear_bit(NILFS_SC_SUPER_ROOT, &sci->sc_flags); in nilfs_segctor_complete_write()
1919 static int nilfs_segctor_wait(struct nilfs_sc_info *sci) in nilfs_segctor_wait() argument
1923 ret = nilfs_wait_on_logs(&sci->sc_write_logs); in nilfs_segctor_wait()
1925 nilfs_segctor_complete_write(sci); in nilfs_segctor_wait()
1926 nilfs_destroy_logs(&sci->sc_write_logs); in nilfs_segctor_wait()
1931 static int nilfs_segctor_collect_dirty_files(struct nilfs_sc_info *sci, in nilfs_segctor_collect_dirty_files() argument
1935 struct inode *ifile = sci->sc_root->ifile; in nilfs_segctor_collect_dirty_files()
1948 nilfs_warn(sci->sc_super, in nilfs_segctor_collect_dirty_files()
1967 list_move_tail(&ii->i_dirty, &sci->sc_dirty_files); in nilfs_segctor_collect_dirty_files()
1974 static void nilfs_segctor_drop_written_files(struct nilfs_sc_info *sci, in nilfs_segctor_drop_written_files() argument
1978 int during_mount = !(sci->sc_super->s_flags & SB_ACTIVE); in nilfs_segctor_drop_written_files()
1982 list_for_each_entry_safe(ii, n, &sci->sc_dirty_files, i_dirty) { in nilfs_segctor_drop_written_files()
1996 list_add_tail(&ii->i_dirty, &sci->sc_iput_queue); in nilfs_segctor_drop_written_files()
2007 schedule_work(&sci->sc_iput_work); in nilfs_segctor_drop_written_files()
2013 static int nilfs_segctor_do_construct(struct nilfs_sc_info *sci, int mode) in nilfs_segctor_do_construct() argument
2015 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_do_construct()
2018 nilfs_sc_cstage_set(sci, NILFS_ST_INIT); in nilfs_segctor_do_construct()
2019 sci->sc_cno = nilfs->ns_cno; in nilfs_segctor_do_construct()
2021 err = nilfs_segctor_collect_dirty_files(sci, nilfs); in nilfs_segctor_do_construct()
2025 if (nilfs_test_metadata_dirty(nilfs, sci->sc_root)) in nilfs_segctor_do_construct()
2026 set_bit(NILFS_SC_DIRTY, &sci->sc_flags); in nilfs_segctor_do_construct()
2028 if (nilfs_segctor_clean(sci)) in nilfs_segctor_do_construct()
2032 sci->sc_stage.flags &= ~NILFS_CF_HISTORY_MASK; in nilfs_segctor_do_construct()
2034 err = nilfs_segctor_begin_construction(sci, nilfs); in nilfs_segctor_do_construct()
2039 sci->sc_seg_ctime = ktime_get_real_seconds(); in nilfs_segctor_do_construct()
2041 err = nilfs_segctor_collect(sci, nilfs, mode); in nilfs_segctor_do_construct()
2046 if (nilfs_sc_cstage_get(sci) == NILFS_ST_DONE && in nilfs_segctor_do_construct()
2047 nilfs_segbuf_empty(sci->sc_curseg)) { in nilfs_segctor_do_construct()
2048 nilfs_segctor_abort_construction(sci, nilfs, 1); in nilfs_segctor_do_construct()
2052 err = nilfs_segctor_assign(sci, mode); in nilfs_segctor_do_construct()
2056 if (sci->sc_stage.flags & NILFS_CF_IFILE_STARTED) in nilfs_segctor_do_construct()
2057 nilfs_segctor_fill_in_file_bmap(sci); in nilfs_segctor_do_construct()
2060 nilfs_sc_cstage_get(sci) >= NILFS_ST_CPFILE) { in nilfs_segctor_do_construct()
2061 err = nilfs_segctor_fill_in_checkpoint(sci); in nilfs_segctor_do_construct()
2065 nilfs_segctor_fill_in_super_root(sci, nilfs); in nilfs_segctor_do_construct()
2067 nilfs_segctor_update_segusage(sci, nilfs->ns_sufile); in nilfs_segctor_do_construct()
2070 nilfs_segctor_prepare_write(sci); in nilfs_segctor_do_construct()
2072 nilfs_add_checksums_on_logs(&sci->sc_segbufs, in nilfs_segctor_do_construct()
2075 err = nilfs_segctor_write(sci, nilfs); in nilfs_segctor_do_construct()
2079 if (nilfs_sc_cstage_get(sci) == NILFS_ST_DONE || in nilfs_segctor_do_construct()
2088 err = nilfs_segctor_wait(sci); in nilfs_segctor_do_construct()
2092 } while (nilfs_sc_cstage_get(sci) != NILFS_ST_DONE); in nilfs_segctor_do_construct()
2095 nilfs_segctor_drop_written_files(sci, nilfs); in nilfs_segctor_do_construct()
2099 if (sci->sc_stage.flags & NILFS_CF_IFILE_STARTED) in nilfs_segctor_do_construct()
2100 nilfs_redirty_inodes(&sci->sc_dirty_files); in nilfs_segctor_do_construct()
2104 nilfs_redirty_inodes(&sci->sc_gc_inodes); in nilfs_segctor_do_construct()
2105 nilfs_segctor_abort_construction(sci, nilfs, err); in nilfs_segctor_do_construct()
2111 * @sci: nilfs_sc_info
2117 static void nilfs_segctor_start_timer(struct nilfs_sc_info *sci) in nilfs_segctor_start_timer() argument
2119 spin_lock(&sci->sc_state_lock); in nilfs_segctor_start_timer()
2120 if (!(sci->sc_state & NILFS_SEGCTOR_COMMIT)) { in nilfs_segctor_start_timer()
2121 sci->sc_timer.expires = jiffies + sci->sc_interval; in nilfs_segctor_start_timer()
2122 add_timer(&sci->sc_timer); in nilfs_segctor_start_timer()
2123 sci->sc_state |= NILFS_SEGCTOR_COMMIT; in nilfs_segctor_start_timer()
2125 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_start_timer()
2128 static void nilfs_segctor_do_flush(struct nilfs_sc_info *sci, int bn) in nilfs_segctor_do_flush() argument
2130 spin_lock(&sci->sc_state_lock); in nilfs_segctor_do_flush()
2131 if (!(sci->sc_flush_request & BIT(bn))) { in nilfs_segctor_do_flush()
2132 unsigned long prev_req = sci->sc_flush_request; in nilfs_segctor_do_flush()
2134 sci->sc_flush_request |= BIT(bn); in nilfs_segctor_do_flush()
2136 wake_up(&sci->sc_wait_daemon); in nilfs_segctor_do_flush()
2138 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_do_flush()
2149 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_flush_segment() local
2151 if (!sci || nilfs_doing_construction()) in nilfs_flush_segment()
2153 nilfs_segctor_do_flush(sci, NILFS_MDT_INODE(sb, ino) ? ino : 0); in nilfs_flush_segment()
2164 static int nilfs_segctor_sync(struct nilfs_sc_info *sci) in nilfs_segctor_sync() argument
2169 spin_lock(&sci->sc_state_lock); in nilfs_segctor_sync()
2173 wait_req.seq = ++sci->sc_seq_request; in nilfs_segctor_sync()
2174 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_sync()
2177 add_wait_queue(&sci->sc_wait_request, &wait_req.wq); in nilfs_segctor_sync()
2179 wake_up(&sci->sc_wait_daemon); in nilfs_segctor_sync()
2193 finish_wait(&sci->sc_wait_request, &wait_req.wq); in nilfs_segctor_sync()
2197 static void nilfs_segctor_wakeup(struct nilfs_sc_info *sci, int err) in nilfs_segctor_wakeup() argument
2202 spin_lock_irqsave(&sci->sc_wait_request.lock, flags); in nilfs_segctor_wakeup()
2203 list_for_each_entry_safe(wrq, n, &sci->sc_wait_request.head, wq.entry) { in nilfs_segctor_wakeup()
2205 nilfs_cnt32_ge(sci->sc_seq_done, wrq->seq)) { in nilfs_segctor_wakeup()
2215 spin_unlock_irqrestore(&sci->sc_wait_request.lock, flags); in nilfs_segctor_wakeup()
2238 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_construct_segment() local
2242 if (!sci) in nilfs_construct_segment()
2248 err = nilfs_segctor_sync(sci); in nilfs_construct_segment()
2276 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_construct_dsync_segment() local
2281 if (!sci) in nilfs_construct_dsync_segment()
2289 test_bit(NILFS_SC_UNCLOSED, &sci->sc_flags) || in nilfs_construct_dsync_segment()
2292 err = nilfs_segctor_sync(sci); in nilfs_construct_dsync_segment()
2304 sci->sc_dsync_inode = ii; in nilfs_construct_dsync_segment()
2305 sci->sc_dsync_start = start; in nilfs_construct_dsync_segment()
2306 sci->sc_dsync_end = end; in nilfs_construct_dsync_segment()
2308 err = nilfs_segctor_do_construct(sci, SC_LSEG_DSYNC); in nilfs_construct_dsync_segment()
2321 * @sci: segment constructor object
2323 static void nilfs_segctor_accept(struct nilfs_sc_info *sci) in nilfs_segctor_accept() argument
2325 spin_lock(&sci->sc_state_lock); in nilfs_segctor_accept()
2326 sci->sc_seq_accepted = sci->sc_seq_request; in nilfs_segctor_accept()
2327 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_accept()
2328 del_timer_sync(&sci->sc_timer); in nilfs_segctor_accept()
2333 * @sci: segment constructor object
2337 static void nilfs_segctor_notify(struct nilfs_sc_info *sci, int mode, int err) in nilfs_segctor_notify() argument
2340 spin_lock(&sci->sc_state_lock); in nilfs_segctor_notify()
2343 sci->sc_state &= ~NILFS_SEGCTOR_COMMIT; in nilfs_segctor_notify()
2344 sci->sc_seq_done = sci->sc_seq_accepted; in nilfs_segctor_notify()
2345 nilfs_segctor_wakeup(sci, err); in nilfs_segctor_notify()
2346 sci->sc_flush_request = 0; in nilfs_segctor_notify()
2349 sci->sc_flush_request &= ~FLUSH_FILE_BIT; in nilfs_segctor_notify()
2351 sci->sc_flush_request &= ~FLUSH_DAT_BIT; in nilfs_segctor_notify()
2354 if ((sci->sc_state & NILFS_SEGCTOR_COMMIT) && in nilfs_segctor_notify()
2355 time_before(jiffies, sci->sc_timer.expires)) in nilfs_segctor_notify()
2356 add_timer(&sci->sc_timer); in nilfs_segctor_notify()
2358 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_notify()
2363 * @sci: segment constructor object
2366 static int nilfs_segctor_construct(struct nilfs_sc_info *sci, int mode) in nilfs_segctor_construct() argument
2368 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_construct()
2372 nilfs_segctor_accept(sci); in nilfs_segctor_construct()
2376 if (!nilfs_segctor_confirm(sci)) in nilfs_segctor_construct()
2377 err = nilfs_segctor_do_construct(sci, mode); in nilfs_segctor_construct()
2382 if (test_bit(NILFS_SC_SUPER_ROOT, &sci->sc_flags) && in nilfs_segctor_construct()
2386 sbp = nilfs_prepare_super(sci->sc_super, in nilfs_segctor_construct()
2390 err = nilfs_commit_super(sci->sc_super, in nilfs_segctor_construct()
2397 nilfs_segctor_notify(sci, mode, err); in nilfs_segctor_construct()
2403 struct nilfs_sc_info *sci = from_timer(sci, t, sc_timer); in nilfs_construction_timeout() local
2405 wake_up_process(sci->sc_timer_task); in nilfs_construction_timeout()
2427 struct nilfs_sc_info *sci = nilfs->ns_writer; in nilfs_clean_segments() local
2431 if (unlikely(!sci)) in nilfs_clean_segments()
2446 sci->sc_freesegs = kbufs[4]; in nilfs_clean_segments()
2447 sci->sc_nfreesegs = argv[4].v_nmembs; in nilfs_clean_segments()
2448 list_splice_tail_init(&nilfs->ns_gc_inodes, &sci->sc_gc_inodes); in nilfs_clean_segments()
2451 err = nilfs_segctor_construct(sci, SC_LSEG_SR); in nilfs_clean_segments()
2452 nilfs_remove_written_gcinodes(nilfs, &sci->sc_gc_inodes); in nilfs_clean_segments()
2459 schedule_timeout(sci->sc_interval); in nilfs_clean_segments()
2462 int ret = nilfs_discard_segments(nilfs, sci->sc_freesegs, in nilfs_clean_segments()
2463 sci->sc_nfreesegs); in nilfs_clean_segments()
2473 sci->sc_freesegs = NULL; in nilfs_clean_segments()
2474 sci->sc_nfreesegs = 0; in nilfs_clean_segments()
2480 static void nilfs_segctor_thread_construct(struct nilfs_sc_info *sci, int mode) in nilfs_segctor_thread_construct() argument
2484 nilfs_transaction_lock(sci->sc_super, &ti, 0); in nilfs_segctor_thread_construct()
2485 nilfs_segctor_construct(sci, mode); in nilfs_segctor_thread_construct()
2492 if (test_bit(NILFS_SC_UNCLOSED, &sci->sc_flags)) in nilfs_segctor_thread_construct()
2493 nilfs_segctor_start_timer(sci); in nilfs_segctor_thread_construct()
2495 nilfs_transaction_unlock(sci->sc_super); in nilfs_segctor_thread_construct()
2498 static void nilfs_segctor_do_immediate_flush(struct nilfs_sc_info *sci) in nilfs_segctor_do_immediate_flush() argument
2502 spin_lock(&sci->sc_state_lock); in nilfs_segctor_do_immediate_flush()
2503 mode = (sci->sc_flush_request & FLUSH_DAT_BIT) ? in nilfs_segctor_do_immediate_flush()
2505 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_do_immediate_flush()
2508 nilfs_segctor_do_construct(sci, mode); in nilfs_segctor_do_immediate_flush()
2510 spin_lock(&sci->sc_state_lock); in nilfs_segctor_do_immediate_flush()
2511 sci->sc_flush_request &= (mode == SC_FLUSH_FILE) ? in nilfs_segctor_do_immediate_flush()
2513 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_do_immediate_flush()
2515 clear_bit(NILFS_SC_PRIOR_FLUSH, &sci->sc_flags); in nilfs_segctor_do_immediate_flush()
2518 static int nilfs_segctor_flush_mode(struct nilfs_sc_info *sci) in nilfs_segctor_flush_mode() argument
2520 if (!test_bit(NILFS_SC_UNCLOSED, &sci->sc_flags) || in nilfs_segctor_flush_mode()
2521 time_before(jiffies, sci->sc_lseg_stime + sci->sc_mjcp_freq)) { in nilfs_segctor_flush_mode()
2522 if (!(sci->sc_flush_request & ~FLUSH_FILE_BIT)) in nilfs_segctor_flush_mode()
2524 else if (!(sci->sc_flush_request & ~FLUSH_DAT_BIT)) in nilfs_segctor_flush_mode()
2539 struct nilfs_sc_info *sci = (struct nilfs_sc_info *)arg; in nilfs_segctor_thread() local
2540 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_thread()
2543 sci->sc_timer_task = current; in nilfs_segctor_thread()
2546 sci->sc_task = current; in nilfs_segctor_thread()
2547 wake_up(&sci->sc_wait_task); /* for nilfs_segctor_start_thread() */ in nilfs_segctor_thread()
2548 nilfs_info(sci->sc_super, in nilfs_segctor_thread()
2550 sci->sc_interval / HZ, sci->sc_mjcp_freq / HZ); in nilfs_segctor_thread()
2552 spin_lock(&sci->sc_state_lock); in nilfs_segctor_thread()
2557 if (sci->sc_state & NILFS_SEGCTOR_QUIT) in nilfs_segctor_thread()
2560 if (timeout || sci->sc_seq_request != sci->sc_seq_done) in nilfs_segctor_thread()
2562 else if (sci->sc_flush_request) in nilfs_segctor_thread()
2563 mode = nilfs_segctor_flush_mode(sci); in nilfs_segctor_thread()
2567 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_thread()
2568 nilfs_segctor_thread_construct(sci, mode); in nilfs_segctor_thread()
2569 spin_lock(&sci->sc_state_lock); in nilfs_segctor_thread()
2575 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_thread()
2577 spin_lock(&sci->sc_state_lock); in nilfs_segctor_thread()
2582 prepare_to_wait(&sci->sc_wait_daemon, &wait, in nilfs_segctor_thread()
2585 if (sci->sc_seq_request != sci->sc_seq_done) in nilfs_segctor_thread()
2587 else if (sci->sc_flush_request) in nilfs_segctor_thread()
2589 else if (sci->sc_state & NILFS_SEGCTOR_COMMIT) in nilfs_segctor_thread()
2591 sci->sc_timer.expires); in nilfs_segctor_thread()
2594 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_thread()
2596 spin_lock(&sci->sc_state_lock); in nilfs_segctor_thread()
2598 finish_wait(&sci->sc_wait_daemon, &wait); in nilfs_segctor_thread()
2599 timeout = ((sci->sc_state & NILFS_SEGCTOR_COMMIT) && in nilfs_segctor_thread()
2600 time_after_eq(jiffies, sci->sc_timer.expires)); in nilfs_segctor_thread()
2608 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_thread()
2611 sci->sc_task = NULL; in nilfs_segctor_thread()
2612 wake_up(&sci->sc_wait_task); /* for nilfs_segctor_kill_thread() */ in nilfs_segctor_thread()
2616 static int nilfs_segctor_start_thread(struct nilfs_sc_info *sci) in nilfs_segctor_start_thread() argument
2620 t = kthread_run(nilfs_segctor_thread, sci, "segctord"); in nilfs_segctor_start_thread()
2624 nilfs_err(sci->sc_super, "error %d creating segctord thread", in nilfs_segctor_start_thread()
2628 wait_event(sci->sc_wait_task, sci->sc_task != NULL); in nilfs_segctor_start_thread()
2632 static void nilfs_segctor_kill_thread(struct nilfs_sc_info *sci) in nilfs_segctor_kill_thread() argument
2633 __acquires(&sci->sc_state_lock) in nilfs_segctor_kill_thread()
2634 __releases(&sci->sc_state_lock) in nilfs_segctor_kill_thread()
2636 sci->sc_state |= NILFS_SEGCTOR_QUIT; in nilfs_segctor_kill_thread()
2638 while (sci->sc_task) { in nilfs_segctor_kill_thread()
2639 wake_up(&sci->sc_wait_daemon); in nilfs_segctor_kill_thread()
2640 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_kill_thread()
2641 wait_event(sci->sc_wait_task, sci->sc_task == NULL); in nilfs_segctor_kill_thread()
2642 spin_lock(&sci->sc_state_lock); in nilfs_segctor_kill_thread()
2653 struct nilfs_sc_info *sci; in nilfs_segctor_new() local
2655 sci = kzalloc(sizeof(*sci), GFP_KERNEL); in nilfs_segctor_new()
2656 if (!sci) in nilfs_segctor_new()
2659 sci->sc_super = sb; in nilfs_segctor_new()
2662 sci->sc_root = root; in nilfs_segctor_new()
2664 init_waitqueue_head(&sci->sc_wait_request); in nilfs_segctor_new()
2665 init_waitqueue_head(&sci->sc_wait_daemon); in nilfs_segctor_new()
2666 init_waitqueue_head(&sci->sc_wait_task); in nilfs_segctor_new()
2667 spin_lock_init(&sci->sc_state_lock); in nilfs_segctor_new()
2668 INIT_LIST_HEAD(&sci->sc_dirty_files); in nilfs_segctor_new()
2669 INIT_LIST_HEAD(&sci->sc_segbufs); in nilfs_segctor_new()
2670 INIT_LIST_HEAD(&sci->sc_write_logs); in nilfs_segctor_new()
2671 INIT_LIST_HEAD(&sci->sc_gc_inodes); in nilfs_segctor_new()
2672 INIT_LIST_HEAD(&sci->sc_iput_queue); in nilfs_segctor_new()
2673 INIT_WORK(&sci->sc_iput_work, nilfs_iput_work_func); in nilfs_segctor_new()
2674 timer_setup(&sci->sc_timer, nilfs_construction_timeout, 0); in nilfs_segctor_new()
2676 sci->sc_interval = HZ * NILFS_SC_DEFAULT_TIMEOUT; in nilfs_segctor_new()
2677 sci->sc_mjcp_freq = HZ * NILFS_SC_DEFAULT_SR_FREQ; in nilfs_segctor_new()
2678 sci->sc_watermark = NILFS_SC_DEFAULT_WATERMARK; in nilfs_segctor_new()
2681 sci->sc_interval = HZ * nilfs->ns_interval; in nilfs_segctor_new()
2683 sci->sc_watermark = nilfs->ns_watermark; in nilfs_segctor_new()
2684 return sci; in nilfs_segctor_new()
2687 static void nilfs_segctor_write_out(struct nilfs_sc_info *sci) in nilfs_segctor_write_out() argument
2698 nilfs_transaction_lock(sci->sc_super, &ti, 0); in nilfs_segctor_write_out()
2699 ret = nilfs_segctor_construct(sci, SC_LSEG_SR); in nilfs_segctor_write_out()
2700 nilfs_transaction_unlock(sci->sc_super); in nilfs_segctor_write_out()
2702 flush_work(&sci->sc_iput_work); in nilfs_segctor_write_out()
2709 * @sci: nilfs_sc_info
2715 static void nilfs_segctor_destroy(struct nilfs_sc_info *sci) in nilfs_segctor_destroy() argument
2717 struct the_nilfs *nilfs = sci->sc_super->s_fs_info; in nilfs_segctor_destroy()
2722 spin_lock(&sci->sc_state_lock); in nilfs_segctor_destroy()
2723 nilfs_segctor_kill_thread(sci); in nilfs_segctor_destroy()
2724 flag = ((sci->sc_state & NILFS_SEGCTOR_COMMIT) || sci->sc_flush_request in nilfs_segctor_destroy()
2725 || sci->sc_seq_request != sci->sc_seq_done); in nilfs_segctor_destroy()
2726 spin_unlock(&sci->sc_state_lock); in nilfs_segctor_destroy()
2728 if (flush_work(&sci->sc_iput_work)) in nilfs_segctor_destroy()
2731 if (flag || !nilfs_segctor_confirm(sci)) in nilfs_segctor_destroy()
2732 nilfs_segctor_write_out(sci); in nilfs_segctor_destroy()
2734 if (!list_empty(&sci->sc_dirty_files)) { in nilfs_segctor_destroy()
2735 nilfs_warn(sci->sc_super, in nilfs_segctor_destroy()
2737 nilfs_dispose_list(nilfs, &sci->sc_dirty_files, 1); in nilfs_segctor_destroy()
2740 if (!list_empty(&sci->sc_iput_queue)) { in nilfs_segctor_destroy()
2741 nilfs_warn(sci->sc_super, in nilfs_segctor_destroy()
2743 nilfs_dispose_list(nilfs, &sci->sc_iput_queue, 1); in nilfs_segctor_destroy()
2746 WARN_ON(!list_empty(&sci->sc_segbufs)); in nilfs_segctor_destroy()
2747 WARN_ON(!list_empty(&sci->sc_write_logs)); in nilfs_segctor_destroy()
2749 nilfs_put_root(sci->sc_root); in nilfs_segctor_destroy()
2753 del_timer_sync(&sci->sc_timer); in nilfs_segctor_destroy()
2754 kfree(sci); in nilfs_segctor_destroy()