aboutsummaryrefslogtreecommitdiff
path: root/src/transport
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport')
-rw-r--r--src/transport/gnunet-communicator-tcp.c18
-rw-r--r--src/transport/test_transport_plugin_cmd_simple_send_performance.c4
-rw-r--r--src/transport/transport_api_cmd_send_simple_performance.c6
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
77struct MQWrapper 77struct 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,