diff options
Diffstat (limited to 'src/transport/gnunet-service-transport.c')
-rw-r--r-- | src/transport/gnunet-service-transport.c | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/transport/gnunet-service-transport.c b/src/transport/gnunet-service-transport.c index 8f88311b0..b89bc8bce 100644 --- a/src/transport/gnunet-service-transport.c +++ b/src/transport/gnunet-service-transport.c | |||
@@ -1194,9 +1194,6 @@ try_transmission_to_peer (struct NeighbourList *neighbour) | |||
1194 | /* FIXME: support bi-directional use of TCP */ | 1194 | /* FIXME: support bi-directional use of TCP */ |
1195 | if (mq->specific_address == NULL) | 1195 | if (mq->specific_address == NULL) |
1196 | mq->specific_address = find_ready_address(neighbour); | 1196 | mq->specific_address = find_ready_address(neighbour); |
1197 | GNUNET_CONTAINER_DLL_remove (neighbour->messages_head, | ||
1198 | neighbour->messages_tail, | ||
1199 | mq); | ||
1200 | if (mq->specific_address == NULL) | 1197 | if (mq->specific_address == NULL) |
1201 | { | 1198 | { |
1202 | timeout = GNUNET_TIME_absolute_get_remaining (mq->timeout); | 1199 | timeout = GNUNET_TIME_absolute_get_remaining (mq->timeout); |
@@ -1210,6 +1207,9 @@ try_transmission_to_peer (struct NeighbourList *neighbour) | |||
1210 | #endif | 1207 | #endif |
1211 | if (mq->client != NULL) | 1208 | if (mq->client != NULL) |
1212 | transmit_send_ok (mq->client, neighbour, GNUNET_NO); | 1209 | transmit_send_ok (mq->client, neighbour, GNUNET_NO); |
1210 | GNUNET_CONTAINER_DLL_remove (neighbour->messages_head, | ||
1211 | neighbour->messages_tail, | ||
1212 | mq); | ||
1213 | GNUNET_free (mq); | 1213 | GNUNET_free (mq); |
1214 | return; /* nobody ready */ | 1214 | return; /* nobody ready */ |
1215 | } | 1215 | } |
@@ -1229,6 +1229,9 @@ try_transmission_to_peer (struct NeighbourList *neighbour) | |||
1229 | #endif | 1229 | #endif |
1230 | return; | 1230 | return; |
1231 | } | 1231 | } |
1232 | GNUNET_CONTAINER_DLL_remove (neighbour->messages_head, | ||
1233 | neighbour->messages_tail, | ||
1234 | mq); | ||
1232 | if (mq->specific_address->connected == GNUNET_NO) | 1235 | if (mq->specific_address->connected == GNUNET_NO) |
1233 | mq->specific_address->connect_attempts++; | 1236 | mq->specific_address->connect_attempts++; |
1234 | rl = mq->specific_address->ready_list; | 1237 | rl = mq->specific_address->ready_list; |