New function index_gc().

2 files changed, 43 insertions, 0 deletions

diff --git a/data.c b/data.c
index 4d892cc..8888d4a 100644
--- a/data.c
+++ b/data.c
@@ -285,6 +285,48 @@ int index_add(const char *fn, const char *id)
 }
 
 
+int index_gc(const char *fn)
+/* garbage-collects an index, deleting objects that are not here */
+{
+    FILE *i, *o;
+    int gc = -1;
+
+    pthread_mutex_lock(&data_mutex);
+
+    if ((i = fopen(fn, "r")) != NULL) {
+        xs *nfn = xs_fmt("%s.new", fn);
+        char line[256];
+
+        if ((o = fopen(nfn, "w")) != NULL) {
+            gc = 0;
+
+            while (fgets(line, sizeof(line), i) != NULL) {
+                line[32] = '\0';
+
+                if (object_here_by_md5(line))
+                    fprintf(o, "%s\n", line);
+                else
+                    gc++;
+            }
+
+            fclose(o);
+
+            xs *ofn = xs_fmt("%s.bak", fn);
+
+            unlink(ofn);
+            link(fn, ofn);
+            rename(nfn, fn);
+        }
+
+        fclose(i);
+    }
+
+    pthread_mutex_unlock(&data_mutex);
+
+    return gc;
+}
+
+
 int index_del_md5(const char *fn, const char *md5)
 /* deletes an md5 from an index */
 {
diff --git a/snac.h b/snac.h
index ba8b680..5c02871 100644
--- a/snac.h
+++ b/snac.h
@@ -60,6 +60,7 @@ double mtime_nl(const char *fn, int *n_link);
 #define mtime(fn) mtime_nl(fn, NULL)
 
 int index_add(const char *fn, const char *md5);
+int index_gc(const char *fn);
 int index_del(const char *fn, const char *md5);
 int index_first(const char *fn, char *buf, int size);
 int index_len(const char *fn);