Lines Matching defs:jl
96 struct reiserfs_journal_list *jl, int flushall);
98 struct reiserfs_journal_list *jl, int flushall);
105 struct reiserfs_journal_list *jl);
324 *jl)
348 jb->journal_list = jl;
555 static inline void get_journal_list(struct reiserfs_journal_list *jl)
557 jl->j_refcount++;
561 struct reiserfs_journal_list *jl)
563 if (jl->j_refcount < 1) {
565 jl->j_trans_id, jl->j_refcount);
567 if (--jl->j_refcount == 0)
568 kfree(jl);
577 struct reiserfs_journal_list *jl)
580 struct reiserfs_list_bitmap *jb = jl->j_list_bitmap;
584 jl->j_list_bitmap->journal_list = NULL;
585 jl->j_list_bitmap = NULL;
593 struct reiserfs_journal_list *jl;
596 jl = JOURNAL_LIST_ENTRY(entry->next);
597 if (jl->j_trans_id <= trans_id) {
809 jh->jl = j->j_current_jl;
811 list_add_tail(&jh->list, &jh->jl->j_tail_bh_list);
813 list_add_tail(&jh->list, &jh->jl->j_bh_list);
831 struct reiserfs_journal_list *jl,
919 struct reiserfs_journal_list *jl)
925 unsigned int trans_id = jl->j_trans_id;
933 first_jl = jl;
934 entry = jl->j_list.prev;
946 if (first_jl == jl) {
1005 struct reiserfs_journal_list *jl, int flushall)
1010 unsigned int trans_id = jl->j_trans_id;
1018 if (atomic_read(&jl->j_older_commits_done)) {
1027 BUG_ON(jl->j_len <= 0);
1030 get_journal_list(jl);
1032 if (flush_older_commits(s, jl) == 1) {
1039 reiserfs_mutex_lock_safe(&jl->j_commit_mutex, s);
1042 mutex_unlock(&jl->j_commit_mutex);
1045 BUG_ON(jl->j_trans_id == 0);
1048 if (atomic_read(&(jl->j_commit_left)) <= 0) {
1050 atomic_set(&(jl->j_older_commits_done), 1);
1052 mutex_unlock(&jl->j_commit_mutex);
1056 if (!list_empty(&jl->j_bh_list)) {
1065 journal, jl, &jl->j_bh_list);
1070 BUG_ON(!list_empty(&jl->j_bh_list));
1079 write_len = jl->j_len + 1;
1083 bn = SB_ONDISK_JOURNAL_1st_BLOCK(s) + (jl->j_start + i) %
1107 lock_buffer(jl->j_commit_bh);
1108 ret = submit_barrier_buffer(jl->j_commit_bh);
1110 set_buffer_uptodate(jl->j_commit_bh);
1115 for (i = 0; i < (jl->j_len + 1); i++) {
1117 (jl->j_start + i) % SB_ONDISK_JOURNAL_SIZE(s);
1141 atomic_dec(&(jl->j_commit_left));
1144 BUG_ON(atomic_read(&(jl->j_commit_left)) != 1);
1152 if (buffer_dirty(jl->j_commit_bh))
1154 mark_buffer_dirty(jl->j_commit_bh) ;
1156 sync_dirty_buffer(jl->j_commit_bh) ;
1161 wait_on_buffer(jl->j_commit_bh);
1165 check_barrier_completion(s, jl->j_commit_bh);
1170 if (unlikely(!buffer_uptodate(jl->j_commit_bh))) {
1176 bforget(jl->j_commit_bh);
1178 (jl->j_trans_id - journal->j_last_commit_id) != 1) {
1180 journal->j_last_commit_id, jl->j_trans_id);
1182 journal->j_last_commit_id = jl->j_trans_id;
1185 cleanup_freed_for_journal_list(s, jl);
1191 dirty_one_transaction(s, jl);
1192 atomic_dec(&(jl->j_commit_left));
1195 atomic_set(&(jl->j_older_commits_done), 1);
1197 mutex_unlock(&jl->j_commit_mutex);
1199 put_journal_list(s, jl);
1255 struct reiserfs_journal_list *jl,
1260 cn = jl->j_realblock;
1275 jl, cn->blocknr, 1);
1281 jl->j_realblock = NULL;
1363 struct reiserfs_journal_list *jl)
1368 unsigned int trans_id = jl->j_trans_id;
1391 struct reiserfs_journal_list *jl)
1394 if (!list_empty(&jl->j_working_list)) {
1395 list_del_init(&jl->j_working_list);
1410 struct reiserfs_journal_list *jl, int flushall)
1418 unsigned long j_len_saved = jl->j_len;
1428 BUG_ON(jl->j_trans_id == 0);
1440 j_len_saved, jl->j_trans_id);
1447 if (atomic_read(&(jl->j_nonzerolen)) <= 0 &&
1448 atomic_read(&(jl->j_commit_left)) <= 0) {
1455 flush_commit_list(s, jl, 1);
1457 if (!(jl->j_state & LIST_DIRTY)
1462 if (atomic_read(&(jl->j_nonzerolen)) <= 0 &&
1463 atomic_read(&(jl->j_commit_left)) <= 0) {
1474 cn = jl->j_realblock;
1485 if (!(jl->j_state & LIST_DIRTY))
1569 cn = jl->j_realblock;
1619 flush_older_journal_lists(s, jl);
1634 (jl->j_start + jl->j_len +
1636 jl->j_trans_id);
1642 remove_all_from_journal_list(s, jl, 0);
1643 list_del_init(&jl->j_list);
1645 del_from_work_list(s, jl);
1648 (jl->j_trans_id - journal->j_last_flush_id) != 1) {
1650 journal->j_last_flush_id, jl->j_trans_id);
1652 journal->j_last_flush_id = jl->j_trans_id;
1657 jl->j_len = 0;
1658 atomic_set(&(jl->j_nonzerolen), 0);
1659 jl->j_start = 0;
1660 jl->j_realblock = NULL;
1661 jl->j_commit_bh = NULL;
1662 jl->j_trans_id = 0;
1663 jl->j_state = 0;
1664 put_journal_list(s, jl);
1672 struct reiserfs_journal_list *jl)
1676 if (jl->j_len == 0 || atomic_read(&jl->j_nonzerolen) == 0)
1679 cn = jl->j_realblock;
1697 struct reiserfs_journal_list *jl,
1703 jl->j_state |= LIST_TOUCHED;
1704 del_from_work_list(s, jl);
1705 if (jl->j_len == 0 || atomic_read(&jl->j_nonzerolen) == 0) {
1709 cn = jl->j_realblock;
1747 struct reiserfs_journal_list *jl)
1753 jl->j_state |= LIST_DIRTY;
1754 cn = jl->j_realblock;
1782 struct reiserfs_journal_list *jl,
1790 unsigned int orig_trans_id = jl->j_trans_id;
1807 if (jl->j_len == 0 || (jl->j_state & LIST_TOUCHED) ||
1808 atomic_read(&jl->j_commit_left)
1809 || !(jl->j_state & LIST_DIRTY)) {
1810 del_from_work_list(s, jl);
1813 ret = write_one_transaction(s, jl, &chunk);
1819 entry = jl->j_list.next;
1825 jl = JOURNAL_LIST_ENTRY(entry);
1828 if (jl->j_trans_id <= orig_trans_id)
1850 struct reiserfs_journal_list *jl)
1862 flush_jl = tjl = jl;
1870 tjl->j_trans_id < jl->j_trans_id) {
1887 if (flush_jl != jl) {
1888 ret = kupdate_transactions(s, jl, &tjl, &trans_id, len, i);
1900 struct reiserfs_journal_list *jl,
1913 && (jl == NULL || jl == cur->jlist)
2595 struct reiserfs_journal_list *jl;
2596 jl = kzalloc(sizeof(struct reiserfs_journal_list),
2598 INIT_LIST_HEAD(&jl->j_list);
2599 INIT_LIST_HEAD(&jl->j_working_list);
2600 INIT_LIST_HEAD(&jl->j_tail_bh_list);
2601 INIT_LIST_HEAD(&jl->j_bh_list);
2602 mutex_init(&jl->j_commit_mutex);
2604 get_journal_list(jl);
2605 return jl;
2763 struct reiserfs_journal_list *jl;
2937 jl = journal->j_current_jl;
2938 jl->j_list_bitmap = get_list_bitmap(sb, jl);
2939 if (!jl->j_list_bitmap) {
3583 struct reiserfs_journal_list *jl;
3590 jl = JOURNAL_LIST_ENTRY(entry);
3591 flush_commit_list(sb, jl, 1);
3657 struct reiserfs_journal_list *jl;
3689 jl = journal->j_current_jl;
3690 trans_id = jl->j_trans_id;
3692 jl->j_state |= LIST_COMMIT_PENDING;
3717 flush_commit_list(sb, jl, 1);
3856 struct reiserfs_journal_list *jl)
3865 jl = journal->j_current_jl;
3901 if (atomic_read(&jl->j_commit_left) > 1)
3903 flush_commit_list(sb, jl, 1);
3915 struct reiserfs_journal_list *jl = REISERFS_I(inode)->i_jl;
3920 if (!id || !jl) {
3923 /* jl will be updated in __commit_trans_jl */
3926 return __commit_trans_jl(inode, id, jl);
3981 struct reiserfs_journal_list *jl;
3987 jl = JOURNAL_LIST_ENTRY(entry);
3989 if (jl->j_timestamp < (now - (JOURNAL_MAX_TRANS_AGE * 4)) &&
3990 atomic_read(&jl->j_commit_left) == 0 &&
3991 test_transaction(s, jl)) {
3992 flush_used_journal_lists(s, jl);
4025 struct reiserfs_journal_list *jl, *temp_jl;
4114 jl = journal->j_current_jl;
4121 reiserfs_mutex_lock_safe(&jl->j_commit_mutex, sb);
4124 commit_trans_id = jl->j_trans_id;
4126 atomic_set(&jl->j_older_commits_done, 0);
4127 jl->j_trans_id = journal->j_trans_id;
4128 jl->j_timestamp = journal->j_trans_start_time;
4129 jl->j_commit_bh = c_bh;
4130 jl->j_start = journal->j_start;
4131 jl->j_len = journal->j_len;
4132 atomic_set(&jl->j_nonzerolen, journal->j_len);
4133 atomic_set(&jl->j_commit_left, journal->j_len + 2);
4134 jl->j_realblock = NULL;
4149 jl->j_realblock = jl_cn;
4171 jl_cn->jlist = jl;
4249 list_add_tail(&jl->j_list, &journal->j_journal_list);
4250 list_add_tail(&jl->j_working_list, &journal->j_working_list);
4284 if (!list_empty(&jl->j_tail_bh_list)) {
4287 journal, jl, &jl->j_tail_bh_list);
4290 BUG_ON(!list_empty(&jl->j_tail_bh_list));
4291 mutex_unlock(&jl->j_commit_mutex);
4301 flush_commit_list(sb, jl, 1);
4302 flush_journal_list(sb, jl, 1);
4303 } else if (!(jl->j_state & LIST_COMMIT_PENDING))
4362 flush_commit_list(sb, jl, 1);