[or-cvs] forward-port the onion queue thing

[arma@xxxxxxxx (Roger Dingledine)]

Update of /home2/or/cvsroot/tor/src/or
In directory moria.mit.edu:/home2/arma/work/onion/cvs/tor/src/or

Modified Files:
	onion.c 
Log Message:
forward-port the onion queue thing


Index: onion.c
===================================================================
RCS file: /home2/or/cvsroot/tor/src/or/onion.c,v
retrieving revision 1.175
retrieving revision 1.176
diff -u -d -r1.175 -r1.176
--- onion.c	11 Feb 2005 01:26:47 -0000	1.175
+++ onion.c	20 Feb 2005 09:27:48 -0000	1.176
@@ -15,13 +15,17 @@
 
 struct onion_queue_t {
   circuit_t *circ;
+  time_t when_added;
   struct onion_queue_t *next;
 };
 
-/** global (within this file) variables used by the next few functions */
+/** 5 seconds on the onion queue til we just send back a destroy */
+#define ONIONQUEUE_WAIT_CUTOFF 5
+
+/** Global (within this file) variables used by the next few functions */
 static struct onion_queue_t *ol_list=NULL;
 static struct onion_queue_t *ol_tail=NULL;
-/** length of ol_list */
+/** Length of ol_list */
 static int ol_length=0;
 
 /** Add <b>circ</b> to the end of ol_list and return 0, except
@@ -29,9 +33,11 @@
  */
 int onion_pending_add(circuit_t *circ) {
   struct onion_queue_t *tmp;
+  time_t now = time(NULL);
 
   tmp = tor_malloc_zero(sizeof(struct onion_queue_t));
   tmp->circ = circ;
+  tmp->when_added = now;
 
   if (!ol_tail) {
     tor_assert(!ol_list);
@@ -54,6 +60,13 @@
   ol_length++;
   ol_tail->next = tmp;
   ol_tail = tmp;
+  while ((int)(now - ol_list->when_added) >= ONIONQUEUE_WAIT_CUTOFF) {
+    /* cull elderly requests. */
+    circ = ol_list->circ;
+    onion_pending_remove(ol_list->circ);
+    log_fn(LOG_INFO,"Circuit create request is too old; cancelling due to overload.");
+    circuit_mark_for_close(circ);
+  }
   return 0;
 }