]> err.no Git - linux-2.6/blobdiff - fs/gfs2/log.c
[GFS2] Update copyright, tidy up incore.h
[linux-2.6] / fs / gfs2 / log.c
index cadfef193e55eb02c711d125399cd17bbef7b39a..45ea3ec6f776e3d9e8ce387c7a861d24f3b9ab2e 100644 (file)
@@ -1,10 +1,10 @@
 /*
  * Copyright (C) Sistina Software, Inc.  1997-2003 All rights reserved.
- * Copyright (C) 2004-2005 Red Hat, Inc.  All rights reserved.
+ * Copyright (C) 2004-2006 Red Hat, Inc.  All rights reserved.
  *
  * This copyrighted material is made available to anyone wishing to use,
  * modify, copy, or redistribute it subject to the terms and conditions
- * of the GNU General Public License v.2.
+ * of the GNU General Public License version 2.
  */
 
 #include <linux/sched.h>
@@ -14,7 +14,6 @@
 #include <linux/buffer_head.h>
 #include <linux/gfs2_ondisk.h>
 #include <linux/crc32.h>
-#include <asm/semaphore.h>
 
 #include "gfs2.h"
 #include "lm_interface.h"
@@ -196,7 +195,6 @@ int gfs2_log_reserve(struct gfs2_sbd *sdp, unsigned int blks)
 
 void gfs2_log_release(struct gfs2_sbd *sdp, unsigned int blks)
 {
-       up_read(&sdp->sd_log_flush_lock);
 
        gfs2_log_lock(sdp);
        sdp->sd_log_blks_free += blks;
@@ -204,6 +202,7 @@ void gfs2_log_release(struct gfs2_sbd *sdp, unsigned int blks)
        gfs2_assert_withdraw(sdp,
                             sdp->sd_log_blks_free <= sdp->sd_jdesc->jd_blocks);
        gfs2_log_unlock(sdp);
+       up_read(&sdp->sd_log_flush_lock);
 }
 
 static uint64_t log_bmap(struct gfs2_sbd *sdp, unsigned int lbn)
@@ -211,9 +210,12 @@ static uint64_t log_bmap(struct gfs2_sbd *sdp, unsigned int lbn)
        int new = 0;
        uint64_t dbn;
        int error;
+       int bdy;
 
-       error = gfs2_block_map(sdp->sd_jdesc->jd_inode->u.generic_ip,
-                              lbn, &new, &dbn, NULL);
+       error = gfs2_block_map(sdp->sd_jdesc->jd_inode, lbn, &new, &dbn, &bdy);
+       if (!(!error && dbn)) {
+               printk(KERN_INFO "error=%d, dbn=%llu lbn=%u", error, (unsigned long long)dbn, lbn);
+       }
        gfs2_assert_withdraw(sdp, !error && dbn);
 
        return dbn;
@@ -254,8 +256,8 @@ static unsigned int current_tail(struct gfs2_sbd *sdp)
        if (list_empty(&sdp->sd_ail1_list))
                tail = sdp->sd_log_head;
        else {
-               ai = list_entry(sdp->sd_ail1_list.prev,
-                               struct gfs2_ail, ai_list);
+               ai = list_entry(sdp->sd_ail1_list.prev, struct gfs2_ail,
+                               ai_list);
                tail = ai->ai_first;
        }
 
@@ -384,10 +386,10 @@ static void log_write_header(struct gfs2_sbd *sdp, uint32_t flags, int pull)
        lh->lh_header.mh_magic = cpu_to_be32(GFS2_MAGIC);
        lh->lh_header.mh_type = cpu_to_be32(GFS2_METATYPE_LH);
        lh->lh_header.mh_format = cpu_to_be32(GFS2_FORMAT_LH);
-       lh->lh_sequence = be64_to_cpu(sdp->sd_log_sequence++);
-       lh->lh_flags = be32_to_cpu(flags);
-       lh->lh_tail = be32_to_cpu(tail);
-       lh->lh_blkno = be32_to_cpu(sdp->sd_log_flush_head);
+       lh->lh_sequence = cpu_to_be64(sdp->sd_log_sequence++);
+       lh->lh_flags = cpu_to_be32(flags);
+       lh->lh_tail = cpu_to_be32(tail);
+       lh->lh_blkno = cpu_to_be32(sdp->sd_log_flush_head);
        hash = gfs2_disk_hash(bh->b_data, sizeof(struct gfs2_log_header));
        lh->lh_hash = cpu_to_be32(hash);
 
@@ -412,11 +414,13 @@ static void log_flush_commit(struct gfs2_sbd *sdp)
        struct list_head *head = &sdp->sd_log_flush_list;
        struct gfs2_log_buf *lb;
        struct buffer_head *bh;
