diff options
Diffstat (limited to 'src/transport')
-rw-r--r-- | src/transport/Makefile.am | 9 | ||||
-rw-r--r-- | src/transport/gnunet-helper-transport-wlan-dummy.c | 6 | ||||
-rw-r--r-- | src/transport/gnunet-service-transport.c | 4 | ||||
-rw-r--r-- | src/transport/gnunet-service-transport_validation.c | 13 | ||||
-rw-r--r-- | src/transport/plugin_transport_http_server.c | 2 |
5 files changed, 29 insertions, 5 deletions
diff --git a/src/transport/Makefile.am b/src/transport/Makefile.am index d65da6bb6..e8c1f5d4a 100644 --- a/src/transport/Makefile.am +++ b/src/transport/Makefile.am | |||
@@ -295,7 +295,7 @@ noinst_LTLIBRARIES = \ | |||
295 | libgnunet_plugin_transport_template.la | 295 | libgnunet_plugin_transport_template.la |
296 | 296 | ||
297 | libgnunet_plugin_transport_tcp_la_SOURCES = \ | 297 | libgnunet_plugin_transport_tcp_la_SOURCES = \ |
298 | plugin_transport_tcp.c | 298 | plugin_transport_tcp.c |
299 | libgnunet_plugin_transport_tcp_la_LIBADD = \ | 299 | libgnunet_plugin_transport_tcp_la_LIBADD = \ |
300 | $(top_builddir)/src/hello/libgnunethello.la \ | 300 | $(top_builddir)/src/hello/libgnunethello.la \ |
301 | $(top_builddir)/src/statistics/libgnunetstatistics.la \ | 301 | $(top_builddir)/src/statistics/libgnunetstatistics.la \ |
@@ -1330,7 +1330,6 @@ test_transport_api_monitor_peers_peer2.conf\ | |||
1330 | test_transport_api_monitor_validation_peer1.conf\ | 1330 | test_transport_api_monitor_validation_peer1.conf\ |
1331 | test_transport_api_monitor_validation_peer2.conf\ | 1331 | test_transport_api_monitor_validation_peer2.conf\ |
1332 | test_transport_defaults.conf\ | 1332 | test_transport_defaults.conf\ |
1333 | test_transport_startonly.conf\ | ||
1334 | test_transport_api_disconnect_tcp_peer1.conf\ | 1333 | test_transport_api_disconnect_tcp_peer1.conf\ |
1335 | test_transport_api_disconnect_tcp_peer2.conf\ | 1334 | test_transport_api_disconnect_tcp_peer2.conf\ |
1336 | test_transport_api_timeout_http_peer1.conf\ | 1335 | test_transport_api_timeout_http_peer1.conf\ |
@@ -1350,4 +1349,8 @@ test_transport_api_http_reverse_peer2.conf \ | |||
1350 | perf_tcp_peer1.conf \ | 1349 | perf_tcp_peer1.conf \ |
1351 | perf_tcp_peer2.conf \ | 1350 | perf_tcp_peer2.conf \ |
1352 | test_transport_api_slow_ats_peer1.conf \ | 1351 | test_transport_api_slow_ats_peer1.conf \ |
1353 | test_transport_api_slow_ats_peer2.conf | 1352 | test_transport_api_slow_ats_peer2.conf \ |
1353 | tcp_connection_legacy.c \ | ||
1354 | tcp_server_mst_legacy.c \ | ||
1355 | tcp_server_legacy.c \ | ||
1356 | tcp_service_legacy.c | ||
diff --git a/src/transport/gnunet-helper-transport-wlan-dummy.c b/src/transport/gnunet-helper-transport-wlan-dummy.c index 63ed9c4b7..f02d8bdd7 100644 --- a/src/transport/gnunet-helper-transport-wlan-dummy.c +++ b/src/transport/gnunet-helper-transport-wlan-dummy.c | |||
@@ -121,6 +121,9 @@ send_mac_to_plugin (char *buffer, struct GNUNET_TRANSPORT_WLAN_MacAddress *mac) | |||
121 | * | 121 | * |
122 | * @param cls the 'struct SendBuffer' to copy the converted message to | 122 | * @param cls the 'struct SendBuffer' to copy the converted message to |
123 | * @param hdr inbound message from the FIFO | 123 | * @param hdr inbound message from the FIFO |
124 | * @return #GNUNET_OK on success, | ||
125 | * #GNUNET_NO to stop further processing (no error) | ||
126 | * #GNUNET_SYSERR to stop further processing with error | ||
124 | */ | 127 | */ |
125 | static int | 128 | static int |
126 | stdin_send (void *cls, | 129 | stdin_send (void *cls, |
@@ -167,6 +170,9 @@ stdin_send (void *cls, | |||
167 | * | 170 | * |
168 | * @param cls the 'struct SendBuffer' to copy to | 171 | * @param cls the 'struct SendBuffer' to copy to |
169 | * @param hdr the message we received to copy to the buffer | 172 | * @param hdr the message we received to copy to the buffer |
173 | * @return #GNUNET_OK on success, | ||
174 | * #GNUNET_NO to stop further processing (no error) | ||
175 | * #GNUNET_SYSERR to stop further processing with error | ||
170 | */ | 176 | */ |
171 | static int | 177 | static int |
172 | file_in_send (void *cls, | 178 | file_in_send (void *cls, |
diff --git a/src/transport/gnunet-service-transport.c b/src/transport/gnunet-service-transport.c index 6b354df98..124260c41 100644 --- a/src/transport/gnunet-service-transport.c +++ b/src/transport/gnunet-service-transport.c | |||
@@ -688,6 +688,8 @@ handle_client_hello (void *cls, | |||
688 | { | 688 | { |
689 | struct TransportClient *tc = cls; | 689 | struct TransportClient *tc = cls; |
690 | 690 | ||
691 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | ||
692 | "Received HELLO message\n"); | ||
691 | GST_validation_handle_hello (message); | 693 | GST_validation_handle_hello (message); |
692 | GNUNET_SERVICE_client_continue (tc->client); | 694 | GNUNET_SERVICE_client_continue (tc->client); |
693 | } | 695 | } |
@@ -2802,7 +2804,7 @@ run (void *cls, | |||
2802 | GNUNET_assert (NULL != GST_my_private_key); | 2804 | GNUNET_assert (NULL != GST_my_private_key); |
2803 | 2805 | ||
2804 | GNUNET_log(GNUNET_ERROR_TYPE_INFO, | 2806 | GNUNET_log(GNUNET_ERROR_TYPE_INFO, |
2805 | "My identity is `%4s'\n", | 2807 | "My identity is `%s'\n", |
2806 | GNUNET_i2s_full (&GST_my_identity)); | 2808 | GNUNET_i2s_full (&GST_my_identity)); |
2807 | 2809 | ||
2808 | GNUNET_SCHEDULER_add_shutdown (&shutdown_task, | 2810 | GNUNET_SCHEDULER_add_shutdown (&shutdown_task, |
diff --git a/src/transport/gnunet-service-transport_validation.c b/src/transport/gnunet-service-transport_validation.c index 27c3c7041..cd5aeb5e2 100644 --- a/src/transport/gnunet-service-transport_validation.c +++ b/src/transport/gnunet-service-transport_validation.c | |||
@@ -1347,6 +1347,9 @@ GST_validation_handle_address (const struct GNUNET_HELLO_Address *address) | |||
1347 | if (NULL == papi) | 1347 | if (NULL == papi) |
1348 | { | 1348 | { |
1349 | /* This plugin is currently unvailable ... ignore */ | 1349 | /* This plugin is currently unvailable ... ignore */ |
1350 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | ||
1351 | "No plugin available for %s\n", | ||
1352 | address->transport_name); | ||
1350 | return; | 1353 | return; |
1351 | } | 1354 | } |
1352 | ve = find_validation_entry (address); | 1355 | ve = find_validation_entry (address); |
@@ -1358,6 +1361,13 @@ GST_validation_handle_address (const struct GNUNET_HELLO_Address *address) | |||
1358 | GNUNET_i2s (&ve->address->peer)); | 1361 | GNUNET_i2s (&ve->address->peer)); |
1359 | ve->revalidation_task = GNUNET_SCHEDULER_add_now (&revalidate_address, ve); | 1362 | ve->revalidation_task = GNUNET_SCHEDULER_add_now (&revalidate_address, ve); |
1360 | } | 1363 | } |
1364 | else | ||
1365 | { | ||
1366 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | ||
1367 | "Validation already running for address `%s' of %s\n", | ||
1368 | GST_plugins_a2s (ve->address), | ||
1369 | GNUNET_i2s (&ve->address->peer)); | ||
1370 | } | ||
1361 | } | 1371 | } |
1362 | 1372 | ||
1363 | 1373 | ||
@@ -1657,6 +1667,9 @@ GST_validation_handle_hello (const struct GNUNET_MessageHeader *hello) | |||
1657 | sizeof (struct GNUNET_PeerIdentity))) | 1667 | sizeof (struct GNUNET_PeerIdentity))) |
1658 | { | 1668 | { |
1659 | /* got our own HELLO, how boring */ | 1669 | /* got our own HELLO, how boring */ |
1670 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
1671 | "Validation received our own HELLO (%s), ignoring\n", | ||
1672 | GNUNET_i2s (&pid)); | ||
1660 | return GNUNET_OK; | 1673 | return GNUNET_OK; |
1661 | } | 1674 | } |
1662 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1675 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
diff --git a/src/transport/plugin_transport_http_server.c b/src/transport/plugin_transport_http_server.c index d9fade44f..6a9c1b0ba 100644 --- a/src/transport/plugin_transport_http_server.c +++ b/src/transport/plugin_transport_http_server.c | |||
@@ -1651,7 +1651,7 @@ server_send_callback (void *cls, | |||
1651 | * | 1651 | * |
1652 | * @param cls current session as closure | 1652 | * @param cls current session as closure |
1653 | * @param message the message to be forwarded to transport service | 1653 | * @param message the message to be forwarded to transport service |
1654 | * @return #GNUNET_OK | 1654 | * @return #GNUNET_OK (all OK) |
1655 | */ | 1655 | */ |
1656 | static int | 1656 | static int |
1657 | server_receive_mst_cb (void *cls, | 1657 | server_receive_mst_cb (void *cls, |