[or-cvs] Dont keep rephist info for routers that havent had activity...

[Nick Mathewson]

Update of /home/or/cvsroot/tor/src/or
In directory moria.mit.edu:/tmp/cvs-serv9004/src/or

Modified Files:
	main.c or.h rephist.c 
Log Message:
Dont keep rephist info for routers that havent had activity for 24 hours.

Index: main.c
===================================================================
RCS file: /home/or/cvsroot/tor/src/or/main.c,v
retrieving revision 1.383
retrieving revision 1.384
diff -u -d -r1.383 -r1.384
--- main.c	21 Nov 2004 04:19:04 -0000	1.383
+++ main.c	21 Nov 2004 05:14:46 -0000	1.384
@@ -588,6 +588,9 @@
     if (time_to_fetch_running_routers < now + options->StatusFetchPeriod) {
       time_to_fetch_running_routers = now + options->StatusFetchPeriod;
     }
+
+    /* Also, take this chance to remove old information from rephist. */
+    rep_history_clean(now-24*60*60);
   }
 
   if (time_to_fetch_running_routers < now) {

Index: or.h
===================================================================
RCS file: /home/or/cvsroot/tor/src/or/or.h,v
retrieving revision 1.488
retrieving revision 1.489
diff -u -d -r1.488 -r1.489
--- or.h	21 Nov 2004 04:19:04 -0000	1.488
+++ or.h	21 Nov 2004 05:14:46 -0000	1.489
@@ -1428,6 +1428,7 @@
 void rep_hist_note_bytes_written(int num_bytes, time_t when);
 int rep_hist_bandwidth_assess(void);
 char *rep_hist_get_bandwidth_lines(void);
+void rep_history_clean(time_t before);
 
 /********************************* rendclient.c ***************************/
 

Index: rephist.c
===================================================================
RCS file: /home/or/cvsroot/tor/src/or/rephist.c,v
retrieving revision 1.40
retrieving revision 1.41
diff -u -d -r1.40 -r1.41
--- rephist.c	12 Nov 2004 16:39:03 -0000	1.40
+++ rephist.c	21 Nov 2004 05:14:46 -0000	1.41
@@ -15,6 +15,8 @@
 typedef struct link_history_t {
   /** When did we start tracking this list? */
   time_t since;
+  /** When did we most recently note a change to this link */
+  time_t changed;
   /** How many times did extending from OR1 to OR2 succeeed? */
   unsigned long n_extend_ok;
   /** How many times did extending from OR1 to OR2 fail? */
@@ -25,6 +27,8 @@
 typedef struct or_history_t {
   /** When did we start tracking this OR? */
   time_t since;
+  /** When did we most recently note a change to this OR? */
+  time_t changed;
   /** How many times did we successfully connect? */
   unsigned long n_conn_ok;
   /** How many times did we try to connect and fail?*/
@@ -62,7 +66,7 @@
   if (!hist) {
     hist = tor_malloc_zero(sizeof(or_history_t));
     hist->link_history_map = strmap_new();
-    hist->since = time(NULL);
+    hist->since = hist->changed = time(NULL);
     strmap_set(history_map, hexid, hist);
   }
   return hist;
@@ -87,12 +91,25 @@
   lhist = (link_history_t*) strmap_get(orhist->link_history_map, to_hexid);
   if (!lhist) {
     lhist = tor_malloc_zero(sizeof(link_history_t));
-    lhist->since = time(NULL);
+    lhist->since = lhist->changed = time(NULL);
     strmap_set(orhist->link_history_map, to_hexid, lhist);
   }
   return lhist;
 }
 
+static void
+_free_link_history(void *val)
+{
+  tor_free(val);
+}
+
+static void
+free_or_history(or_history_t *hist)
+{
+  strmap_free(hist->link_history_map, _free_link_history);
+  tor_free(hist);
+}
+
 /** Update an or_history_t object <b>hist</b> so that its uptime/downtime
  * count is up-to-date as of <b>when</b>.
  */
@@ -133,6 +150,7 @@
   }
   if (!hist->down_since)
     hist->down_since = when;
+  hist->changed = when;
 }
 
 /** Remember that an attempt to connect to the OR with identity digest
@@ -151,6 +169,7 @@
   }
   if (!hist->up_since)
     hist->up_since = when;
+  hist->changed = when;
 }
 
 /** Remember that we intentionally closed our connection to the OR
@@ -167,6 +186,7 @@
     hist->uptime += (when - hist->up_since);
     hist->up_since = 0;
   }
+  hist->changed = when;
 }
 
 /** Remember that our connection to the OR with identity digest
@@ -192,6 +212,7 @@
   }
   if (!hist->down_since)
     hist->down_since = when;
+  hist->changed = when;
 }
 
 /** Remember that we successfully extended from the OR with identity
@@ -207,6 +228,7 @@
   if (!hist)
     return;
   ++hist->n_extend_ok;
+  hist->changed = time(NULL);
 }
 
 /** Remember that we tried to extend from the OR with identity digest
@@ -221,6 +243,7 @@
   if (!hist)
     return;
   ++hist->n_extend_fail;
+  hist->changed = time(NULL);
 }
 
 /** Log all the reliability data we have rememberred, with the chosen
@@ -241,6 +264,8 @@
   unsigned long upt, downt;
   routerinfo_t *r;
 
+  rep_history_clean(now-24*60*60);
+
   log(severity, "--------------- Dumping history information:");
 
   for (orhist_it = strmap_iter_init(history_map); !strmap_iter_done(orhist_it);
@@ -294,6 +319,40 @@
   }
 }
 
+/** Remove history info for routers/links that haven't changed since
+ * <b>before</b> */
+void rep_history_clean(time_t before)
+{
+  or_history_t *or_history;
+  link_history_t *link_history;
+  void *or_history_p, *link_history_p;
+  strmap_iter_t *orhist_it, *lhist_it;
+  const char *hd1, *hd2;
+
+  orhist_it = strmap_iter_init(history_map);
+  while (!strmap_iter_done(orhist_it)) {
+    strmap_iter_get(orhist_it, &hd1, &or_history_p);
+    or_history = or_history_p;
+    if (or_history->changed < before) {
+      free_or_history(or_history);
+      orhist_it = strmap_iter_next_rmv(history_map, orhist_it);
+      continue;
+    }
+    for (lhist_it = strmap_iter_init(or_history->link_history_map);
+         !strmap_iter_done(lhist_it); ) {
+      strmap_iter_get(lhist_it, &hd2, &link_history_p);
+      link_history = link_history_p;
+      if (link_history->changed < before) {
+        tor_free(link_history);
+        lhist_it = strmap_iter_next_rmv(or_history->link_history_map,lhist_it);
+        continue;
+      }
+      lhist_it = strmap_iter_next(or_history->link_history_map,lhist_it);
+    }
+    orhist_it = strmap_iter_next(history_map, orhist_it);
+  }
+}
+
 #if 0
 void write_rep_history(const char *filename)
 {