aboutsummaryrefslogtreecommitdiff
path: root/src/transport/gnunet-communicator-tcp.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/gnunet-communicator-tcp.c')
-rw-r--r--src/transport/gnunet-communicator-tcp.c18
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}