From 1c6def292b8551495660bf5dc3477e3d634ed202 Mon Sep 17 00:00:00 2001 From: Roger Dingledine Date: Tue, 20 May 2003 06:53:10 +0000 Subject: remove dead code circuits no longer queue more cells when the windows are empty -- they simply don't package it from the buffer if they're not going to want it. we can restore this code later if we need to resume queueing. svn:r294 --- src/or/circuit.c | 63 +------------------------------------------------------- 1 file changed, 1 insertion(+), 62 deletions(-) (limited to 'src/or/circuit.c') diff --git a/src/or/circuit.c b/src/or/circuit.c index 023256eec2..80d5631afb 100644 --- a/src/or/circuit.c +++ b/src/or/circuit.c @@ -228,36 +228,16 @@ int circuit_deliver_relay_cell_from_edge(cell_t *cell, circuit_t *circ, cell_direction = CELL_DIRECTION_OUT; numsent_ap++; log(LOG_DEBUG,"circuit_deliver_relay_cell_from_edge(): now sent %d relay cells from ap", numsent_ap); -#if 0 - if(layer_hint->package_window <= 0) { - log(LOG_DEBUG,"circuit_deliver_relay_cell_from_edge(): package_window 0, queueing for later."); - circ->relay_queue = relay_queue_add(circ->relay_queue, cell, layer_hint); - return 0; - } - layer_hint->package_window--; -// log(LOG_INFO,"circuit_deliver_relay_cell_from_edge(): package_window now %d.",layer_hint->package_window); -#endif } else { /* i'm the exit */ cell_direction = CELL_DIRECTION_IN; -// assert(layer_hint == NULL); -// assert(circ->cpath == NULL); numsent_exit++; log(LOG_DEBUG,"circuit_deliver_relay_cell_from_edge(): now sent %d relay cells from exit", numsent_exit); -#if 0 - if(circ->package_window <= 0) { - log(LOG_DEBUG,"circuit_deliver_relay_cell_from_edge(): package_window 0, queueing for later."); - circ->relay_queue = relay_queue_add(circ->relay_queue, cell, layer_hint); - return 0; - } - circ->package_window--; -#endif } if(circuit_deliver_relay_cell(cell, circ, cell_direction, layer_hint) < 0) { return -1; } -// circuit_consider_stop_edge_reading(circ, edge_type, layer_hint); /* has window reached 0? */ return 0; } @@ -344,9 +324,8 @@ int relay_crypt(circuit_t *circ, char *in, int inlen, char cell_direction, thishop = thishop->next; } while(thishop != circ->cpath && thishop->state == CPATH_STATE_OPEN); - log(LOG_INFO,"relay_crypt(): in-cell at OP not recognized. Killing circuit."); + log(LOG_INFO,"relay_crypt(): in-cell at OP not recognized. Dropping."); return 0; -// return -1; } else { /* we're in the middle. Just one crypt. */ log(LOG_DEBUG,"relay_crypt(): before encrypt: %d",*(int*)(in+2)); @@ -448,46 +427,6 @@ void circuit_resume_edge_reading(circuit_t *circ, int edge_type, crypt_path_t *l assert(edge_type == EDGE_EXIT || edge_type == EDGE_AP); log(LOG_DEBUG,"circuit_resume_edge_reading(): resuming"); -#if 0 - /* first, send the queue waiting at circ onto the circuit */ - relay = circ->relay_queue; - while(relay) { - assert(relay->cell); - if(edge_type == EDGE_EXIT) { - assert(relay->layer_hint == NULL); - circ->package_window--; - assert(circ->package_window >= 0); - - if(circuit_deliver_relay_cell(relay->cell, circ, CELL_DIRECTION_IN, relay->layer_hint) < 0) { - circuit_close(circ); - return; - } - } else { /* ap */ - assert(relay->layer_hint); - if(relay->layer_hint != layer_hint) { - relay=relay->next; /* this cell isn't destined for this layer. don't send it. */ - continue; - } - relay->layer_hint->package_window--; - assert(relay->layer_hint->package_window >= 0); - - if(circuit_deliver_relay_cell(relay->cell, circ, CELL_DIRECTION_OUT, relay->layer_hint) < 0) { - circuit_close(circ); - return; - } - } - victim = relay; - relay=relay->next; - if(circ->relay_queue == victim) { - circ->relay_queue = relay; - } - free(victim->cell); - free(victim); - - if(circuit_consider_stop_edge_reading(circ, edge_type, layer_hint)) - return; - } -#endif if(edge_type == EDGE_EXIT) conn = circ->n_conn; -- cgit v1.2.3-54-g00ecf