Changeset 305 for trunk/src/sh_hash.c

Timestamp:

Nov 13, 2010, 11:24:24 PM (14 years ago)

Author:

katerina

Message:

Fix for ticker #226 (incorrect handling of missing files when secondary schedule is active).

File:

• trunk/src/sh_hash.c (modified) (8 diffs)

trunk/src/sh_hash.c

@@ -393 +393 @@
 }
 
+struct two_sh_file_t {
+  sh_file_t * prev;
+  sh_file_t * this;
+};
+
 static sh_file_t * hashsearch (const char * s);
+static int hashsearch_prev (const char * s, struct two_sh_file_t * a, int * index); 
 
 static sh_file_t * tab[TABSIZE];
@@ -423 +429 @@
   char hashbuf[KEYBUF_SIZE];
   int  retval;
+  volatile int flag = 0;
 
   /* --------  find the entry for the file ----------------       */
@@ -449 +456 @@
   sh_error_handle (level, FIL__, __LINE__, 0, 
                    MSG_FI_MISS2, tmp, str);
+  flag = 1;
   SH_FREE(tmp);
   SH_FREE(str);
@@ -458 +466 @@
   ; /* 'label at end of compound statement */
   SH_MUTEX_UNLOCK(mutex_hash);
+
   return retval;
 }
@@ -625 +634 @@
 
 
+
 /*********************************************************************
  *
@@ -646 +656 @@
   SL_RET0(_("hash_unvisited"));
 }
+
+/*********************************************************************
+ *
+ * Remove a single file from the database.
+ *
+ *********************************************************************/
+void sh_hash_remove (const char * path)
+{
+  struct two_sh_file_t entries;
+  int index;
+
+  SL_ENTER(_("sh_hash_remove"));
+
+  SH_MUTEX_LOCK(mutex_hash);
+
+  if ((sh.flag.reportonce == S_TRUE && sh.flag.update == S_FALSE) || 
+      (S_TRUE == sh.flag.update && S_TRUE == sh_util_ask_update(path)))
+    {
+      if (0 == hashsearch_prev (path, &entries, &index))
+        {
+          sh_file_t * p = entries.this;
+#ifdef REPLACE_OLD
+          /* Remove the old entry
+           */
+          if (entries.prev == p)
+            tab[index] = p->next;
+          else
+            entries.prev->next = p->next;
+          
+          p = delete_db_entry(p);
+          
+          goto end;
+          SL_RET0(_("sh_hash_remove"));
+#else
+          SET_SH_FFLAG_REPORTED(p->fflags); 
+#endif
+        }
+    }
+
+ end:
+  ; /* 'label at end of compound statement' */
+  SH_MUTEX_UNLOCK(mutex_hash);
+
+  SL_RET0(_("sh_hash_remove"));
+}
+
 
 /*********************************************************************
@@ -772 +828 @@
     } 
   SL_RETURN( NULL, _("hashsearch"));
+} 
+
+static int hashsearch_prev (const char * s, struct two_sh_file_t * a, int * index) 
+{
+  sh_file_t * this;
+  sh_file_t * prev = NULL;
+
+  SL_ENTER(_("hashsearch_prev"));
+
+  if (s)
+    {
+      *index = hashfunc(s);
+
+      this = tab[*index];
+
+      prev  = this;
+
+      if (this)
+        {
+          do {
+            
+            if ((this->fullpath != NULL) && (0 == strcmp(s, this->fullpath)))
+              {
+                a->prev = prev;
+                a->this = this;
+                
+                SL_RETURN( 0, _("hashsearch_prev"));
+              }
+            
+            prev = this;
+            this = this->next;
+            
+          } while(this);
+        } 
+    }
+  SL_RETURN( -1, _("hashsearch"));
 } 
 
@@ -2226 +2318 @@
   int i;
   SL_ENTER(_("sh_hash_set_missing"));
+
   i = sh_hash_set_visited_int(newname, SH_FFLAG_CHECKED);
+
+  if (sh.flag.checkSum != SH_CHECK_INIT) {
+    sh_hash_remove(newname);
+  }
+
   SL_RETURN(i, _("sh_hash_set_missing"));
 }