+#if 0
        unsigned int d;
 
        d = log_distance(sdp, sdp->sd_log_flush_head, sdp->sd_log_head);
 
        gfs2_assert_withdraw(sdp, d + 1 == sdp->sd_log_blks_reserved);
+#endif
 
        while (!list_empty(head)) {
                lb = list_entry(head->next, struct gfs2_log_buf, lb_list);
@@ -483,6 +487,7 @@ void gfs2_log_flush(struct gfs2_sbd *sdp, struct gfs2_glock *gl)
        sdp->sd_log_head = sdp->sd_log_flush_head;
 
        /* printk(KERN_INFO "sd_log_num_hdrs %u\n", sdp->sd_log_num_hdrs); */
+       sdp->sd_log_blks_free -= sdp->sd_log_num_hdrs;
 
        sdp->sd_log_blks_reserved =
                sdp->sd_log_commited_buf =
@@ -504,7 +509,7 @@ void gfs2_log_flush(struct gfs2_sbd *sdp, struct gfs2_glock *gl)
 
 static void log_refund(struct gfs2_sbd *sdp, struct gfs2_trans *tr)
 {
-       unsigned int reserved = 1;
+       unsigned int reserved = 0;
        unsigned int old;
 
        gfs2_log_lock(sdp);
@@ -515,11 +520,12 @@ static void log_refund(struct gfs2_sbd *sdp, struct gfs2_trans *tr)
        gfs2_assert_withdraw(sdp, ((int)sdp->sd_log_commited_revoke) >= 0);
 
        if (sdp->sd_log_commited_buf)
-               reserved += 1 + sdp->sd_log_commited_buf +
-                           sdp->sd_log_commited_buf/503;
+               reserved += sdp->sd_log_commited_buf;
        if (sdp->sd_log_commited_revoke)
                reserved += gfs2_struct2blk(sdp, sdp->sd_log_commited_revoke,
                                            sizeof(uint64_t));
+       if (reserved)
+               reserved++;
 
        old = sdp->sd_log_blks_free;
        sdp->sd_log_blks_free += tr->tr_reserved -
@@ -527,7 +533,8 @@ static void log_refund(struct gfs2_sbd *sdp, struct gfs2_trans *tr)
 
        gfs2_assert_withdraw(sdp, sdp->sd_log_blks_free >= old);
        gfs2_assert_withdraw(sdp,
-                            sdp->sd_log_blks_free <= sdp->sd_jdesc->jd_blocks);
+                            sdp->sd_log_blks_free <= sdp->sd_jdesc->jd_blocks +
+                            sdp->sd_log_num_hdrs);
 
        sdp->sd_log_blks_reserved = reserved;
 
@@ -575,6 +582,7 @@ void gfs2_log_shutdown(struct gfs2_sbd *sdp)
        gfs2_assert_withdraw(sdp, !sdp->sd_log_num_revoke);
        gfs2_assert_withdraw(sdp, !sdp->sd_log_num_rg);
        gfs2_assert_withdraw(sdp, !sdp->sd_log_num_databuf);
+       gfs2_assert_withdraw(sdp, !sdp->sd_log_num_hdrs);
        gfs2_assert_withdraw(sdp, list_empty(&sdp->sd_ail1_list));
 
        sdp->sd_log_flush_head = sdp->sd_log_head;
@@ -582,10 +590,10 @@ void gfs2_log_shutdown(struct gfs2_sbd *sdp)
 
        log_write_header(sdp, GFS2_LOG_HEAD_UNMOUNT, 0);
 
-       gfs2_assert_withdraw(sdp, sdp->sd_log_blks_free ==
-                            sdp->sd_jdesc->jd_blocks);
-       gfs2_assert_withdraw(sdp, sdp->sd_log_head == sdp->sd_log_tail);
-       gfs2_assert_withdraw(sdp, list_empty(&sdp->sd_ail2_list));
+       /* printk(KERN_INFO "sd_log_blks_free %u, sd_jdesc->jd_blocks %u\n", sdp->sd_log_blks_free, sdp->sd_jdesc->jd_blocks); */
+       gfs2_assert_warn(sdp, sdp->sd_log_blks_free == sdp->sd_jdesc->jd_blocks);
+       gfs2_assert_warn(sdp, sdp->sd_log_head == sdp->sd_log_tail);
+       gfs2_assert_warn(sdp, list_empty(&sdp->sd_ail2_list));
 
        sdp->sd_log_head = sdp->sd_log_flush_head;
        sdp->sd_log_tail = sdp->sd_log_head;