diff options
Diffstat (limited to 'src/or/relay.c')
| -rw-r--r-- | src/or/relay.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/or/relay.c b/src/or/relay.c index 46c23d7de4..8e6f623b01 100644 --- a/src/or/relay.c +++ b/src/or/relay.c @@ -349,7 +349,7 @@ relay_lookup_conn(circuit_t *circ, cell_t *cell, int cell_direction) */ for (tmpconn = circ->n_streams; tmpconn; tmpconn=tmpconn->next_stream) { - if (rh.stream_id == tmpconn->stream_id) { + if (rh.stream_id == tmpconn->stream_id && !tmpconn->marked_for_close) { log_fn(LOG_DEBUG,"found conn for stream %d.", rh.stream_id); if (cell_direction == CELL_DIRECTION_OUT || connection_edge_is_rendezvous_stream(tmpconn)) @@ -357,13 +357,13 @@ relay_lookup_conn(circuit_t *circ, cell_t *cell, int cell_direction) } } for (tmpconn = circ->p_streams; tmpconn; tmpconn=tmpconn->next_stream) { - if (rh.stream_id == tmpconn->stream_id) { + if (rh.stream_id == tmpconn->stream_id && !tmpconn->marked_for_close) { log_fn(LOG_DEBUG,"found conn for stream %d.", rh.stream_id); return tmpconn; } } for (tmpconn = circ->resolving_streams; tmpconn; tmpconn=tmpconn->next_stream) { - if (rh.stream_id == tmpconn->stream_id) { + if (rh.stream_id == tmpconn->stream_id && !tmpconn->marked_for_close) { log_fn(LOG_DEBUG,"found conn for stream %d.", rh.stream_id); return tmpconn; } |