From a6a17bc52ca8951debf294d616c30cf0fe010c02 Mon Sep 17 00:00:00 2001
From: nvt-se <nvt-se>
Date: Tue, 4 Nov 2008 15:49:54 +0000
Subject: [PATCH] optimized the merge log operation and fixed a fd update bug.

---
 core/cfs/cfs-coffee.c | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/core/cfs/cfs-coffee.c b/core/cfs/cfs-coffee.c
index fb3015293..d5aef3ba2 100644
--- a/core/cfs/cfs-coffee.c
+++ b/core/cfs/cfs-coffee.c
@@ -338,7 +338,7 @@ find_offset_in_file(int first_page)
    * are zeroes, then these are skipped from the calculation.
    */
   
-  for(page = first_page + range_end; page >= first_page; page--) {
+  for(page = first_page + range_end - 1; page >= first_page; page--) {
     watchdog_periodic();
     COFFEE_READ(buf, sizeof(buf), page * COFFEE_PAGE_SIZE);
     for(i = COFFEE_PAGE_SIZE - 1; i >= 0; i--) {
@@ -633,7 +633,6 @@ merge_log(coffee_page_t file_page)
   coffee_page_t log_page, new_file_page;
   struct file_header hdr, hdr2;
   int fd, n;
-  char buf[64];
   coffee_offset_t offset;
 
   READ_HEADER(&hdr, file_page);
@@ -658,6 +657,7 @@ merge_log(coffee_page_t file_page)
 
   offset = 0;
   do {
+    char buf[hdr.log_entry_size == 0 ? COFFEE_PAGE_SIZE : hdr.log_entry_size];
     watchdog_periodic();
     n = cfs_read(fd, buf, sizeof(buf));
     if(n < 0) {
@@ -689,6 +689,7 @@ merge_log(coffee_page_t file_page)
     if(coffee_fd_set[n].file_page == file_page) {
 	coffee_fd_set[n].file_page = new_file_page;
 	coffee_fd_set[n].flags &= ~COFFEE_FD_MODIFIED;
+	coffee_fd_set[n].next_log_entry = 0;
     }
   }
 
@@ -759,7 +760,6 @@ write_log_page(struct file_desc *fdp, struct log_param *lp)
     if(log_entry >= log_entries) {
       /* The log is full; merge the log. */
       PRINTF("Coffee: Merging the file %s with its log\n", hdr.name);
-      fdp->next_log_entry = 0;
       return merge_log(fdp->file_page);
     }
   } else {