diff options
Diffstat (limited to 'src/transport')
-rw-r--r-- | src/transport/gnunet-communicator-tcp.c | 18 | ||||
-rw-r--r-- | src/transport/test_transport_plugin_cmd_simple_send_performance.c | 4 | ||||
-rw-r--r-- | src/transport/transport_api_cmd_send_simple_performance.c | 6 |
3 files changed, 16 insertions, 12 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 | } |
diff --git a/src/transport/test_transport_plugin_cmd_simple_send_performance.c b/src/transport/test_transport_plugin_cmd_simple_send_performance.c index 17325e369..9cd780705 100644 --- a/src/transport/test_transport_plugin_cmd_simple_send_performance.c +++ b/src/transport/test_transport_plugin_cmd_simple_send_performance.c | |||
@@ -135,7 +135,7 @@ handle_test (void *cls, | |||
135 | sender = GNUNET_new (struct Sender); | 135 | sender = GNUNET_new (struct Sender); |
136 | sender->time_first = time_send; | 136 | sender->time_first = time_send; |
137 | sender->mean_time = GNUNET_TIME_UNIT_ZERO; | 137 | sender->mean_time = GNUNET_TIME_UNIT_ZERO; |
138 | GNUNET_CONTAINER_multipeermap_put (senders, peer, sender, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY); | 138 | GNUNET_assert (GNUNET_OK == GNUNET_CONTAINER_multipeermap_put (senders, peer, sender, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY)); |
139 | } | 139 | } |
140 | 140 | ||
141 | if (GNUNET_TIME_UNIT_ZERO.rel_value_us == sender->mean_time.rel_value_us) | 141 | if (GNUNET_TIME_UNIT_ZERO.rel_value_us == sender->mean_time.rel_value_us) |
@@ -146,7 +146,7 @@ handle_test (void *cls, | |||
146 | } | 146 | } |
147 | else | 147 | else |
148 | { | 148 | { |
149 | double factor = sender->num_received/(sender->num_received + 1); | 149 | double factor = (double) sender->num_received/((double) sender->num_received + 1.0); |
150 | struct GNUNET_TIME_Relative s1; | 150 | struct GNUNET_TIME_Relative s1; |
151 | struct GNUNET_TIME_Relative s2; | 151 | struct GNUNET_TIME_Relative s2; |
152 | 152 | ||
diff --git a/src/transport/transport_api_cmd_send_simple_performance.c b/src/transport/transport_api_cmd_send_simple_performance.c index 7e195d9ef..d7850e007 100644 --- a/src/transport/transport_api_cmd_send_simple_performance.c +++ b/src/transport/transport_api_cmd_send_simple_performance.c | |||
@@ -66,12 +66,12 @@ struct SendSimplePerfState | |||
66 | /** | 66 | /** |
67 | * Size of the message in bytes. | 67 | * Size of the message in bytes. |
68 | */ | 68 | */ |
69 | int size; | 69 | unsigned int size; |
70 | 70 | ||
71 | /** | 71 | /** |
72 | * Maximum number of messages per peer. | 72 | * Maximum number of messages per peer. |
73 | */ | 73 | */ |
74 | int max_send; | 74 | unsigned int max_send; |
75 | }; | 75 | }; |
76 | 76 | ||
77 | struct MQWrapper | 77 | struct MQWrapper |
@@ -116,7 +116,7 @@ send_simple_single (void *cls) | |||
116 | now = GNUNET_TIME_absolute_get (); | 116 | now = GNUNET_TIME_absolute_get (); |
117 | mq_wrapper->num_send++; | 117 | mq_wrapper->num_send++; |
118 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 118 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
119 | "Sending simple test message with size %llu number %u with mq %p max %llu\n", | 119 | "Sending simple test message with size %u number %lu with mq %p max %u\n", |
120 | mq_wrapper->sss->size, | 120 | mq_wrapper->sss->size, |
121 | mq_wrapper->num_send, | 121 | mq_wrapper->num_send, |
122 | mq_wrapper->mq, | 122 | mq_wrapper->mq, |