chiark / gitweb /
rename recentact to lowvol
authorIan Jackson <ian@liberator.(none)>
Wed, 5 May 2010 20:36:39 +0000 (21:36 +0100)
committerIan Jackson <ian@liberator.(none)>
Wed, 5 May 2010 20:36:39 +0000 (21:36 +0100)
backends/innduct.c

index adf6cad9573b4b925b79c2dacd8a46278f5500ec..b5fb0176cf5e8adc29ca33c5f5161994ff521ac0 100644 (file)
@@ -391,8 +391,8 @@ static int backlog_spontrescan_periods=300;
 static int spontaneous_flush_periods=100000;
 static int max_separated_periods=2000;
 static int need_activity_periods=1000;
-static int recentact_thresh=3;
-static int recentact_periods=1000;
+static int lowvol_thresh=3;
+static int lowvol_periods=1000;
 
 static double max_bad_data_ratio= 1; /* conv'd from percentage by main */
 static int max_bad_data_initial= 30;
@@ -530,9 +530,9 @@ static ConnList conns;
 static char *path_lock, *path_flushing, *path_defer, *path_dump;
 static char *globpat_backlog;
 static pid_t self_pid;
-static int *recentact_perperiod;
-static int recentact_circptr;
-static int recentact_total;
+static int *lowvol_perperiod;
+static int lowvol_circptr;
+static int lowvol_total;
 
 /* statemc_init initialises */
 static StateMachineState sms;
@@ -1190,11 +1190,11 @@ static void conn_idle_close(Conn *conn, const char *why) {
 static void check_idle_conns(void) {
   Conn *conn;
 
-  int veryrecentact= recentact_perperiod[recentact_circptr];
-  recentact_circptr++;
-  recentact_circptr %= recentact_periods;
-  recentact_total -= recentact_perperiod[recentact_circptr];
-  recentact_perperiod[recentact_circptr]= 0;
+  int verylowvol= lowvol_perperiod[lowvol_circptr];
+  lowvol_circptr++;
+  lowvol_circptr %= lowvol_periods;
+  lowvol_total -= lowvol_perperiod[lowvol_circptr];
+  lowvol_perperiod[lowvol_circptr]= 0;
 
   FOR_CONN(conn)
     conn->since_activity++;
@@ -1220,9 +1220,9 @@ static void check_idle_conns(void) {
   }
 
   conn= LIST_HEAD(conns);
-  if (!veryrecentact &&
+  if (!verylowvol &&
       conns.count==1 &&
-      recentact_total+veryrecentact < recentact_thresh &&
+      lowvol_total+verylowvol < lowvol_thresh &&
       !conn_busy(conn))
     conn_idle_close(conn, "low volume");
 }  
@@ -1521,7 +1521,7 @@ static void check_assign_articles(void) {
        Article *art= dequeue(0);
        if (!art) break;
        LIST_ADDTAIL(use->waiting, art);
-       recentact_perperiod[recentact_circptr]++;
+       lowvol_perperiod[lowvol_circptr]++;
        spare--;
       }
       conn_maybe_write(use);
@@ -3654,8 +3654,8 @@ static const Option innduct_options[]= {
 {0,"max-flush-interval",     "PERIOD", &spontaneous_flush_periods,op_seconds },
 {0,"flush-finish-timeout",   "PERIOD", &max_separated_periods,    op_seconds },
 {0,"idle-timeout",           "PERIOD", &need_activity_periods,    op_seconds },
-{0,"low-volume-thresh",      "PERIOD", &recentact_thresh,         op_integer },
-{0,"low-volume-window",      "PERIOD", &recentact_periods,        op_seconds },
+{0,"low-volume-thresh",      "PERIOD", &lowvol_thresh,            op_integer },
+{0,"low-volume-window",      "PERIOD", &lowvol_periods,           op_seconds },
 
 {0,"max-bad-input-data-ratio","PERCENT", &max_bad_data_ratio,   op_double    },
 {0,"max-bad-input-data-init", "PERCENT", &max_bad_data_initial, op_integer   },
@@ -3729,7 +3729,7 @@ int main(int argc, char **argv) {
   convert_to_periods_rndup(&spontaneous_flush_periods);
   convert_to_periods_rndup(&max_separated_periods);
   convert_to_periods_rndup(&need_activity_periods);
-  convert_to_periods_rndup(&recentact_periods);
+  convert_to_periods_rndup(&lowvol_periods);
 
   if (max_bad_data_ratio < 0 || max_bad_data_ratio > 100)
     badusage("bad input data ratio must be between 0..100");
@@ -3765,10 +3765,10 @@ int main(int argc, char **argv) {
       badusage("feed filename may not contain metacharacter %c",c);
 
   int i;
-  recentact_perperiod= xcalloc(sizeof(*recentact_perperiod),recentact_periods);
-  for (i=0; i<recentact_periods; i++) {
-    recentact_perperiod[i]= recentact_thresh;
-    recentact_total += recentact_thresh;
+  lowvol_perperiod= xcalloc(sizeof(*lowvol_perperiod), lowvol_periods);
+  for (i=0; i<lowvol_periods; i++) {
+    lowvol_perperiod[i]= lowvol_thresh;
+    lowvol_total += lowvol_thresh;
   }
 
   /* set things up */