aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_udp.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/plugin_transport_udp.c')
-rw-r--r--src/transport/plugin_transport_udp.c18
1 files changed, 13 insertions, 5 deletions
diff --git a/src/transport/plugin_transport_udp.c b/src/transport/plugin_transport_udp.c
index 0a8c3cab4..f185c8738 100644
--- a/src/transport/plugin_transport_udp.c
+++ b/src/transport/plugin_transport_udp.c
@@ -2265,13 +2265,17 @@ process_udp_message (struct Plugin *plugin,
2265 udp_addr, 2265 udp_addr,
2266 udp_addr_len, 2266 udp_addr_len,
2267 GNUNET_HELLO_ADDRESS_INFO_NONE); 2267 GNUNET_HELLO_ADDRESS_INFO_NONE);
2268 if (NULL == (s = udp_plugin_lookup_session (plugin, address))) 2268 if (NULL ==
2269 (s = udp_plugin_lookup_session (plugin, address)))
2269 { 2270 {
2270 s = udp_plugin_create_session (plugin, 2271 s = udp_plugin_create_session (plugin,
2271 address, 2272 address,
2272 network_type); 2273 network_type);
2273 plugin->env->session_start (plugin->env->cls, 2274 plugin->env->session_start (plugin->env->cls,
2274 address, s, NULL, 0); 2275 address,
2276 s,
2277 NULL,
2278 0);
2275 notify_session_monitor (s->plugin, 2279 notify_session_monitor (s->plugin,
2276 s, 2280 s,
2277 GNUNET_TRANSPORT_SS_INIT); 2281 GNUNET_TRANSPORT_SS_INIT);
@@ -3566,9 +3570,13 @@ libgnunet_plugin_transport_udp_init (void *cls)
3566 p->sessions = GNUNET_CONTAINER_multipeermap_create (10, GNUNET_NO); 3570 p->sessions = GNUNET_CONTAINER_multipeermap_create (10, GNUNET_NO);
3567 p->defrag_ctxs = GNUNET_CONTAINER_heap_create ( 3571 p->defrag_ctxs = GNUNET_CONTAINER_heap_create (
3568 GNUNET_CONTAINER_HEAP_ORDER_MIN); 3572 GNUNET_CONTAINER_HEAP_ORDER_MIN);
3569 p->mst = GNUNET_SERVER_mst_create (&process_inbound_tokenized_messages, p); 3573 p->mst = GNUNET_SERVER_mst_create (&process_inbound_tokenized_messages,
3570 GNUNET_BANDWIDTH_tracker_init (&p->tracker, NULL, NULL, 3574 p);
3571 GNUNET_BANDWIDTH_value_init ((uint32_t) udp_max_bps), 30); 3575 GNUNET_BANDWIDTH_tracker_init (&p->tracker,
3576 NULL,
3577 NULL,
3578 GNUNET_BANDWIDTH_value_init ((uint32_t) udp_max_bps),
3579 30);
3572 LOG(GNUNET_ERROR_TYPE_DEBUG, 3580 LOG(GNUNET_ERROR_TYPE_DEBUG,
3573 "Setting up sockets\n"); 3581 "Setting up sockets\n");
3574 res = setup_sockets (p, 3582 res = setup_sockets (p,