aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--fs/gfs2/glock.c3
-rw-r--r--fs/gfs2/incore.h4
-rw-r--r--fs/gfs2/inode.c3
-rw-r--r--fs/gfs2/log.c15
-rw-r--r--fs/gfs2/log.h9
-rw-r--r--fs/gfs2/lops.c58
-rw-r--r--fs/gfs2/ops_fstype.c1
-rw-r--r--fs/gfs2/trans.c5
-rw-r--r--fs/gfs2/trans.h1
9 files changed, 21 insertions, 78 deletions
diff --git a/fs/gfs2/glock.c b/fs/gfs2/glock.c
index 5fbd9d34ce23..d83df6888402 100644
--- a/fs/gfs2/glock.c
+++ b/fs/gfs2/glock.c
@@ -346,7 +346,6 @@ int gfs2_glock_get(struct gfs2_sbd *sdp, u64 number,
346 gl->gl_object = NULL; 346 gl->gl_object = NULL;
347 gl->gl_sbd = sdp; 347 gl->gl_sbd = sdp;
348 gl->gl_aspace = NULL; 348 gl->gl_aspace = NULL;
349 lops_init_le(&gl->gl_le, &gfs2_glock_lops);
350 INIT_DELAYED_WORK(&gl->gl_work, glock_work_func); 349 INIT_DELAYED_WORK(&gl->gl_work, glock_work_func);
351 350
352 /* If this glock protects actual on-disk data or metadata blocks, 351 /* If this glock protects actual on-disk data or metadata blocks,
@@ -1900,8 +1899,6 @@ static int dump_glock(struct glock_iter *gi, struct gfs2_glock *gl)
1900 print_dbg(gi, " req_bh = %s\n", (gl->gl_req_bh) ? "yes" : "no"); 1899 print_dbg(gi, " req_bh = %s\n", (gl->gl_req_bh) ? "yes" : "no");
1901 print_dbg(gi, " lvb_count = %d\n", atomic_read(&gl->gl_lvb_count)); 1900 print_dbg(gi, " lvb_count = %d\n", atomic_read(&gl->gl_lvb_count));
1902 print_dbg(gi, " object = %s\n", (gl->gl_object) ? "yes" : "no"); 1901 print_dbg(gi, " object = %s\n", (gl->gl_object) ? "yes" : "no");
1903 print_dbg(gi, " le = %s\n",
1904 (list_empty(&gl->gl_le.le_list)) ? "no" : "yes");
1905 print_dbg(gi, " reclaim = %s\n", 1902 print_dbg(gi, " reclaim = %s\n",
1906 (list_empty(&gl->gl_reclaim)) ? "no" : "yes"); 1903 (list_empty(&gl->gl_reclaim)) ? "no" : "yes");
1907 if (gl->gl_aspace) 1904 if (gl->gl_aspace)
diff --git a/fs/gfs2/incore.h b/fs/gfs2/incore.h
index 478023e9fda6..911822d1e4c0 100644
--- a/fs/gfs2/incore.h
+++ b/fs/gfs2/incore.h
@@ -168,6 +168,7 @@ enum {
168 GLF_PENDING_DEMOTE = 4, 168 GLF_PENDING_DEMOTE = 4,
169 GLF_DIRTY = 5, 169 GLF_DIRTY = 5,
170 GLF_DEMOTE_IN_PROGRESS = 6, 170 GLF_DEMOTE_IN_PROGRESS = 6,
171 GLF_LFLUSH = 7,
171}; 172};
172 173
173struct gfs2_glock { 174struct gfs2_glock {
@@ -208,7 +209,6 @@ struct gfs2_glock {
208 struct gfs2_sbd *gl_sbd; 209 struct gfs2_sbd *gl_sbd;
209 210
210 struct inode *gl_aspace; 211 struct inode *gl_aspace;
211 struct gfs2_log_element gl_le;
212 struct list_head gl_ail_list; 212 struct list_head gl_ail_list;
213 atomic_t gl_ail_count; 213 atomic_t gl_ail_count;
214 struct delayed_work gl_work; 214 struct delayed_work gl_work;
@@ -584,13 +584,11 @@ struct gfs2_sbd {
584 unsigned int sd_log_commited_databuf; 584 unsigned int sd_log_commited_databuf;
585 unsigned int sd_log_commited_revoke; 585 unsigned int sd_log_commited_revoke;
586 586
587 unsigned int sd_log_num_gl;
588 unsigned int sd_log_num_buf; 587 unsigned int sd_log_num_buf;
589 unsigned int sd_log_num_revoke; 588 unsigned int sd_log_num_revoke;
590 unsigned int sd_log_num_rg; 589 unsigned int sd_log_num_rg;
591 unsigned int sd_log_num_databuf; 590 unsigned int sd_log_num_databuf;
592 591
593 struct list_head sd_log_le_gl;
594 struct list_head sd_log_le_buf; 592 struct list_head sd_log_le_buf;
595 struct list_head sd_log_le_revoke; 593 struct list_head sd_log_le_revoke;
596 struct list_head sd_log_le_rg; 594 struct list_head sd_log_le_rg;
diff --git a/fs/gfs2/inode.c b/fs/gfs2/inode.c
index 532784eb5ba4..92959d093adf 100644
--- a/fs/gfs2/inode.c
+++ b/fs/gfs2/inode.c
@@ -362,7 +362,8 @@ int gfs2_dinode_dealloc(struct gfs2_inode *ip)
362 if (error) 362 if (error)
363 goto out_rg_gunlock; 363 goto out_rg_gunlock;
364 364
365 gfs2_trans_add_gl(ip->i_gl); 365 set_bit(GLF_DIRTY, &ip->i_gl->gl_flags);
366 set_bit(GLF_LFLUSH, &ip->i_gl->gl_flags);
366 367
367 gfs2_free_di(rgd, ip); 368 gfs2_free_di(rgd, ip);
368 369
diff --git a/fs/gfs2/log.c b/fs/gfs2/log.c
index 1e1fe8def375..d24684330bc3 100644
--- a/fs/gfs2/log.c
+++ b/fs/gfs2/log.c
@@ -692,20 +692,16 @@ static void gfs2_ordered_wait(struct gfs2_sbd *sdp)
692 * 692 *
693 */ 693 */
694 694
695void gfs2_log_flush(struct gfs2_sbd *sdp, struct gfs2_glock *gl) 695void __gfs2_log_flush(struct gfs2_sbd *sdp, struct gfs2_glock *gl)
696{ 696{
697 struct gfs2_ail *ai; 697 struct gfs2_ail *ai;
698 698
699 down_write(&sdp->sd_log_flush_lock); 699 down_write(&sdp->sd_log_flush_lock);
700 700
701 if (gl) { 701 /* Log might have been flushed while we waited for the flush lock */
702 gfs2_log_lock(sdp); 702 if (gl && !test_bit(GLF_LFLUSH, &gl->gl_flags)) {
703 if (list_empty(&gl->gl_le.le_list)) { 703 up_write(&sdp->sd_log_flush_lock);
704 gfs2_log_unlock(sdp); 704 return;
705 up_write(&sdp->sd_log_flush_lock);
706 return;
707 }
708 gfs2_log_unlock(sdp);
709 } 705 }
710 706
711 ai = kzalloc(sizeof(struct gfs2_ail), GFP_NOFS | __GFP_NOFAIL); 707 ai = kzalloc(sizeof(struct gfs2_ail), GFP_NOFS | __GFP_NOFAIL);
@@ -823,7 +819,6 @@ void gfs2_log_shutdown(struct gfs2_sbd *sdp)
823 down_write(&sdp->sd_log_flush_lock); 819 down_write(&sdp->sd_log_flush_lock);
824 820
825 gfs2_assert_withdraw(sdp, !sdp->sd_log_blks_reserved); 821 gfs2_assert_withdraw(sdp, !sdp->sd_log_blks_reserved);
826 gfs2_assert_withdraw(sdp, !sdp->sd_log_num_gl);
827 gfs2_assert_withdraw(sdp, !sdp->sd_log_num_buf); 822 gfs2_assert_withdraw(sdp, !sdp->sd_log_num_buf);
828 gfs2_assert_withdraw(sdp, !sdp->sd_log_num_revoke); 823 gfs2_assert_withdraw(sdp, !sdp->sd_log_num_revoke);
829 gfs2_assert_withdraw(sdp, !sdp->sd_log_num_rg); 824 gfs2_assert_withdraw(sdp, !sdp->sd_log_num_rg);
diff --git a/fs/gfs2/log.h b/fs/gfs2/log.h
index 24e7161486e2..4babd430b722 100644
--- a/fs/gfs2/log.h
+++ b/fs/gfs2/log.h
@@ -57,7 +57,14 @@ void gfs2_log_incr_head(struct gfs2_sbd *sdp);
57struct buffer_head *gfs2_log_get_buf(struct gfs2_sbd *sdp); 57struct buffer_head *gfs2_log_get_buf(struct gfs2_sbd *sdp);
58struct buffer_head *gfs2_log_fake_buf(struct gfs2_sbd *sdp, 58struct buffer_head *gfs2_log_fake_buf(struct gfs2_sbd *sdp,
59 struct buffer_head *real); 59 struct buffer_head *real);
60void gfs2_log_flush(struct gfs2_sbd *sdp, struct gfs2_glock *gl); 60void __gfs2_log_flush(struct gfs2_sbd *sdp, struct gfs2_glock *gl);
61
62static inline void gfs2_log_flush(struct gfs2_sbd *sbd, struct gfs2_glock *gl)
63{
64 if (!gl || test_bit(GLF_LFLUSH, &gl->gl_flags))
65 __gfs2_log_flush(sbd, gl);
66}
67
61void gfs2_log_commit(struct gfs2_sbd *sdp, struct gfs2_trans *trans); 68void gfs2_log_commit(struct gfs2_sbd *sdp, struct gfs2_trans *trans);
62void gfs2_remove_from_ail(struct gfs2_bufdata *bd); 69void gfs2_remove_from_ail(struct gfs2_bufdata *bd);
63 70
diff --git a/fs/gfs2/lops.c b/fs/gfs2/lops.c
index e901f8f7d650..fae59d69d01a 100644
--- a/fs/gfs2/lops.c
+++ b/fs/gfs2/lops.c
@@ -87,6 +87,7 @@ static void gfs2_unpin(struct gfs2_sbd *sdp, struct buffer_head *bh,
87 } 87 }
88 bd->bd_ail = ai; 88 bd->bd_ail = ai;
89 list_add(&bd->bd_ail_st_list, &ai->ai_ail1_list); 89 list_add(&bd->bd_ail_st_list, &ai->ai_ail1_list);
90 clear_bit(GLF_LFLUSH, &bd->bd_gl->gl_flags);
90 gfs2_log_unlock(sdp); 91 gfs2_log_unlock(sdp);
91 unlock_buffer(bh); 92 unlock_buffer(bh);
92} 93}
@@ -124,49 +125,6 @@ static struct buffer_head *gfs2_get_log_desc(struct gfs2_sbd *sdp, u32 ld_type)
124 return bh; 125 return bh;
125} 126}
126 127
127static void __glock_lo_add(struct gfs2_sbd *sdp, struct gfs2_log_element *le)
128{
129 struct gfs2_glock *gl;
130 struct gfs2_trans *tr = current->journal_info;
131
132 tr->tr_touched = 1;
133
134 gl = container_of(le, struct gfs2_glock, gl_le);
135 if (gfs2_assert_withdraw(sdp, gfs2_glock_is_held_excl(gl)))
136 return;
137
138 if (!list_empty(&le->le_list))
139 return;
140
141 gfs2_glock_hold(gl);
142 set_bit(GLF_DIRTY, &gl->gl_flags);
143 sdp->sd_log_num_gl++;
144 list_add(&le->le_list, &sdp->sd_log_le_gl);
145}
146
147static void glock_lo_add(struct gfs2_sbd *sdp, struct gfs2_log_element *le)
148{
149 gfs2_log_lock(sdp);
150 __glock_lo_add(sdp, le);
151 gfs2_log_unlock(sdp);
152}
153
154static void glock_lo_after_commit(struct gfs2_sbd *sdp, struct gfs2_ail *ai)
155{
156 struct list_head *head = &sdp->sd_log_le_gl;
157 struct gfs2_glock *gl;
158
159 while (!list_empty(head)) {
160 gl = list_entry(head->next, struct gfs2_glock, gl_le.le_list);
161 list_del_init(&gl->gl_le.le_list);
162 sdp->sd_log_num_gl--;
163
164 gfs2_assert_withdraw(sdp, gfs2_glock_is_held_excl(gl));
165 gfs2_glock_put(gl);
166 }
167 gfs2_assert_warn(sdp, !sdp->sd_log_num_gl);
168}
169
170static void buf_lo_add(struct gfs2_sbd *sdp, struct gfs2_log_element *le) 128static void buf_lo_add(struct gfs2_sbd *sdp, struct gfs2_log_element *le)
171{ 129{
172 struct gfs2_bufdata *bd = container_of(le, struct gfs2_bufdata, bd_le); 130 struct gfs2_bufdata *bd = container_of(le, struct gfs2_bufdata, bd_le);
@@ -182,7 +140,8 @@ static void buf_lo_add(struct gfs2_sbd *sdp, struct gfs2_log_element *le)
182 list_add(&bd->bd_list_tr, &tr->tr_list_buf); 140 list_add(&bd->bd_list_tr, &tr->tr_list_buf);
183 if (!list_empty(&le->le_list)) 141 if (!list_empty(&le->le_list))
184 goto out; 142 goto out;
185 __glock_lo_add(sdp, &bd->bd_gl->gl_le); 143 set_bit(GLF_LFLUSH, &bd->bd_gl->gl_flags);
144 set_bit(GLF_DIRTY, &bd->bd_gl->gl_flags);
186 gfs2_meta_check(sdp, bd->bd_bh); 145 gfs2_meta_check(sdp, bd->bd_bh);
187 gfs2_pin(sdp, bd->bd_bh); 146 gfs2_pin(sdp, bd->bd_bh);
188 sdp->sd_log_num_buf++; 147 sdp->sd_log_num_buf++;
@@ -568,8 +527,8 @@ static void databuf_lo_add(struct gfs2_sbd *sdp, struct gfs2_log_element *le)
568 if (!list_empty(&le->le_list)) 527 if (!list_empty(&le->le_list))
569 goto out; 528 goto out;
570 529
571 if (tr) 530 set_bit(GLF_LFLUSH, &bd->bd_gl->gl_flags);
572 __glock_lo_add(sdp, &bd->bd_gl->gl_le); 531 set_bit(GLF_DIRTY, &bd->bd_gl->gl_flags);
573 if (gfs2_is_jdata(ip)) { 532 if (gfs2_is_jdata(ip)) {
574 gfs2_pin(sdp, bd->bd_bh); 533 gfs2_pin(sdp, bd->bd_bh);
575 tr->tr_num_databuf_new++; 534 tr->tr_num_databuf_new++;
@@ -776,12 +735,6 @@ static void databuf_lo_after_commit(struct gfs2_sbd *sdp, struct gfs2_ail *ai)
776} 735}
777 736
778 737
779const struct gfs2_log_operations gfs2_glock_lops = {
780 .lo_add = glock_lo_add,
781 .lo_after_commit = glock_lo_after_commit,
782 .lo_name = "glock",
783};
784
785const struct gfs2_log_operations gfs2_buf_lops = { 738const struct gfs2_log_operations gfs2_buf_lops = {
786 .lo_add = buf_lo_add, 739 .lo_add = buf_lo_add,
787 .lo_incore_commit = buf_lo_incore_commit, 740 .lo_incore_commit = buf_lo_incore_commit,
@@ -819,7 +772,6 @@ const struct gfs2_log_operations gfs2_databuf_lops = {
819}; 772};
820 773
821const struct gfs2_log_operations *gfs2_log_ops[] = { 774const struct gfs2_log_operations *gfs2_log_ops[] = {
822 &gfs2_glock_lops,
823 &gfs2_databuf_lops, 775 &gfs2_databuf_lops,
824 &gfs2_buf_lops, 776 &gfs2_buf_lops,
825 &gfs2_rg_lops, 777 &gfs2_rg_lops,
diff --git a/fs/gfs2/ops_fstype.c b/fs/gfs2/ops_fstype.c
index 17de58e83d92..52aaba96d5da 100644
--- a/fs/gfs2/ops_fstype.c
+++ b/fs/gfs2/ops_fstype.c
@@ -77,7 +77,6 @@ static struct gfs2_sbd *init_sbd(struct super_block *sb)
77 77
78 spin_lock_init(&sdp->sd_log_lock); 78 spin_lock_init(&sdp->sd_log_lock);
79 79
80 INIT_LIST_HEAD(&sdp->sd_log_le_gl);
81 INIT_LIST_HEAD(&sdp->sd_log_le_buf); 80 INIT_LIST_HEAD(&sdp->sd_log_le_buf);
82 INIT_LIST_HEAD(&sdp->sd_log_le_revoke); 81 INIT_LIST_HEAD(&sdp->sd_log_le_revoke);
83 INIT_LIST_HEAD(&sdp->sd_log_le_rg); 82 INIT_LIST_HEAD(&sdp->sd_log_le_rg);
diff --git a/fs/gfs2/trans.c b/fs/gfs2/trans.c
index 717983e2c2ae..73e5d92a657c 100644
--- a/fs/gfs2/trans.c
+++ b/fs/gfs2/trans.c
@@ -114,11 +114,6 @@ void gfs2_trans_end(struct gfs2_sbd *sdp)
114 gfs2_log_flush(sdp, NULL); 114 gfs2_log_flush(sdp, NULL);
115} 115}
116 116
117void gfs2_trans_add_gl(struct gfs2_glock *gl)
118{
119 lops_add(gl->gl_sbd, &gl->gl_le);
120}
121
122/** 117/**
123 * gfs2_trans_add_bh - Add a to-be-modified buffer to the current transaction 118 * gfs2_trans_add_bh - Add a to-be-modified buffer to the current transaction
124 * @gl: the glock the buffer belongs to 119 * @gl: the glock the buffer belongs to
diff --git a/fs/gfs2/trans.h b/fs/gfs2/trans.h
index 043d5f4b9c4c..e826f0dab80a 100644
--- a/fs/gfs2/trans.h
+++ b/fs/gfs2/trans.h
@@ -30,7 +30,6 @@ int gfs2_trans_begin(struct gfs2_sbd *sdp, unsigned int blocks,
30 30
31void gfs2_trans_end(struct gfs2_sbd *sdp); 31void gfs2_trans_end(struct gfs2_sbd *sdp);
32 32
33void gfs2_trans_add_gl(struct gfs2_glock *gl);
34void gfs2_trans_add_bh(struct gfs2_glock *gl, struct buffer_head *bh, int meta); 33void gfs2_trans_add_bh(struct gfs2_glock *gl, struct buffer_head *bh, int meta);
35void gfs2_trans_add_revoke(struct gfs2_sbd *sdp, struct gfs2_bufdata *bd); 34void gfs2_trans_add_revoke(struct gfs2_sbd *sdp, struct gfs2_bufdata *bd);
36void gfs2_trans_add_unrevoke(struct gfs2_sbd *sdp, u64 blkno); 35void gfs2_trans_add_unrevoke(struct gfs2_sbd *sdp, u64 blkno);