summaryrefslogtreecommitdiff
path: root/src/or/relay.c
diff options
context:
space:
mode:
authorNick Mathewson <nickm@torproject.org>2006-07-26 19:07:37 +0000
committerNick Mathewson <nickm@torproject.org>2006-07-26 19:07:37 +0000
commitec82db6995e260b9400ded5a767e1f9c60a3cb18 (patch)
tree889f533f374f4c38c4066c9f428d994d2727c5c0 /src/or/relay.c
parent4ff4577beb7b7aa286059a5070b23357fff48bf3 (diff)
downloadtor-ec82db6995e260b9400ded5a767e1f9c60a3cb18.tar.gz
tor-ec82db6995e260b9400ded5a767e1f9c60a3cb18.zip
r6909@Kushana: nickm | 2006-07-26 13:05:58 -0400
Clean up wide lines from last patch. svn:r6907
Diffstat (limited to 'src/or/relay.c')
-rw-r--r--src/or/relay.c18
1 files changed, 12 insertions, 6 deletions
diff --git a/src/or/relay.c b/src/or/relay.c
index 35154f1af2..094697361f 100644
--- a/src/or/relay.c
+++ b/src/or/relay.c
@@ -396,7 +396,8 @@ relay_lookup_conn(circuit_t *circ, cell_t *cell, int cell_direction)
} else {
for (tmpconn = TO_OR_CIRCUIT(circ)->n_streams; tmpconn;
tmpconn=tmpconn->next_stream) {
- if (rh.stream_id == tmpconn->stream_id && !tmpconn->_base.marked_for_close) {
+ if (rh.stream_id == tmpconn->stream_id &&
+ !tmpconn->_base.marked_for_close) {
log_debug(LD_EXIT,"found conn for stream %d.", rh.stream_id);
if (cell_direction == CELL_DIRECTION_OUT ||
connection_edge_is_rendezvous_stream(tmpconn))
@@ -405,7 +406,8 @@ relay_lookup_conn(circuit_t *circ, cell_t *cell, int cell_direction)
}
for (tmpconn = TO_OR_CIRCUIT(circ)->resolving_streams; tmpconn;
tmpconn=tmpconn->next_stream) {
- if (rh.stream_id == tmpconn->stream_id && !tmpconn->_base.marked_for_close) {
+ if (rh.stream_id == tmpconn->stream_id &&
+ !tmpconn->_base.marked_for_close) {
log_debug(LD_EXIT,"found conn for stream %d.", rh.stream_id);
return tmpconn;
}
@@ -465,7 +467,8 @@ connection_edge_send_command(edge_connection_t *fromconn, circuit_t *circ,
if (fromconn && fromconn->_base.marked_for_close) {
log_warn(LD_BUG,
"Bug: called on conn that's already marked for close at %s:%d.",
- fromconn->_base.marked_for_close_file, fromconn->_base.marked_for_close);
+ fromconn->_base.marked_for_close_file,
+ fromconn->_base.marked_for_close);
return 0;
}
@@ -780,7 +783,8 @@ connection_edge_process_end_not_open(
circuit_log_path(LOG_INFO,LD_APP,circ);
connection_mark_unattached_ap(conn, reason);
} else {
- conn->_base.edge_has_sent_end = 1; /* we just got an 'end', don't need to send one */
+ /* we just got an 'end', don't need to send one */
+ conn->_base.edge_has_sent_end = 1;
connection_mark_for_close(TO_CONN(conn));
}
return 0;
@@ -807,7 +811,8 @@ connection_edge_process_relay_cell_not_open(
return 0;
}
- if (conn->_base.type == CONN_TYPE_AP && rh->command == RELAY_COMMAND_CONNECTED) {
+ if (conn->_base.type == CONN_TYPE_AP &&
+ rh->command == RELAY_COMMAND_CONNECTED) {
tor_assert(CIRCUIT_IS_ORIGIN(circ));
if (conn->_base.state != AP_CONN_STATE_CONNECT_WAIT) {
log_warn(LD_APP,"Got 'connected' while not in state connect_wait. "
@@ -846,7 +851,8 @@ connection_edge_process_relay_cell_not_open(
}
return 0;
}
- if (conn->_base.type == CONN_TYPE_AP && rh->command == RELAY_COMMAND_RESOLVED) {
+ if (conn->_base.type == CONN_TYPE_AP &&
+ rh->command == RELAY_COMMAND_RESOLVED) {
int ttl;
int answer_len;
if (conn->_base.state != AP_CONN_STATE_RESOLVE_WAIT) {