aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRoger Dingledine <arma@torproject.org>2002-07-22 04:38:36 +0000
committerRoger Dingledine <arma@torproject.org>2002-07-22 04:38:36 +0000
commitc42c2b66409a855bbf749ffc661133f0f7d4660c (patch)
tree7972a4532ff804c82f8d65d2f00052ac37ee1852
parentcd0760ddda650c147ba21b933cebef5008eb645e (diff)
downloadtor-c42c2b66409a855bbf749ffc661133f0f7d4660c.tar
tor-c42c2b66409a855bbf749ffc661133f0f7d4660c.tar.gz
only choose routers for the onion that are currently connected to us
svn:r72
-rw-r--r--src/or/onion.c17
1 files changed, 10 insertions, 7 deletions
diff --git a/src/or/onion.c b/src/or/onion.c
index 34f1db36a..a7240addc 100644
--- a/src/or/onion.c
+++ b/src/or/onion.c
@@ -100,8 +100,8 @@ unsigned int *new_route(double cw, routerinfo_t **rarray, size_t rarray_len, siz
unsigned int *route = NULL;
unsigned int oldchoice, choice;
- if ( (cw >= 0) && (cw < 1) && (rarray) && (rlen) ) /* valid parameters */
- {
+ assert((cw >= 0) && (cw < 1) && (rarray) && (rlen) ); /* valid parameters */
+
routelen = chooselen(cw);
if (routelen == -1)
{
@@ -109,6 +109,9 @@ unsigned int *new_route(double cw, routerinfo_t **rarray, size_t rarray_len, siz
return NULL;
}
log(LOG_DEBUG,"new_route(): Chosen route length %u.",routelen);
+
+ /* FIXME need to figure out how many routers we can actually choose from.
+ * We can get into an infinite loop if there are too few. */
/* allocate memory for the new route */
route = (unsigned int *)malloc(routelen * sizeof(unsigned int));
@@ -132,8 +135,11 @@ unsigned int *new_route(double cw, routerinfo_t **rarray, size_t rarray_len, siz
choice = choice % (rarray_len);
log(LOG_DEBUG,"new_route() : Chosen router %u.",choice);
if (choice == oldchoice ||
- (oldchoice < rarray_len && !pkey_cmp(rarray[choice]->pkey, rarray[oldchoice]->pkey))) {
- /* same router, or router twin. try again. */
+ (oldchoice < rarray_len && !pkey_cmp(rarray[choice]->pkey, rarray[oldchoice]->pkey)) ||
+ !connection_twin_get_by_addr_port(rarray[choice]->addr, rarray[choice]->or_port)) {
+ /* Same router as last choice, or router twin,
+ * or no routers with that key are connected to us.
+ * Try again. */
i--;
continue;
}
@@ -143,9 +149,6 @@ unsigned int *new_route(double cw, routerinfo_t **rarray, size_t rarray_len, siz
*rlen = routelen;
return route;
- } /* valid parameters */
- else /* invalid parameters */
- return NULL;
}
/* creates a new onion from route, stores it and its length into bufp and lenp respectively */