diff options
Diffstat (limited to 'src/transport/gnunet-communicator-tcp.c')
-rw-r--r-- | src/transport/gnunet-communicator-tcp.c | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/src/transport/gnunet-communicator-tcp.c b/src/transport/gnunet-communicator-tcp.c index 7d4360bb0..db2aea552 100644 --- a/src/transport/gnunet-communicator-tcp.c +++ b/src/transport/gnunet-communicator-tcp.c | |||
@@ -1643,9 +1643,9 @@ pending_reversals_delete_it (void *cls, | |||
1643 | GNUNET_SCHEDULER_cancel (pending_reversal->timeout_task); | 1643 | GNUNET_SCHEDULER_cancel (pending_reversal->timeout_task); |
1644 | pending_reversal->timeout_task = NULL; | 1644 | pending_reversal->timeout_task = NULL; |
1645 | } | 1645 | } |
1646 | GNUNET_CONTAINER_multihashmap_remove (pending_reversals, | 1646 | GNUNET_assert (GNUNET_YES == GNUNET_CONTAINER_multihashmap_remove (pending_reversals, |
1647 | key, | 1647 | key, |
1648 | pending_reversal); | 1648 | pending_reversal)); |
1649 | GNUNET_free (pending_reversal->in); | 1649 | GNUNET_free (pending_reversal->in); |
1650 | GNUNET_free (pending_reversal); | 1650 | GNUNET_free (pending_reversal); |
1651 | return GNUNET_OK; | 1651 | return GNUNET_OK; |
@@ -1675,7 +1675,7 @@ check_and_remove_pending_reversal (struct sockaddr *in, sa_family_t sa_family, s | |||
1675 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, | 1675 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, |
1676 | "Removing invalid pending reversal for `%s'at `%s'\n", | 1676 | "Removing invalid pending reversal for `%s'at `%s'\n", |
1677 | GNUNET_i2s (&pending_reversal->target), | 1677 | GNUNET_i2s (&pending_reversal->target), |
1678 | GNUNET_a2s (in, sizeof (in))); | 1678 | GNUNET_a2s (in, sizeof (struct sockaddr))); |
1679 | pending_reversals_delete_it (NULL, &key, pending_reversal); | 1679 | pending_reversals_delete_it (NULL, &key, pending_reversal); |
1680 | } | 1680 | } |
1681 | GNUNET_free (natted_address); | 1681 | GNUNET_free (natted_address); |
@@ -3071,6 +3071,7 @@ create_proto_queue (struct GNUNET_NETWORK_Handle *sock, | |||
3071 | in->sa_family, | 3071 | in->sa_family, |
3072 | strerror (errno)); | 3072 | strerror (errno)); |
3073 | GNUNET_free (in); | 3073 | GNUNET_free (in); |
3074 | GNUNET_free (pq); | ||
3074 | return NULL; | 3075 | return NULL; |
3075 | } | 3076 | } |
3076 | if ((GNUNET_OK != GNUNET_NETWORK_socket_connect (sock, in, addrlen)) && | 3077 | if ((GNUNET_OK != GNUNET_NETWORK_socket_connect (sock, in, addrlen)) && |
@@ -3201,9 +3202,12 @@ pending_reversal_timeout (void *cls) | |||
3201 | 3202 | ||
3202 | GNUNET_assert (NULL != pending_reversal); | 3203 | GNUNET_assert (NULL != pending_reversal); |
3203 | 3204 | ||
3204 | GNUNET_CONTAINER_multihashmap_remove (pending_reversals, | 3205 | if (GNUNET_NO == GNUNET_CONTAINER_multihashmap_remove (pending_reversals, |
3205 | &key, | 3206 | &key, |
3206 | pending_reversal); | 3207 | pending_reversal)) |
3208 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, | ||
3209 | "No pending reversal found for address %s\n", | ||
3210 | GNUNET_a2s (in, sizeof (struct sockaddr))); | ||
3207 | GNUNET_free (pending_reversal->in); | 3211 | GNUNET_free (pending_reversal->in); |
3208 | GNUNET_free (pending_reversal); | 3212 | GNUNET_free (pending_reversal); |
3209 | } | 3213 | } |